نموذج موارد Azure Stream Analytics

Azure Stream Analytics هو منصة كخدمة مدارة بالكامل لمعالجة التدفقات. تصف هذه المقالة نموذج الموارد لتحليلات التدفق من خلال تقديم مفهوم تجمع تحليلات التدفق، والوظيفة، ومكونات الوظيفة.

وظيفة تحليلات التدفق

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

  • الإدخال
  • الإخرَاج
  • الاستعلام

الإدخال

يمكن أن تحتوي الوظيفة على مدخل أو أكثر لقراءة البيانات باستمرار. قد تكون هذه المصادر المتدفقة هي Azure Event Hubs، أو Azure IoT Hub، أو Azure Storage. تدعم تحليلات التدفق أيضا قراءة بيانات الإدخال الثابتة أو المتغيرة ببطء (تسمى بيانات المرجع) والتي غالبا ما تستخدم لإثراء بيانات البث. إضافة هذه المدخلات إلى وظيفتك هي عملية بدون كود.

الإخرَاج

يمكن أن يكون للوظيفة مخرجات واحدة أو أكثر لكتابة البيانات باستمرار. يدعم Stream Analytics 12 مصارف إخراج مختلفة بما في ذلك Azure SQL Database وAzure Data Lake Storage وAzure Cosmos DB وPower BI والمزيد. إضافة هذه المخرجات إلى وظيفتك هي أيضا عملية بدون كود.

الاستعلام

يمكنك تنفيذ منطق معالجة التدفق عن طريق كتابة استعلام SQL في وظيفتك. يتيح دعم لغة SQL الغنية التعامل مع سيناريوهات مثل تحليل JSON المعقد، تصفية القيم، حساب التجميعات، إجراء الانضمامات، وحتى حالات استخدام أكثر تقدما مثل التحليلات الجغرافية المكانية واكتشاف الشذوذات. يمكنك أيضا توسيع هذه اللغة باستخدام JavaScript باستخدام وظائف المستخدم المعرفة (UDF) وUDA: التجميعات المعرفة من قبل المستخدم (UDA). تتيح لك تحليلات البث أيضا تعديل الأحداث المتأخرة أو غير المرتبة بسهولة من خلال إعدادات بسيطة في إعدادات وظيفتك. يمكنك أيضا اختيار تنفيذ استعلامك بناء على وقت وصول حدث الإدخال إلى مصدر الإدخال أو متى تم توليد الحدث في مصدر الحدث.

إدارة وظيفة

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

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

عنقود تحليلات التدفق

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

مخطط يوضح بيئة متعددة المستأجرين القياسية في تحليلات التدفق.

مخطط يوضح بيئة مخصصة في تحليلات التدفق.

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

تعلم كيفية إدارة تحليلات Azure Stream ومفاهيم أخرى: