استخدام محرر Azure Stream Analytics بدون تعليمات برمجية لتحويل البيانات وتخزينها في قاعدة بيانات Azure SQL

توضح هذه المقالة كيف يمكنك استخدام محرر التعليمات البرمجية لإنشاء وظيفة Stream Analytics بسهولة، والتي تقرأ البيانات باستمرار من مثيل مراكز الأحداث (مركز الأحداث)، وتحول البيانات، ثم تكتب النتائج إلى قاعدة بيانات Azure SQL.

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

يجب أن تكون موارد Azure Event Hubs وAzure SQL Database متاحة للجمهور ولا تكون خلف جدار حماية أو مؤمنة في شبكة Azure الظاهرية. يجب إجراء تسلسل للبيانات الموجودة في مراكز الأحداث بتنسيق JSON أو CSV أو Avro.

إذا كنت تريد تجربة الخطوات الواردة في هذه المقالة، فاتبع هذه الخطوات.

• إنشاء مركز أحداث إذا لم يكن لديك مركز بالفعل. إنشاء بيانات في مركز الأحداث. في صفحة Event Hubs Instance ، حدد Generate data (preview) في القائمة اليسرى، وحدد Stock data for Dataset، ثم حدد Send لإرسال بعض البيانات النموذجية إلى مركز الأحداث. هذه الخطوة مطلوبة إذا كنت تريد اختبار الخطوات الواردة في هذه المقالة.

  

• إنشاء قاعدة بيانات Azure SQL. فيما يلي بعض النقاط المهمة التي يجب ملاحظتها أثناء إنشاء قاعدة البيانات.

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

  2. في صفحة Networking ، اتبع الخطوات التالية:

     1. تمكين نقطة النهاية العامة.
     2. حدد نعمللسماح لخدمات وموارد Azure بالوصول إلى هذا الخادم.
     3. حدد نعملإضافة عنوان IP للعميل الحالي.

  3. في صفحة Additional settings ، حدد None for Use existing data.

  4. في المقالة، تخط الخطوات في قسمي الاستعلام عن قاعدة البياناتوتنظيف الموارد .

  5. إذا كنت تريد اختبار الخطوات، فقم بإنشاء جدول في قاعدة بيانات SQL باستخدام محرر الاستعلام (معاينة).

     create table stocks (
         symbol varchar(4),
         price decimal
     )
     

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

في هذا القسم، يمكنك إنشاء وظيفة Azure Stream Analytics باستخدام محرر بدون تعليمات برمجية. تحول المهمة تدفق البيانات من مثيل مراكز الأحداث (مركز الأحداث) وتخزن بيانات النتائج في قاعدة بيانات Azure SQL.

1. في مدخل Microsoft Azure، انتقل إلى صفحة Event Hubs Instance لمركز الأحداث الخاص بك.

2. حدد الميزات>معالجة البيانات في القائمة اليسرى ثم حدد البدء على بطاقة قاعدة بيانات تحويل البيانات وتخزينها إلى SQL .

   

3. أدخل اسماً لمهمة Stream Analytics، ثم حدد إنشاء. ترى الرسم التخطيطي لمهمة Stream Analytics مع نافذة مراكز الأحداث إلى اليمين.

   

4. في نافذة Event hub ، راجع إعدادات وضع التسلسلوالمصادقة ، وحدد Connect.

   

5. عند إنشاء الاتصال بنجاح ولديك بيانات في مثيل مراكز الأحداث، سترى أمرين:

   • الحقول الموجودة في بيانات الإدخال. يمكنك اختيار إضافة حقل أو تحديد رمز النقاط الثلاث بجوار الحقل لإزالته أو إعادة تسميته أو تغيير نوعه.

     

   • عينة مباشرة من البيانات الواردة في جدول معاينة البيانات ضمن طريقة عرض الرسم التخطيطي. يتم تحديثه تلقائياً بشكلٍ دوري. يمكنك تحديد إيقاف معاينة البث مؤقتاً لمشاهدة طريقة عرض ثابتة لنموذج بيانات الإدخال.

     

