Quickstart: إنشاء وظيفة تحليلات التدفق في Visual Studio

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

المتطلبات المسبقه

قبل أن تبدأ، تأكد من أن لديك المتطلبات التالية جاهزة.

إشعار

للحصول على أفضل تجربة تطوير محلي، استخدم أدوات تحليلات التدفق Stream لل تعليمة Visual Studio برمجية. أدوات تحليلات البث ل Visual Studio 2019 (الإصدار 2.6.3000.0) تعاني من فجوات معروفة في الميزات ولا تحصل على تحسينات إضافية. لا تدعم أدوات Visual Studio وتعليمة Visual Studio برمجية الوظائف في مناطق شرق الصين وشمال الصين ووسط ألمانيا وشمال شرق ألمانيا.

• حساب Azure مع اشتراك نشط. إذا لم يكن لديك اشتراك Azure، فبادر بإنشاء حساب مجاني.

• Visual Studio 2019. إصدارات إنتربرايز (Ultimate/Premium)، والمحترفين، وإصدارات المجتمع تعمل، لكن نسخة Express لا تعمل.

• أدوات تحليلات التدفق للعبة Visual Studio مثبتة.

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

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

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

2. حدد إنشاء مورد>إنترنت الأشياء>IoT Hub.

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

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

   

4. حدد "Review + create". راجع معلومات مركز إنترنت الأشياء الخاص بك واختر إنشاء (إنشاء). قد يستغرق إنشاء مركز إنترنت الأشياء الخاص بك بضع دقائق. راقب التقدم المحرز في جزء Notifications .

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

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

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

   

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

   

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

   

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

إنشاء تخزين كائن ثنائي كبير الحجم

في هذا القسم، تنشئ حساب تخزين Azure وحاوية blob لتخزين أحداث الإخراج من وظيفتك.

1. من الزاوية العلوية اليمنى من مدخل Microsoft Azure، حدد Create a resource>>

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

   

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

   

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

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

   

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

أنشئ مشروع تحليلات التدفق في Visual Studio لتحديد مدخلات ومخرجات واستعلام الوظيفة.

1. ابدأ تشغيل Visual Studio.

2. اختر ملف>Project جديد.

3. في قائمة القوالب، اختر Stream Analytics، ثم اختر Azure Stream Analytics Application.

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

   

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

   

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

اربط Visual Studio باشتراك Azure الذي يحتوي على الموارد التي أنشأتها.

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

تحديد المدخلات

قم بتكوين إدخال المهمة لقراءة بيانات التدفق من مركز إنترنت الأشياء الذي أنشأته.

1. في مستكشف الحلول، قم بتوسيع عقدة المدخلات وافتح Input.json.

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

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

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

   

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

قم بتكوين مخرجات المهمة لكتابة النتائج إلى حاوية تخزين blob الخاصة بك.

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

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

   الإعداد	القيمة المقترحة	الوصف
   الاسم المستعار للإخراج	Output	أدخل اسما لتحديد مخرجات الوظيفة.
   جزر	تخزين بحيرة البيانات Gen 2 / تخزين Blob	اختر الحوض المناسب.
   Resource	توفير إعدادات مصدر البيانات يدويا	اختر إدخال البيانات يدويا أو اختر حسابا موجودا.
   الاشتراك	<اشتراكك>	حدد اشتراك Azure الذي يحتوي على حساب التخزين الذي قمت بإنشائه. يمكن أن يكون حساب التخزين في نفس الحساب أو في اشتراك مختلف. هذا المثال يفترض أنك أنشأت حساب تخزين بنفس الاشتراك.
   حساب التخزين	ASAQUICKSTARTstorage	اختر أو أدخل اسم حساب التخزين. أسماء حسابات التخزين تظهر تلقائيا إذا أنشأتها بنفس الاشتراك.
   وعاء	حاوية1	حدد الحاوية الموجودة التي قمت بإنشائها في حساب التخزين الخاص بك.
   نمط المسار	output	أدخل اسم مسار ملف لإنشائه داخل الحاوية.

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

   

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

حدد استعلاما يقوم بتصفية بيانات التدفق ويرسل النتائج إلى المخرج.

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

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

   SELECT *
   INTO Output
   FROM Input
   WHERE Temperature > 27
   

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

أرسل الاستعلام إلى Azure لإنشاء وظيفة تحليلات التدفق.

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

2. في نافذة إرسال الوظيفة ، حدد إنشاء وظيفة Azure Stream Analytics جديدة.

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

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

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

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

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

8. حدد إرسال.

   

تشغيل محاكي IoT

شغل محاكي Raspberry Pi لإرسال بيانات عينات المستشعر إلى مركز إنترنت الأشياء الخاص بك.

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

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

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

   

بدء مهمة Stream Analytics والتحقق من الإخراج

ابدأ المهمة وتحقق من أنها تعالج أحداث الإدخال وتكتب الإخراج إلى تخزين blob.

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

   

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

   

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

   

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

   

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

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

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

المحتوى ذو الصلة

• استخدام Visual Studio لعرض مهام Azure Stream Analytics
• إنشاء وظيفة Stream Analytics باستخدام مدخل Azure
• إنشاء وظيفة تحليلات التدفق باستخدام PowerShell