Share via

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

  • مقالة

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

قبل البدء

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

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

يجب إعداد بيانات الإدخال قبل تحديد وظيفة Stream Analytics. تُستوعب بيانات مستشعر الوقت الفعلي في IoT Hub، والذي يُكون لاحقًا كمدخل للوظيفة. أكمل الخطوات التالية لتحضير بيانات الإدخال التي تتطلبها الوظيفة:

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

  2. حدد Create a resource.

    Screenshot showing the Create a resource menu.

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

    Screenshot showing the IoT Hub menu on the Create a resource page.

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

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

    Screenshot showing the IoT Hub page for creation.

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

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

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

    Screenshot showing the Add device button on the Devices page.

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

    Screenshot showing the Create a device page.

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

    Screenshot showing the list of devices.

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

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

    Screenshot showing the copy button next to device connection string.

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

  1. من الزاوية العلوية اليسرى بمدخل Azure، حدد "Create a resource">"Storage">"Storage account".

  2. في جزء "Create storage account"، أدخل اسم حساب التخزين والموقع ومجموعة الموارد. اختر نفس الموقع ومجموعة الموارد الذي اخترته لمركز "انترنت الأشياء" الذي أنشأته. ثم حدد مراجعة في أسفل الصفحة.

    Screenshot showing the Create a storage account page.

  3. في صفحة "مراجعة"، راجع الإعدادات، ثم حدد "إنشاء" لإنشاء الحساب.

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

  5. في صفحة "حساب التخزين"، حدد "الحاويات" في القائمة اليسرى، ثم حدد "+ حاوية".

    Screenshot showing the Add container menu on the Containers page.

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

    Screenshot showing the **Add container** page.

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

  1. في علامة تبويب منفصلة في نفس نافذة المستعرض أو في نافذة مستعرض منفصلة، سجل الدخول إلى مدخل Microsoft Azure.
  2. حدد"Create a resource"من الزاوية العلوية اليسرى من مدخل Azure.
  3. حدد "Analytics"> "Stream Analytics job" من قائمة النتائج. إذا كنت لا ترى وظيفة Stream Analytics في القائمة، فابحث عن وظيفة Stream Analytics باستخدام مربع البحث في الموضوع، وحددها من نتائج البحث.
  4. في صفحة وظيفة New Stream Analytics، اتبع الخطوات التالية:

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

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

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

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

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

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

      Screenshot showing the **New Stream Analytics job** page.

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

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

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

  1. في صفحة وظيفة Stream Analytics، حدد Inputs ضمن Job topology في القائمة اليسرى.

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

    Screenshot showing the **Inputs** page with **Add stream input** > **IoT Hub** menu selected.**.

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

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

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

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

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

      Screenshot showing the New input page to enter input IoT hub information.

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

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

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

    Screenshot showing the **Outputs** page with **Add** -> **Blob storage** option selected on the menu.

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

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

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

    3. بالنسبة إلى "حساب التخزين"، حدد حساب "التخزين".

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

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

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

      Screenshot showing the **New output** page to enter input Azure storage account information.

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

  1. حدد "استعلام" ضمن "مخطط الوظيفة" من القائمة اليسرى.

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

    SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27

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

    Screenshot showing the **Query** page with the sample query.

تشغيل محاكي IoT

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

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

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

    Screenshot showing the **Raspberry Pi Azure IoT Online Simulator** page with the sample query.

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

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

    Screenshot showing the **Overview** page with **Start** button selected.

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

    Screenshot showing the **Start job** page.

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

    Screenshot showing the **Container** page with the sample output file.

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

    Screenshot showing the sample output file.

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

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

  1. حدد "مجموعات الموارد" من القائمة اليمنى في بوابة Azure، ثم حدد اسم المورد الذي قمت بإنشائه.

  2. في صفحة مجموعة الموارد، حدد "حذف"، واكتب اسم المورد المطلوب حذفه في مربع النص، ثم حدد "حذف".

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

في هذا التشغيل السريع، قمت بنشر مهمة Stream Analytics بسيطة باستخدام مدخل Azure. يمكن أيضاً نشر وظائف Stream Analytics باستخدام PowerShell و Visual Studio و Visual Studio Code .

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

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