6. حدد الإطار المتجانب تجميع حسب لتجميع البيانات. في لوحة التجميع حسب التكوين، يمكنك تحديد الحقل الذي تريد تجميعه حسب مع النافذة الزمنية.

   في المثال التالي، يتم استخدام متوسط السعروالرمز .

   

7. يمكنك التحقق من صحة نتائج الخطوة في قسم معاينة البيانات .

   

8. حدد الإطار المتجانب إدارة الحقول . في لوحة تكوين إدارة الحقول ، اختر الحقول التي تريد إخراجها عن طريق تحديد إضافة حقل ->مخطط مستورد -> حقل.

   إذا كنت تريد إضافة كافة الحقول، فحدد إضافة كافة الحقول. أثناء إضافة حقل، يمكنك تحديد اسم مختلف للإخراج. على سبيل المثال، AVG_Value إلى Value. بعد حفظ التحديدات، سترى البيانات في جزء معاينة البيانات .

   في المثال التالي، يتم تحديد الرمزAVG_Value . يتم تعيين الرمز إلى رمز، ويتم تعيين AVG_Value إلى السعر.

   

9. حدد لوحة SQL . في لوحة تكوين قاعدة بيانات SQL ، املأ المعلمات المطلوبة واتصل. حدد تحميل الجدول الموجود لاختيار الجدول تلقائيا. في المثال التالي، [dbo].[stocks] يتم اختيار . ثم حدد Connect.

   ملاحظة

   يجب أن يتطابق مخطط الجدول الذي تختار كتابته تماما مع عدد الحقول وأنواعها التي تنشئها معاينة البيانات.

   

10. في جزء معاينة البيانات ، سترى معاينة البيانات التي تم استيعابها في قاعدة بيانات SQL.

    

11. حدد Save ثم حدد بدء وظيفة Stream Analytics.

    

12. لبدء الوظيفة، حدد:

    • عدد وحدات البث (SUs) التي تعمل بها الوظيفة. تمثل وحدات SUs مقدار الحوسبة والذاكرة المخصصة للوظيفة. نوصي بأن تبدأ بثلاثة ثم تضبط حسب الحاجة.

    • معالجة أخطاء بيانات الإخراج - يسمح لك بتحديد السلوك الذي تريده عند فشل إخراج الوظيفة إلى وجهتك بسبب أخطاء البيانات. بشكلٍ افتراضي، تعيد مهمتك المحاولة حتى تنجح عملية الكتابة. يمكنك أيضاً اختيار إسقاط أحداث الإخراج هذه.

      

13. بعد تحديد "Start"، تبدأ المهمة في العمل في غضون دقيقتين. ترى لوحة المقاييس في الجزء السفلي مفتوحة. يستغرق تحديث هذه اللوحة بعض الوقت. حدد تحديث في الزاوية العلوية اليسرى من اللوحة لتحديث المخطط. انتقل إلى الخطوة التالية في علامة تبويب أو نافذة منفصلة من مستعرض الويب.

    

    يمكنك أيضا رؤية المهمة ضمن قسم Process Data في علامة التبويب Stream Analytics jobs . حدد Open metrics لمراقبته أو إيقافه وإعادة تشغيله، حسب الحاجة.

    

14. انتقل إلى مركز الأحداث في المدخل في نافذة مستعرض منفصلة أو علامة تبويب، وأرسل عينة من بيانات المخزون مرة أخرى (كما فعلت في المتطلبات الأساسية). في صفحة Event Hubs Instance ، حدد Generate data (preview) في القائمة اليسرى، وحدد Stock data for Dataset، ثم حدد Send لإرسال بعض البيانات النموذجية إلى مركز الأحداث. يستغرق الأمر بضع دقائق لرؤية لوحة Metrics محدثة.

15. يجب أن تشاهد السجلات المدرجة في قاعدة بيانات Azure SQL.

    

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

تعرف على المزيد بشأن Azure Stream Analytics وكيفية مراقبة الوظيفة التي أنشأتها.

• مقدمة إلى Azure Stream Analytics
• مراقبة وظيفة Stream Analytics باستخدام مدخل Microsoft Azure