مشاركة عبر

التشغيل السريع: إنشاء وظيفة Azure Stream Analytics باستخدام Visual Studio

  • مقالة

يوضح لك هذا التشغيل السريع كيفية إنشاء وتشغيل وظيفة Stream Analytics باستخدام أدوات Azure Stream Analytics لـ Visual Studio. يقرأ المثال على الوظيفة بيانات التدفق من مركز IoT. أنت تحدد وظيفة تحسب متوسط درجة الحرارة عندما تزيد عن 27 درجة وتكتب أحداث الإخراج الناتجة في ملف جديد في مخزن البيانات الثنائية الكبيرة.

ملاحظة

  • نوصي بشدة باستعمال أدوات Stream Analytics لـ Visual Studio Code للحصول على أفضل تجربة تطوير محلية. هناك فجوات في الميزات المعروفة في أدوات Stream Analytics لبرنامج Visual Studio 2019 (الإصدار 2.6.3000.0) ولن يتم تحسينها من الآن فصاعداً.
  • أدوات Visual Studio، وVisual Studio Code لا تدعم الوظائف في مناطق شرق الصين وشمال الصين، ومنطقة وسط ألمانيا، وشمال شرق ألمانيا.

قبل أن تبدأ

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

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

  • تثبيت Visual Studio 2019 أو Visual Studio 2015 أو Visual Studio 2013 تحديث 4. يتم دعم الإصدارات (Ultimate/Premium) المؤسسية والاحترافية والمجتمعية. الإصدار السريع غير مدعم.

  • اتبع إرشادات التثبيت لتثبيت أدوات Stream Analytics لبرنامج Visual Studio.

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

قبل تحديد مهمة Stream Analytics، عليك إعداد البيانات التي تم تكوينها لاحقاً كمدخل للوظيفة. لإعداد بيانات الإدخال المطلوبة من قبل الوظيفة، أكمل الخطوات التالية:

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

  2. حدد ⁧⁩إنشاء مورد⁧⁩⁧>⁩⁧⁩إنترنت الأشياء⁧⁩⁧>⁩⁧⁩مركز IoT⁧⁩.

  3. في جزء ⁧⁩مركز IoT⁧⁩، أدخل المعلومات التالية:

    الإعداد القيمة المقترحة الوصف
    الاشتراك <اشتراكك> حدد اشتراك Azure الذي تريد استخدامه.
    مجموعة الموارد asaquickstart-resourcegroup حدد ⁧⁩إنشاء جديد⁧⁩، وأدخل اسمًا جديدًا لمجموعة الموارد لحسابك.
    اسم مركز IoT MyASAIoTHub حدد اسمًا لمركز IoT.
    المنطقة <حدد المنطقة الأقرب إلى المستخدمين> حدد موقعًا جغرافيًا يمكنك فيه استضافة مركز IoT. استخدم الموقع الأقرب إلى المستخدمين.
    المستوى مجاني بالنسبة إلى هذا التشغيل السريع، حدد مجاني إذا كان لا يزال متوفرا على اشتراكك. إذا لم يكن المستوى المجاني متوفرًا، فاختر أدنى مستوى متاح. لمزيد من المعلومات، راجع أسعار مركز IoT.

    لقطة شاشة تعرض معالج Create IoT Hub في مدخل Microsoft Azure.

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

  5. بعد اكتمال التوزيع، حدد Go to resource للانتقال إلى صفحة IoT Hub لمركز IoT الخاص بك.

  6. في صفحة IoT Hub ، حدد الأجهزة ضمن إدارة الأجهزة في قائمة التنقل اليسرى.

  7. في صفحة الأجهزة ، حدد + إضافة جهاز على شريط الأدوات.

    لقطة شاشة تعرض صفحة الأجهزة مع تحديد إضافة جهاز.

  8. في صفحة إنشاء جهاز ، أدخل اسما للجهاز، وحدد حفظ.

    لقطة شاشة تعرض صفحة

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

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

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

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

  1. من الزاوية العلوية اليسرى بمدخل Azure، حدد إنشاء مورد>مخزن>حساب التخزين.

  2. في جزء إنشاء حساب تخزين، أدخل اسم حساب التخزين وموقعه ومجموعة الموارد. اختر نفس الموقع ومجموعة الموارد بمركز IoT الذي أنشأته. ثم انقر فوق ⁧⁩مراجعة + إنشاء⁧⁩ لإنشاء الحساب.

    لقطة شاشة تعرض صفحة إنشاء حساب تخزين في مدخل Microsoft Azure.

  3. بمجرد إنشاء حساب التخزين الخاص بك، حدد تجانب خدمة Blob في جزء Overview .

    لقطة شاشة تعرض صفحة نظرة عامة على حساب التخزين مع تحديد خدمة Blob.

  4. في صفحة خدمة Blob ، حدد + Container على شريط الأدوات.

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

    لقطة شاشة تعرض صفحة حاوية جديدة.

قم بإنشاء مشروع Stream Analytics

  1. ابدأ Visual Studio.

  2. حدد File > New Project.

  3. في قائمة القوالب على اليمين، حدد Stream Analytics، ثم حدد تطبيق Azure Stream Analytics.

  4. أدخل اسم المشروع والموقعواسم الحل، وحدد إنشاء.

    لقطة شاشة تعرض مربع الحوار إنشاء مشروع Stream Analytics.

  5. لاحظ العناصر المضمنة في مشروع Azure Stream Analytics.

    لقطة شاشة تعرض نافذة مستكشف الحلول لعينة مشروع تطبيق Stream Analytics في Visual Studio.

