إخراج موضوعات ناقل الخدمة من Azure Stream Analytics

  • مقالة
  • قراءة خلال 3 دقائق

توفر قوائم انتظار Service Bus طريقة اتصال فردية من المرسل إلى المتلقي. توفر موضوعات حافلة الخدمة شكلا واحدا إلى أكثر من أشكال الاتصال.

يسرد الجدول التالي أسماء الخصائص وأوصافها لإنشاء مخرجات موضوع Service Bus.

اسم الخاصية الوصف
اسم مستعار للإخراج اسم مألوف يُستخدم في الاستعلامات لتوجيه إخراج الاستعلام إلى موضوع Service Bus هذا.
مساحة اسم Service Bus حاوية لمجموعة من كيانات المراسلة. عند إنشاء مركز أحداث جديد، يمكنك أيضا إنشاء مساحة اسم ناقل الخدمة.
اسم الموضوع الموضوعات هي كيانات مراسلة، على غرار مراكز الأحداث وقوائم الانتظار. وهي مصممة لجمع تدفقات الأحداث من الأجهزة والخدمات. عند إنشاء موضوع، يتم أيضا إعطاؤه اسما محددا. لا تتوفر الرسائل المرسلة إلى موضوع ما ما لم يتم إنشاء اشتراك، لذا تأكد من وجود اشتراك واحد أو أكثر ضمن الموضوع.
اسم نهج الموضوع عند إنشاء موضوع "ناقل الخدمة"، يمكنك أيضا إنشاء نهج وصول مشترك على علامة التبويب تكوين في الموضوع. تحتوي كل سياسة وصول مشتركة على اسم وأذونات تقوم بتعيينها ومفاتيح وصول.
مفتاح نهج الموضوع مفتاح الوصول المشترك المستخدم لمصادقة الوصول إلى مساحة اسم ناقل الخدمة.
تنسيق تسلسل الأحداث تنسيق التسلسل لبيانات الإخراج. يتم دعم JSON وCSV وAvro.
الترميز إذا كنت تستخدم تنسيق CSV أو JSON، فيجب تحديد ترميز. UTF-8 هو تنسيق الترميز الوحيد المدعوم في الوقت الحالي.
المحدِد ينطبق فقط على تسلسل CSV. يدعم Stream Analytics عددا من المحددات الشائعة لتسلسل البيانات بتنسيق CSV. القيم المدعومة هي الفاصلة، والفاصلة المنقوطة، والمسافة، وعلامة الجدولة، والشريط العمودي.
أعمدة الملكية ‏‏اختياري. أعمدة مفصولة بفواصل يجب إرفاقها كخصائص مستخدم للرسالة الصادرة بدلاً من الحمولة. مزيد من المعلومات حول هذه الميزة موجودة في القسم خصائص بيانات التعريف المخصصة للإخراج.
أعمدة خصائص النظام ‏‏اختياري. أزواج القيم الرئيسية لخصائص النظام وأسماء الأعمدة المقابلة التي يجب إرفاقها بالرسالة الصادرة بدلاً من الحمولة.

يعتمد عدد الأقسام على رمز SKU لناقل الخدمة وحجمه. مفتاح القسم هو قيمة عدد صحيح فريد لكل قسم.

التقسيم

يتم اختيار التقسيم تلقائيا. يعتمد عدد الأقسام على رمز SKU لناقل الخدمة وحجمه. مفتاح القسم هو قيمة عدد صحيح فريد لكل قسم. عدد كتاب المخرجات هو نفسه عدد الأقسام في موضوع الإخراج.

حجم دفعة الإخراج

الحد الأقصى لحجم الرسالة هو 256 كيلوبايت لكل رسالة للطبقة القياسية و 1 ميغابايت للطبقة Premium. لمزيد من المعلومات، راجع حدود ناقل الخدمة. للتحسين، استخدم حدثا واحدا لكل رسالة.

خصائص بيانات التعريف المخصصة للإخراج

يمكنك إرفاق أعمدة الاستعلام كخصائص مستخدم إلى رسائلك الصادرة. لا تدخل هذه الأعمدة في الحمولة. الخصائص موجودة في شكل قاموس على رسالة الإخراج. المفتاح هو اسم العمود والقيمة هي قيمة العمود في قاموس الخصائص. يتم دعم جميع أنواع بيانات Stream Analytics باستثناء Record وArray.

في المثال التالي، تتم إضافة الحقول DeviceIdDeviceStatus إلى بيانات التعريف.

  1. استخدم الاستعلام التالي:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. تكوين DeviceId,DeviceStatus كأعمدة خاصية في الإخراج.

    Property columns

الصورة التالية هي لخصائص رسالة الإخراج المتوقعة التي تم فحصها في EventHub باستخدام مستكشف ناقل الخدمة.

Event custom properties

خصائص النظام

يمكنك إرفاق أعمدة الاستعلام كخصائص النظام برسائل قائمة انتظار ناقل الخدمة الصادرة أو رسائل الموضوع. لا تنتقل هذه الأعمدة إلى الحمولة بدلا من ذلك ، يتم ملء خاصية نظام BrokeredMessage المقابلة بقيم عمود الاستعلام. يتم دعم خصائص النظام هذه - MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc.

يتم تحليل قيم السلسلة الخاصة بهذه الأعمدة كنوع قيمة لخاصية النظام المقابلة ويتم التعامل مع أي حالات فشل في التحليل على أنها أخطاء في البيانات. يتم توفير هذا الحقل كتنسيق كائن JSON. التفاصيل حول هذا التنسيق هي كما يلي:

  • محاط بأقواس معقوفة {}.
  • مكتوبة في أزواج مفتاح/قيمة.
  • يجب أن تكون المفاتيح والقيم عبارة عن سلاسل.
  • المفتاح هو اسم خاصية النظام والقيمة هي اسم عمود الاستعلام.
  • المفاتيح والقيم مفصولة بنقطتين.
  • يتم فصل كل زوج مفتاح/قيمة بفاصلة.

يوضح هذا كيفية استخدام هذه الخاصية -

  • الاستعلام: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • أعمدة خصائص النظام: { "MessageId": "column1", "PartitionKey": "column2"}

يؤدي هذا إلى تعيين MessageId على رسائل قائمة انتظار Service Bus مع قيم column1 ويتم تعيين PartitionKey مع قيم column2.

الخطوات التالية