تشغيل سريع: أنشئ وظيفة Stream Analytics باستخدام مدخل Azure

في هذا التشغيل السريع، يمكنك إنشاء وظيفة Stream Analytics في مدخل Microsoft Azure. يمكنك تحديد وظيفة Stream Analytics التي تقرأ بيانات الدفق في الوقت الحقيقي وتصفية الرسائل بدرجة حرارة أكبر من 27. تقرأ مهمة Stream Analytics البيانات من IoT Hub، وتحول البيانات، وتكتب بيانات الإخراج إلى حاوية في تخزين Azure blob. يتم توليد بيانات الإدخال المستخدمة في هذه البداية السريعة باستخدام محاكي راسبيري باي عبر الإنترنت.

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

إذا لم يكن لديك اشتراك Azure، فأنشئ حسابًا مجانًا.

إعداد بيانات الإدخال

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

  1. قم بتسجيل الدخول إلى بوابة Azure.

  2. حدد Create a resource. في صفحة "إنشاء مورد"، حدد "إنترنت الأشياء>مركز إنترنت الأشياء".

    لقطة شاشة تعرض قائمة

  3. اتبع الخطوات التالية في صفحة "مركز إنترنت الأشياء":

    1. للاشتراك: تحديد اشتراك Azure الخاص بك.
    2. بالنسبة إلى "مجموعة الموارد"، حدد مجموعة الموارد الموجودة أو أنشئ مجموعة موارد جديدة.
    3. بالنسبة إلى "اسم مركز إنترنت الأشياء"، أدخل اسمًا لمركز إنترنت الأشياء.
    4. بالنسبة إلى "المنطقة"، حدد المنطقة الأقرب إليك.
    5. بالنسبة للدرجة، اختر مجاني إذا كان لا يزال متاحا على اشتراكك. لمزيد من المعلومات، راجع تسعير مركز IoT.
    6. بالنسبة إلى حد الرسائل اليومية، احتفظ بالقيمة الافتراضية.
    7. حدد Next: Networking في أسفل الصفحة.

    لقطة شاشة تظهر صفحة مركز إنترنت الأشياء للإنشاء.

  4. حدد "Review + create". راجع معلومات مركز IoT وحدد إنشاء. قد يستغرق مركز "انترنت الأشياء" بضع دقائق لإنشائها. يمكن مراقبة التقدم في جزء الإعلامات.

  5. بعد إنشاء المورد (مركز إنترنت الأشياء)، حدد "الانتقال إلى مورد" للانتقال إلى صفحة "مركز إنترنت الأشياء".

  6. في صفحة "مركز إنترنت الأشياء"، حدد "الأجهزة" في القائمة اليسرى، ثم حدد "+ إضافة جهاز".

    لقطة شاشة تعرض زر

  7. أدخل معرف الجهاز وحدد حفظ.

    لقطة شاشة تظهر صفحة إنشاء جهاز.

  8. بمجرد إنشاء الجهاز، ترى الجهاز في قائمة أجهزة إنترنت الأشياء . حدد زر "تحديث" على الصفحة إذا لم تتمكن من رؤيته.

    لقطة شاشة تعرض قائمة الأجهزة.

  9. حدد جهازك من القائمة.

  10. في صفحة الجهاز، حدد زر النسخ بجوار سلسلة الاتصال الأساسية، واحفظه في مفكرة لاستخدامها لاحقا.

    لقطة شاشة تعرض زر النسخ بجوار سلسلة اتصال الجهاز.

تشغيل محاكي IoT

  1. افتح Raspberry Pi Azure IoT Online Simulator .

  2. استبدل العنصر المؤقت في السطر 15 بسلسلة اتصال أجهزة Azure IoT Hub التي حفظتها في قسم سابق.

  3. حدد تشغيل. يظهر المخرج بيانات المستشعرات والرسائل التي ترسل إلى مركز إنترنت الأشياء الخاص بك.

    لقطة شاشة تعرض صفحة **Raspberry Pi Azure IoT Online Simulator** مع نموذج الاستعلام.

