إنشاء لوحات معلومات Power BI في الوقت الحقيقي باستخدام Stream Analytics بدون محرر تعليمات برمجية

يوضح هذا الدرس كيفية استخدام محرر الشيفرة بدون كود في Stream Analytics لحساب التجميعات على تدفقات البيانات في الوقت الحقيقي وتخزينها في Azure Synapse Analytics.

في هذا البرنامج التعليمي، تتعلم كيفية:

• قم بتوزيع منشئ الأحداث الذي يرسل البيانات إلى مركز الأحداث الخاص بك
• أنشئ وظيفة تحليلات التدفق باستخدام محرر بدون كود
• مراجعة بيانات الإدخال والمخطط
• حدد الحقول للتجميع حسبها وحدد التجميعات مثل العدد
• Configure Azure Synapse Analytics التي تكتب عليها النتائج
• تشغيل وظيفة Stream Analytics
• تصور البيانات في Power BI

المتطلبات الأساسية

قبل أن تبدأ، تأكد من إكمال الخطوات التالية:

1. إذا لم يكن لديك اشتراك Azure، فأنشئ حسابًا مجانًا.
2. نشر مولد الأحداث TollApp على Azure. استخدم هذا الرابط لنشر قالب TollApp Azure. اضبط المعامل interval على 1. استخدم مجموعة موارد جديدة لهذه الخطوة.
3. أنشئ مساحة عمل Azure Synapse Analytics باستخدام تجمع SQL مخصص.
4. أنشئ جدولا مسماة carsummary باستخدام مجموعة SQL المخصصة لديك. شغل سكريبت SQL التالي:

   CREATE TABLE carsummary   
   (  
       Make nvarchar(20),  
       CarCount int,
   	times datetime
   )
   WITH ( CLUSTERED COLUMNSTORE INDEX ) ;
   

لا تستخدم أي محرر كود لإنشاء وظيفة Stream Analytics

1. حدد موقع مجموعة الموارد التي نشرت فيها مولد أحداث TollApp.

2. حدد namespace في مراكز الأحداث.

3. في صفحة مساحة أسماء مراكز الأحداث ، اختر مراكز الأحداث تحت الكيانات في القائمة اليسرى.

4. اختر الحالة entrystream .

   

5. تحت قسم الميزات ، اذهب إلى بيانات العملية ثم اختر ابدأ في قالب البدء مع لوحة فارغة .

   

6. قم بتسمية وظيفتك carsummary وحدد إنشاء.

   

7. في صفحة تكوين event hub، قم بتأكيد الإعدادات التالية، ثم حدد Connect.

   1. بالنسبة إلى مجموعة المستهلكين، حدد استخدام موجود، ثم حدد افتراضي.

   2. بالنسبة إلى نوع التسلسل، تأكد من تحديد JSON .

   3. بالنسبة إلى وضع المصادقة، تأكد من استخدام سلسلة الاتصال للاتصال بمركز الأحداث: سلسلة الاتصال.

      

8. خلال ثوان قليلة، ترى بيانات الإدخال العينة والمخطط. يمكنك اختيار حذف الحقول، أو إعادة تسمية الحقول، أو تغيير أنواع البيانات.

   

9. حدد Operations على شريط الأوامر ثم حدد Group by.

   

10. حدد المربع Group by على اللوحة وقم بتوصيلها بلوحة مركز الحدث.

    

11. تكوين المربع Group by عن طريق تحديد:

    1. التجميع على هيئة عدد.

    2. حقل كصنع، وهو حقل متداخل داخل CarModel.

    3. حدد إضافة.

       

    4. في قسم الإعدادات :

       1. بالنسبة إلى تجميعات المجموعة حسب، حدد إنشاء.

       2. بالنسبة للنافذة الزمنية، تأكد من تعيين القيمة إلى Tumbling.

       3. للمدة، أدخل 3 دقائق.

       4. حدد تم في أسفل الصفحة.

          

12. حدد تجميع حسب، ولاحظ البيانات المجمعة في علامة التبويب معاينة البيانات في أسفل الصفحة.

    

13. في شريط الأوامر، حدد العمليات ثم إدارة الحقول.

14. توصيل تجانبات الحقول "تجميع حسب" و"إدارة".

15. في صفحة إدارة الحقول ، اتبع الخطوات التالية:

    1. أضف الحقل Make كما هو موضح في الصورة التالية، ثم حدد Add.

       

    2. حدد إضافة.

       

16. حدد Add all fields في صفحة تكوين Manage Fields.

    

17. حدد ... بجوار الحقول، وحدد Edit لإعادة تسميتها.

    • COUNT_make إلى CarCount

    • Window_End_Time إلى مرة

      