اختر الاشتراك المطلوب

  1. في Visual Studio، في القائمة عرض، حدد مستكشف الخادم.
  2. انقر بزر الماوس الأيمن على Azure، وحدد الاتصال باشتراك Microsoft Azure، ثم سجل الدخول باستخدام حساب Azure الخاص بك.

تحديد الإدخال

  1. في مستكشف الحلول، قم بتوسيع عقدة الإدخالات وانقر نقراً مزدوجاً فوق Input.json.

  2. املأ تكوين إدخال Stream Analytics بالقيم التالية:

    الإعداد القيمة المقترحة الوصف
    الاسم المستعار للإدخال إدخال أدخل اسماً لتعريف إدخال الوظيفة.
    نوع المصدر دفق البيانات اختر مصدر الإدخال المناسب: دفق البيانات أو البيانات المرجعية.
    المصدر IoT Hub اختر مصدر الإدخال المناسب.
    مورد اختيار مصدر البيانات من حساب جارٍ اختر إدخال البيانات يدوياً أو تحديد حساب موجود.
    الاشتراك <اشتراكك> حدد اشتراك Azure الذي يحتوي على مركز IoT الذي قمت بإنشائه.
    IoT Hub MyASAIoTHub اختر أو أدخل اسم مركز IoT الخاص بك. يتم الكشف عن أسماء IoT Hub تلقائيا إذا تم إنشاؤها في نفس الاشتراك.

  3. اترك خيارات أخرى للقيم الافتراضية وحدد "حفظ" لحفظ الإعدادات.

    لقطة شاشة تعرض صفحة تكوين إدخال Stream Analytics.

تحديد الإخراج

  1. في مستكشف الحلول، قم بتوسيع عقدة الإخراجات وانقر نقراً مزدوجاً فوق Output.json.

  2. املأ تكوين إدخال Stream Analytics بالقيم التالية:

    الإعداد القيمة المقترحة الوصف
    الاسم المستعار للإخراج المخرجات أدخل اسماً لتعريف إخراج الوظيفة.
    Sink Data Lake Storage Gen 2/Blob Storage اختيار المخزن المناسب.
    مورد توفير إعدادات مصدر البيانات يدوياً اختر إدخال البيانات يدوياً أو تحديد حساب موجود.
    الاشتراك <اشتراكك> حدد اشتراك Azure الذي يحتوي على حساب التخزين الذي أنشأته. يمكن أن يكون حساب التخزين في نفس الاشتراك أو في اشتراك مختلف. يفترض هذا المثال إنشاء حساب تخزين في نفس الاشتراك.
    حساب التخزين asaquickstartstorage اختر أو أدخل اسم حساب التخزين. يتم اكتشاف أسماء حسابات التخزين تلقائيًا إذا تم إنشاؤها في نفس الاشتراك.
    الحاوية الحاوية1 حدد الحاوية الموجودة التي قمت بإنشائها في حساب التخزين الخاص بك.
    نمط المسار الإخراج أدخل اسم مسار ملف ليتم إنشاؤه داخل الحاوية.

  3. اترك خيارات أخرى للقيم الافتراضية وحدد حفظ لحفظ الإعدادات.

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

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

  1. افتح Script.asaql من مستكشف الحلول في Visual Studio.

  2. أضف الاستعلام التالي:

    SELECT *
INTO Output
FROM Input
WHERE Temperature > 27

إرسال استعلام Stream Analytics إلى Azure

  1. في محرر الاستعلام، حدد إرسال إلى Azure في محرر البرنامج النصي.

  2. في نافذة Submit Job ، حدد Create a New Azure Stream Analytics job.

  3. أدخل اسم الوظيفة.

  4. اختر اشتراك Azure.

  5. اختر مجموعة الموارد.

  6. احتفظ بالقيمة الافتراضية لنظام المجموعة.

  7. حدد الموقع الذي استخدمته في بداية التشغيل السريع.

  8. ثم حدد Submit.

    لقطة شاشة تعرض مربع الحوار إرسال مهمة.

تشغيل محاكي IoT

  1. افتح Raspberry Pi Azure IoT Online Simulator في علامة تبويب مستعرض أو نافذة جديدة.

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

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

    لقطة شاشة تعرض Raspberry Pi Azure IoT Online Simulator.

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

  1. عند إنشاء الوظيفة، يتم فتح طريقة عرض المهمة تلقائياً. حدد زر السهم الأخضر لبدء الوظيفة،

    لقطة شاشة تعرض زر البدء لبدء مهمة Stream Analytics من Visual Studio.

  2. تغيير وضع بدء إخراج المهمة إلى JobStartTime وحدد بدء.

    لقطة شاشة تعرض مربع الحوار Stream Analytics Start Job Configuration.

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

    لقطة شاشة تعرض حالة الوظيفة كتشغيل ومقاييس للوظيفة.

  4. لعرض النتائج، في القائمة عرض، حدد Cloud Explorer، وانتقل إلى حساب التخزين في مجموعة الموارد. ضمن حاويات الكائن الثنائي كبير الحجم، انقر نقراً مزدوجاً فوق الحاوية 1، ثم مسار ملف الإخراج.

    View results

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

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

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

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

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

للتعرف على أدوات Azure Stream Analytics لـ Visual Studio، تابع المقالة التالية:

استخدام Visual Studio لعرض وظائف Azure Stream Analytics