إنشاء مخزن "كائنات ثنائية كبيرة"

  1. من الزاوية العلوية اليمنى من مدخل Microsoft Azure، حدد Create a resource. حدد Storage ضمن Categories في القائمة اليمنى، ثم حدد Storage account.

    لقطة شاشة تظهر صفحة إنشاء مورد.

  2. في صفحة حساب التخزين ، اختر إنشاء لبدء إنشاء حساب تخزين.

  3. في صفحة إنشاء حساب تخزين ، اتبع هذه الخطوات:

    1. أدخل اسم حساب التخزين، والموقع، ومجموعة الموارد. اختر نفس الموقع ومجموعة الموارد الذي اخترته لمركز "انترنت الأشياء" الذي أنشأته. ثم حدد مراجعة في أسفل الصفحة.
    2. لنوع التخزين المفضل، اختر Azure Blob Storage أو Azure Data Lake Storage Gen2. يتيح لك هذا الخيار استخدام حساب التخزين لإخراج وظائف Stream Analytics.
    3. حدد مراجعة + إنشاء عند أسفل الصفحة. راجع إعداداتك.

    لقطة شاشة تظهر صفحة إنشاء حساب تخزين.

  4. في صفحة المراجعة + الإنجاب ، راجع إعداداتك، واختر إنشاء لإنشاء الحساب.

  5. بعد إنشاء المورد، حدد "الانتقال إلى مورد" للانتقال إلى صفحة "حساب التخزين".

  6. في صفحة حساب التخزين ، اختر الحاويات في القائمة اليسرى، ثم اختر + إضافة حاوية.

    لقطة شاشة تظهر قائمة إضافة الحاوية في صفحة الحاويات.

  7. في صفحة "حاوية جديدة"، أدخل اسم للحاوية مثل "حاوية1"، وحدد "إنشاء".

    لقطة شاشة تظهر صفحة **إضافة حاوية**.

إنشاء مشروع وظائف Stream Analytics

  1. في علامة تبويب منفصلة في نفس نافذة المستعرض أو في نافذة مستعرض منفصلة، سجل الدخول إلى مدخل Microsoft Azure.

  2. حدد كل الخدمات في القائمة اليسرى. حدد Analytics ضمن Categories. مرر مؤشر الماوس فوق وظائف تحليلات البث، ثم اختر +أو اختر + Create في نافذة النوافذ المنبثقة.

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

  3. في وظيفة تحليلات التيار الجديد، اتبع الخطوات التالية:

    1. للاشتراك: تحديد اشتراك Azure الخاص بك.

    2. بالنسبة إلى "مجموعة الموارد"، حدد نفس المورد الذي استخدمته سابقاً في هذا التشغيل السريع.

    3. بالنسبة إلى "الاسم "، أدخل اسمًا للوظيفة. من الممكن أن يحتوي اسم وظيفة Stream Analytics على أحرف أبجدية رقمية وواصلات وشرطات سفلية فقط ويجب أن يتراوح طولها بين 3 و 63 حرفًا.

    4. بالنسبة إلى "بيئة الاستضافة"، تأكد من تحديد "السحابة". يمكن نشر وظائف Stream Analytics في "السحابة" أو "Edge". تتيح لك "السحابة" التوزيع إلى سحابة Azure، ويتيح لك خيار "Edge" التوزيع إلى جهاز IoT Edge.

    5. بالنسبة إلى "لوحدات البث"، حدد "1". تمثل وحدات البث موارد الحوسبة المطلوبة لتنفيذ مهمة ما. لمعرفة المزيد عن قياس وحدات البث، راجع مقالة فهم وضبط وحدات البث .

    6. حدد مراجعة + إنشاء عند أسفل الصفحة.

      لقطة شاشة تظهر صفحة وظيفة **تحليل التدفق الجديدة**.

  4. على المراجعة + الإنشاء، راجع الإعدادات، واختر إنشاء لإنشاء صفحة تحليلات البث.

  5. في صفحة "التوزيع"، حدد "الانتقال إلى مورد" للانتقال إلى صفحة "وظيفة Stream Analytics".

تكوين إدخال المهمة

في هذا القسم، يمكنك تكوين إدخال جهاز IoT Hub إلى وظيفة Stream Analytics. استخدم IoT Hub الذي أنشأته في القسم السابق في التشغيل السريع.

  1. في صفحة وظائف تحليلات التدفق ، اختر المدخلات تحت طوبولوجيا الوظائف في القائمة اليسرى.

  2. في صفحة Inputs، حدد Add input>IoT Hub.

    لقطة شاشة تظهر صفحة **المدخلات** مع اختيار قائمة **إضافة مدخل التدفق** > **IoT Hub** المفضلة.

  3. اتبع الخطوات التالية في صفحة "مركز إنترنت الأشياء":

    1. بالنسبة إلى "الاسم المستعار للمدخلات"، أدخل "IoTHubInput".

    2. بالنسبة إلى "الاشتراك"، حدد الاشتراك الذي يحتوي على مركز إنترنت الأشياء الذي أنشأته سابقاً. هذا البدء السريع يفترض أنك تنشئ مركز إنترنت الأشياء بنفس الاشتراك.

    3. بالنسبة إلى "مركز إنترنت الأشياء"، حدد مركز إنترنت الأشياء.

    4. حدد "حفظ" لحفظ إعدادات الإدخال لوظيفة Stream Analytics.

      لقطة شاشة تظهر صفحة الإدخال الجديدة لإدخال معلومات مركز إنترنت الأشياء المدخل.