18. حدد تم في صفحة إدارة الحقول . يجب أن تظهر صفحة إدارة الحقول كما هو موضح في الصورة التالية.

    

19. حدد تجانب إدارة الحقول ، واطلع على البيانات المتدفقة إلى العملية في علامة التبويب معاينة البيانات في أسفل الصفحة.

    

20. في شريط الأوامر، حدد Outputs، ثم حدد Synapse.

    

21. قم بتوصيل مربع Synapse بلوحة إدارة الحقول على لوحتك.

22. في صفحة إعدادات Synapse ، اتبع الخطوات التالية:

    1. إذا لم يتم تعيين حساب تخزين الوظيفة بالفعل، فحدد حساب Azure Data Lake Storage في مجموعة الموارد. إنه حساب التخزين الذي يستخدمه Synapse SQL لتحميل البيانات في مستودع البيانات الخاص بك.

       

    2. حدد اشتراك Azure حيث يوجد Azure Synapse Analytics.

    3. حدد قاعدة بيانات تجمع SQL المخصص الذي استخدمته لإنشاء carsummary الجدول في القسم السابق.

    4. أدخل اسم المستخدم وكلمة المرور للمصادقة.

    5. أدخل اسم الجدول ك carsummary.

    6. حدد اتصال. ترى نتائج عينات مكتوبة على جدول Synapse SQL الخاص بك.

       

23. حدد لوحة Synapse واطلع على علامة التبويب معاينة البيانات في أسفل الصفحة. ترى البيانات المتدفقة إلى تجمع SQL المخصص.

    

24. حدد Save في الشريط العلوي لحفظ وظيفتك ثم حدد Start.

25. في صفحة Start Stream Analytics Job ، حدد Start لتشغيل وظيفتك.

    

26. ثم ترى قائمة بجميع وظائف Stream Analytics التي تم إنشاؤها باستخدام محرر التعليمات البرمجية. وفي غضون دقيقتين، تنتقل مهمتك إلى حالة قيد التشغيل . اختر زر التحديث في الصفحة لرؤية تغير الحالة من إنشاء -> بدء -> تشغيل.

    

قم بإنشاء تصور Power BI

1. حمل أحدث إصدار من Power BI Desktop.

2. استخدم موصل Power BI ل Azure Synapse SQL.

   

3. اتصل بقاعدة بياناتك باستخدام DirectQuery، واستخدم هذا الاستعلام لجلب البيانات من قاعدة بياناتك

   SELECT [Make],[CarCount],[times]
   FROM [dbo].[carsummary]
   WHERE times >= DATEADD(day, -1, GETDATE())
   

   

   انتقل إلى تبويب قاعدة البيانات ، وأدخل بيانات اعتمادك (اسم المستخدم وكلمة المرور) للاتصال بقاعدة البيانات وتشغيل الاستعلام.

4. اختر تحميل لتحميل البيانات إلى Power BI.

5. يمكنك بعد ذلك إنشاء مخطط خطي باستخدام

   • المحور السيني مرات
   • المحور Y مثل CarCount
   • الأسطورة كما تجعلك ترى مخططا يمكنك نشره. يمكنك تكوين التحديث التلقائي للصفحة وتعيينه إلى 3 دقائق للحصول على طريقة عرض في الوقت الحقيقي.

المزيد من الخيارات

بجانب Azure Synapse SQL، يمكنك أيضا استخدام قاعدة بيانات SQL كمخرج محرر بدون كود لاستقبال بيانات البث. ثم استخدم موصل Power BI للاتصال بقاعدة بيانات SQL مع قاعدة بياناتك باستخدام DirectQuery لبناء لوحة التحكم في الوقت الحقيقي.

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

تنظيف الموارد

1. حدد موقع مركز الأحداث الخاص بك واطلع على قائمة وظائف تحليلات التدفق تحت قسم بيانات العمليات . أوقفوا أي وظائف تدير.
2. انتقل إلى مجموعة الموارد التي استخدمتها أثناء توزيع منشئ أحداث TollApp.
3. حدد Delete resource group. لتأكيد الحذف، اكتب اسم مجموعة الموارد.

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

في هذا الدرس، أنشأت وظيفة تحليلات التدفق باستخدام محرر بدون كود لتعريف التجميعات وكتابة النتائج إلى Azure Synapse Analytics. ثم استخدمت Power BI لبناء لوحة تحكم في الوقت الحقيقي لرؤية النتائج التي تنتجها المهمة.

عدم معالجة تدفق التعليمة البرمجية باستخدام Azure Stream Analytics