معالجة البيانات من مركز الأحداث باستخدام تحليلات Azure Stream

تسهل خدمة Azure Stream Analytics استيعاب بيانات البث ومعالجتها وتحليلها من مراكز أحداث Azure، مما يتيح رؤى قوية لدفع الإجراءات في الوقت الفعلي. يمكنك استخدام مدخل Microsoft Azure لتصور البيانات الواردة وكتابة استعلام Stream Analytics. بمجرد أن يصبح الاستعلام جاهزاً، يمكنك نقله إلى الإنتاج ببضع نقرات فقط.

المزايا الهامة

فيما يلي الفوائد الرئيسية لمراكز أحداث Azure وتكامل Azure Stream Analytics:

  • معاينة البيانات - يمكنك معاينة البيانات الواردة من مركز الأحداث في مدخل Microsoft Azure.
  • اختبار استعلامك - قم بإعداد استعلام تحويل واختبره مباشرةً في مدخل Microsoft Azure. للحصول على بناء جملة لغة الاستعلام، راجع وثائق لغة استعلام Stream Analytics.
  • نشر استعلامك في الإنتاج - يمكنك نشر الاستعلام في الإنتاج عن طريق إنشاء وظيفة Azure Stream Analytics وبدء تشغيلها.

التدفق من طرف إلى طرف

هام

إذا لم تكن عضواً في أدوار مالك أو مساهم على مستوى اشتراك Azure، يجب أن تكون عضواً في دور Stream Analytics Query Tester في مستوى اشتراك Azure لإكمال الخطوات الواردة في هذا القسم بنجاح. يسمح لك هذا الدور بإجراء استعلامات الاختبار دون إنشاء وظيفة تحليلات دفق البيانات أولاً. للحصول على إرشادات عن تعيين دور لمستخدم، راجع تعيين أدوار مجال التطبيق (AD) للمستخدمين.

  1. تسجيل الدخول إلى ⁧⁩مدخل Microsoft Azure⁧⁩.

  2. انتقل إلى مساحة اسم مركز الأحداث ثم انتقل إلى مركز الأحداث، الذي يحتوي على البيانات الواردة.

  3. حدد معالجة البيانات في صفحة مركز الحدث أو حدد معالجة البيانات في القائمة اليسرى.

    لقطة شاشة تعرض صفحة بيانات العملية لمركز الأحداث.

  4. حدد البدء في لوحة تمكين نتائج التحليلات في الوقت الحقيقي من الأحداث .

    لقطة شاشة تعرض صفحة بيانات العملية مع تحديد تمكين نتائج التحليلات في الوقت الحقيقي من تجانب الأحداث.

  5. تشاهد صفحة استعلام مع القيم التي تم تعيينها مسبقاً للحقول التالية:

    1. مركز الأحداث الخاص بك كمدخل للاستعلام.

    2. نموذج استعلام SQL مع عبارة SELECT.

    3. إخراج الاسم المستعار للإشارة إلى نتائج اختبار الاستعلام.

      لقطة شاشة تعرض محرر الاستعلام لاستعلام Stream Analytics.

      ملاحظة

      عند استخدام هذه الميزة للمرة الأولى، تطلب هذه الصفحة إذنك لإنشاء مجموعة من المستهلكين ونهج لمركز الأحداث لمعاينة البيانات الواردة.

  6. حدد إنشاء في جزء معاينة الإدخال كما هو موضح في الصورة السابقة.

  7. سترى على الفور لقطة لأحدث البيانات الواردة في علامة التبويب هذه.

    • يتم الكشف عن نوع التسلسل في البيانات تلقائيا (JSON/CSV). يمكنك تغييره يدويا كذلك إلى JSON / CSV / AVRO.

    • يمكنك معاينة البيانات الواردة بتنسيق الجدول أو بتنسيق أولي.

    • إذا لم تكن بياناتك المعروضة حديثة، فحدد تحديث لمشاهدة آخر الأحداث.

      فيما يلي مثال على البيانات بتنسيق الجدول:

      لقطة شاشة لنافذة معاينة الإدخال في جزء النتائج من صفحة بيانات العملية بتنسيق جدول.

      فيما يلي مثال على البيانات بالتنسيق الأولي:

      لقطة شاشة لنافذة معاينة الإدخال في جزء النتائج من صفحة بيانات العملية بالتنسيق الأولي.

  8. حدد اختبار الاستعلام لمشاهدة لقطة لنتائج الاختبار لاستعلامك في علامة التبويب نتائج الاختبار. يمكنك أيضاً تنزيل النتائج.

    لقطة شاشة لنافذة معاينة الإدخال في جزء النتائج مع نتائج الاختبار.

  9. اكتب الاستعلام الخاص بك لتحويل البيانات. راجع مرجع لغة الاستعلام في Stream Analytics .

  10. بمجرد اختبار الاستعلام وتريد نقله إلى الإنتاج، حدد إنشاء وظيفة Stream Analytics.

    لقطة شاشة لصفحة الاستعلام مع تحديد ارتباط مهمة إنشاء Stream Analytics.

  11. اتبع الخطوات التالية في صفحة "وظيفة Stream Analytics جديدة":

    1. حدد اسما للوظيفة.

    2. حدد اشتراك Azure حيث تريد إنشاء الوظيفة.

    3. حدد مجموعة الموارد لمورد وظيفة Stream Analytics.

    4. حدد موقع الوظيفة.

    5. بالنسبة إلى اسم نهج مراكز الأحداث، قم بإنشاء نهج جديد أو حدد نهج موجود.

    6. بالنسبة لمجموعة مستهلكين مراكز الأحداث، قم بإنشاء مجموعة مستهلكين جديدة أو حدد مجموعة مستهلكين موجودة.

    7. حدد Create لإنشاء وظيفة Stream Analytics.

      لقطة شاشة تعرض نافذة وظيفة Stream Analytics الجديدة.

      ملاحظة

      نوصي بإنشاء مجموعة مستهلكين ونهج لكل وظيفة جديدة في Azure Stream Analytics تقوم بإنشائها من صفحة Event Hubs. تسمح مجموعات المستهلكين بخمسة قراء متزامنين فقط، لذا فإن توفير مجموعة مستهلكين مخصصة لكل وظيفة سيؤدي إلى تجنب أي أخطاء قد تنشأ عن تجاوز هذا الحد. يسمح لك نهج مخصص بتدوير المفتاح أو إبطال الأذونات دون التأثير على الموارد الأخرى.

  12. يتم الآن إنشاء مهمة Stream Analytics حيث يكون الاستعلام هو نفسه الذي قمت باختباره، والمدخلات هي مركز الأحداث.

    لقطة شاشة تعرض صفحة وظيفة Stream Analytics مع ارتباط لإضافة إخراج.

  13. أضف إخراجا من اختيارك.

  14. انتقل مرة أخرى إلى صفحة وظيفة Stream Analytics بالنقر فوق اسم المهمة في ارتباط التنقل.

  15. حدد تحرير الاستعلام أعلى نافذة الاستعلام .

  16. قم بالتحديث [OutputAlias] باسم الإخراج الخاص بك، وحدد Save query link أعلى الاستعلام. أغلق صفحة الاستعلام عن طريق تحديد X في الزاوية العلوية اليسرى.

  17. الآن، في صفحة وظيفة Stream Analytics، حدد Start على شريط الأدوات لبدء المهمة.

    لقطة شاشة لنافذة Start job لوظيفة Stream Analytics.