تكوين إخراج المهمة

  1. اختر المخرجات تحت طوبولوجيا الوظائف في القائمة اليسرى.

  2. في صفحة Outputs، حدد Add output>Blob storage/ADLS Gen2.

    لقطة شاشة تظهر صفحة **المخرجات** مع خيار **إضافة** -> **تخزين الكتل** في القائمة.

  3. في صفحة "إخراج جديد" لـ "مخزن كائن ثنائي كبير الحجم/ADLS Gen2"، اتبع الخطوات التالية:

    1. بالنسبة إلى "⁧⁩الأسماء المستعارة للمخرجات⁧⁩"، أدخل "⁧⁩BlobOutput⁧⁩".

    2. بالنسبة إلى "الاشتراك"، حدد الاشتراك الذي يحتوي على حساب تخزين Azure الذي أنشأته سابقاً. هذا البدء السريع يفترض أنك أنشأت حساب التخزين بنفس الاشتراك.

    3. بالنسبة لحساب التخزين، اختر حساب التخزين الخاص بك.

    4. بالنسبة إلى "الحاوية"، حدد حاوية كائن ثنائي كبير الحجم إذا لم تكن محددة بالفعل.

    5. بالنسبة إلى "وضع المصادقة"، حدد "سلسلة الاتصال".

    6. حدد "حفظ" في أسفل الصفحة لحفظ إعدادات الإخراج.

      لقطة شاشة تظهر صفحة **المخرج الجديد** لإدخال معلومات حساب تخزين Azure المدخل.

حدد استعلام التحويل

  1. اختر الاستعلام تحت طوبولوجيا الوظائف في القائمة اليسرى.

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

    SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27

  3. حدد "حفظ الاستعلام" في شريط الأدوات.

    لقطة شاشة تعرض صفحة **الاستعلام** مع نموذج الاستعلام.

ابدأ وظيفة Stream Analytics وتحقق من الإخراج

  1. ارجع إلى صفحة نظرة عامة على الوظيفة في مدخل Microsoft Azure، وحدد Start job.

    لقطة شاشة تظهر صفحة **النظرة العامة** مع زر **ابدأ** محدد.

  2. في صفحة "بدء وظيفة"، تأكد من تحديد "الآن" لـ "وقت بدء إخراج الوظيفة"، ثم حدد "بدء" في أسفل الصفحة.

    لقطة شاشة تظهر صفحة **بدء الوظيفة**.

  3. بعد بضع دقائق، في البوابة، ابحث عن حساب التخزين والحاوية التي قمت بإعدادها كمخرج للمهمة. يمكن الآن مشاهدة ملف الإخراج في الحاوية. تستغرق المهمة بضع دقائق لتبدأ لأول مرة. بعد أن يبدأ، يستمر في العمل مع وصول البيانات.

    لقطة شاشة تعرض صفحة **حاوية** مع نموذج لملف الإخراج.

  4. حدد الملف، ثم في صفحة "كائن ثنائي كبير الحجم"، حدد "تحرير" لعرض المحتويات في الملف.

    لقطة شاشة تعرض نموذج ملف الإخراج.

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

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

  1. حدد "مجموعات الموارد" من القائمة اليمنى في بوابة Azure، ثم حدد اسم المورد الذي قمت بإنشائه.
  2. في صفحة مجموعة الموارد، حدد "حذف"، واكتب اسم المورد المطلوب حذفه في مربع النص، ثم حدد "حذف".
  3. في تطبيق Raspberry Pi Azure IoT Online Simulator ، حدد Reset بجوار Run في الجزء السفلي إلى اليمين.

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

للتعرف على تكوين مصادر الإدخال الأخرى وإجراء الكشف في الوقت الفعلي، تابع إلى المقالة التالية:

اكتشاف الاحتيال في الوقت الفعلي باستخدام Azure Stream Analytics

  • Last updated on