مخرجات مراكز الأحداث من Azure Stream Analytics
تعد خدمة Azure Event Hubs عبارة عن أداة لأحداث النشر والاشتراك قابلة للتطوير بدرجة كبيرة. يمكنه جمع ملايين الأحداث في الثانية. أحد استخدامات مركز الأحداث كمخرجات هو عندما يصبح إخراج مهمة Stream Analytics مدخلا لمهمة بث أخرى. للحصول على معلومات حول الحد الأقصى لحجم الرسالة وتحسين حجم الدفعة، راجع قسم حجم دفعة الإخراج .
تكوين الإخراج
يحتوي الجدول التالي على المعلمات اللازمة لتكوين تدفقات البيانات من محاور الأحداث كمخرجات.
| اسم الخاصية | الوصف |
|---|---|
| اسم مستعار للإخراج | اسم مألوف يستخدم في الاستعلامات لتوجيه إخراج الاستعلام إلى مركز الأحداث هذا. |
| مساحة اسم مركز الحدث | حاوية لمجموعة من كيانات المراسلة. عند إنشاء مركز أحداث جديد، فإنك تنشئ أيضا مساحة اسم لمركز الأحداث. |
| اسم Event Hub | اسم إخراج مركز الأحداث. |
| اسم نهج مركز الأحداث | سياسة الوصول المشترك، والتي يمكنك إنشاؤها في علامة التبويب تكوين في مركز الأحداث. تحتوي كل سياسة وصول مشتركة على اسم وأذونات تقوم بتعيينها ومفاتيح وصول. |
| مفتاح سياسة مركز الأحداث | مفتاح الوصول المشترك المستخدم لمصادقة الوصول إلى مساحة اسم مركز الأحداث. |
| عمود مفتاح التقسيم | اختياري. عمود يحتوي على مفتاح القسم لإخراج مركز الأحداث. |
| تنسيق تسلسل الأحداث | تنسيق التسلسل لبيانات الإخراج. يتم دعم JSON وCSV وAvro. |
| الترميز | بالنسبة إلى CSV وJSON، فإن تنسيق UTF-8 هو تنسيق الترميز الوحيد المدعوم في الوقت الحالي. |
| المحدِد | ينطبق فقط على تسلسل CSV. يدعم Stream Analytics عددا من المحددات الشائعة لتسلسل البيانات بتنسيق CSV. القيم المدعومة هي الفاصلة، والفاصلة المنقوطة، والمسافة، وعلامة الجدولة، والشريط العمودي. |
| تنسيق | ينطبق فقط على تسلسل JSON. يحدد الخط المنفصل أن الإخراج يتم تنسيقه عن طريق فصل كل كائن JSON بواسطة سطر جديد. إذا قمت بتحديد خط منفصل، قراءة JSON كائنا واحدا في كل مرة. المحتوى بأكمله في حد ذاته لن يكون JSON صالحا. يحدد الصفيف أن الإخراج منسق كصفيف من كائنات JSON. |
| أعمدة الملكية | اختياري. أعمدة مفصولة بفواصل يجب إرفاقها كخصائص مستخدم للرسالة الصادرة بدلاً من الحمولة. مزيد من المعلومات حول هذه الميزة موجودة في القسم خصائص بيانات التعريف المخصصة للإخراج. |
التقسيم
يختلف التقسيم حسب محاذاة القسم. عندما يكون مفتاح القسم الخاص بإخراج مركز الحدث محاذيا بنفس القدر مع خطوة الاستعلام الأولية (السابقة)، يكون عدد الكتاب هو نفسه عدد الأقسام في إخراج مركز الحدث. يستخدم كل كاتب فئة EventHubSender لإرسال الأحداث إلى القسم المحدد. عندما لا يكون مفتاح القسم لإخراج مركز الحدث محاذيا لخطوة الاستعلام الأولية (السابقة)، يكون عدد الكتاب هو نفسه عدد الأقسام في تلك الخطوة السابقة. يستخدم كل كاتب فئة SendBatchAsync في EventHubClient لإرسال الأحداث إلى كافة أقسام الإخراج.
حجم دفعة الإخراج
الحد الأقصى لحجم الرسالة هو 256 كيلوبايت أو 1 ميغابايت لكل رسالة. لمزيد من المعلومات، راجع حدود مراكز الأحداث. عندما لا تتم محاذاة تقسيم الإدخال/الإخراج، يتم تعبئة كل حدث بشكل EventData فردي وإرساله في دفعة تصل إلى الحد الأقصى لحجم الرسالة. يحدث هذا أيضا إذا تم استخدام خصائص بيانات التعريف المخصصة . عند محاذاة تقسيم الإدخال/الإخراج، يتم تعبئة أحداث متعددة في مثيل واحد EventData ، حتى الحد الأقصى لحجم الرسالة، وإرسالها.
خصائص بيانات التعريف المخصصة للإخراج
يمكنك إرفاق أعمدة الاستعلام كخصائص مستخدم إلى رسائلك الصادرة. لا تدخل هذه الأعمدة في الحمولة. الخصائص موجودة في شكل قاموس على رسالة الإخراج. المفتاح هو اسم العمود والقيمة هي قيمة العمود في قاموس الخصائص. يتم دعم جميع أنواع بيانات Stream Analytics باستثناء Record وArray.
في المثال التالي، تتم إضافة الحقول DeviceIdDeviceStatus إلى بيانات التعريف.
استخدم الاستعلام التالي:
select *, DeviceId, DeviceStatus from iotHubInputتكوين
DeviceId,DeviceStatusكأعمدة خاصية في الإخراج.
الصورة التالية هي لخصائص رسالة الإخراج المتوقعة التي تم فحصها في EventHub باستخدام مستكشف ناقل الخدمة.