Access

المشكلة : لا يمكن للمستخدم الوصول إلى بيانات المعاينة لأنه ليس لديه الأذونات الصحيحة على الاشتراك.

الخيار 1: يجب إضافة المستخدم الذي يريد الإصدار الأولي من البيانات الواردة كمساهم في الاشتراك.

الخيار 2: يحتاج المستخدم إلى أن تتم إضافته كدور لمختبِر استعلام Stream Analytics عند الاشتراك. انتقل إلى التحكم في الوصول للاشتراك. أضف تعيين دور جديد للمستخدم باعتباره دور «Stream Analytics Query Tester».

الخيار 3: بإمكان المستخدم إنشاء وظيفة Azure Stream Analytics. قم بتعيين الإدخال كمركز الحدث هذا وانتقل إلى "Query" لمعاينة البيانات الواردة من مركز الأحداث هذا.

الخيار 4: يمكن للمسؤول إنشاء دور مخصص في الاشتراك. أضف أذونات الوصول التالية إلى الدور المخصص ثم أضف المستخدم إلى الدور المخصص الجديد.

لقطات شاشة تعرض صفحة أذونات Microsoft.StreamAnalytics.

وحدات البث

يتم تعيين وظيفة Azure Stream Analytics الافتراضية على ثلاث وحدات دفق (SUs). لضبط هذا الإعداد، حدد مقياس في القائمة اليمنى في صفحة وظيفة Stream Analytics في مدخل Microsoft Azure. لمعرفة المزيد حول وحدات البث، راجع فهم وحدات البث وضبطها .

لقطات شاشة تعرض صفحة المقياس لوظيفة Stream Analytics.

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

لمعرفة المزيد حول استعلامات Stream Analytics، راجع Stream Analytics Query Language