مشاركة عبر

تكوين مرحلة مصدر MQ في البنية الأساسية لبرنامج ربط العمليات التجارية Azure IoT Data Processor Preview

  • مقالة

هام

معاينة عمليات Azure IoT - التي تم تمكينها بواسطة Azure Arc قيد المعاينة حاليا. يجب عدم استخدام برنامج المعاينة هذا في بيئات الإنتاج.

للحصول على الشروط القانونية التي تنطبق على ميزات Azure الموجودة في الإصدار التجريبي، أو المعاينة، أو التي لم يتم إصدارها بعد في التوفر العام، راجع شروط الاستخدام التكميلية لمعاينات Microsoft Azure.

المرحلة المصدر هي المرحلة الأولى والمطلوبة في البنية الأساسية لبرنامج ربط العمليات التجارية Azure IoT Data Processor Preview. تحصل مرحلة المصدر على البيانات في مسار معالجة البيانات وتعدها لمزيد من المعالجة. تتيح لك مرحلة مصدر MQ الاشتراك في الرسائل من موضوع MQTT. في مرحلة المصدر، يمكنك تعريف تفاصيل الاتصال بمصدر MQ وإنشاء تكوين تقسيم استنادا إلى متطلبات معالجة البيانات المحددة.

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

  • يتم نشر مثيل عامل من معالج البيانات.
  • يعد مثيل وسيط Azure IoT MQ Preview مع جميع البيانات الأولية الضرورية المتوفرة قابلا للتشغيل ويمكن الوصول إليه.

تكوين مصدر MQ

لتكوين مصدر MQ:

  • توفير تفاصيل الاتصال إلى مصدر MQ. يتضمن هذا التكوين نوع مصدر MQ وعنوان URL الخاص كوسيط MQTT ومستوى جودة الخدمة (QoS) ونوع الجلسة والموضوعات التي يجب الاشتراك فيها.
  • حدد أسلوب المصادقة. يقتصر حاليا على المصادقة المستندة إلى اسم المستخدم/كلمة المرور أو الرمز المميز لحساب الخدمة.

يصف الجدول التالي معلمات تكوين مصدر MQ:

الحقل ‏‏الوصف مطلوبة افتراضي مثال
الاسم اسم مرئي للعميل لمرحلة المصدر. المطلوب غير متوفرة asset-1broker
‏‏الوصف وصف مرئي للعميل لمرحلة المصدر. اختياري غير متوفرة brokerforasset-1
الوسيط عنوان URL لوسيط MQTT للاتصال به. المطلوب غير متوفرة tls://aio-mq-dmqtt-frontend:8883
المصادقة طريقة المصادقة للاتصال بالوسيط. واحد من: Noneو Username/Passwordو.Service Account Token (SAT) المطلوب Service Account Token (SAT) Service Account Token (SAT)
اسم المستخدم/كلمة المرور > اسم المستخدم لمصادقة اسم المستخدم/كلمة المرور ‏‏نعم‬ غير متوفرة myuser
اسم المستخدم/كلمة المرور > السرية مرجع إلى كلمة المرور المخزنة في Azure Key Vault. ‏‏نعم‬ غير متوفرة AKV_USERNAME_PASSWORD
Qos مستوى QoS لتسليم الرسائل. المطلوب 1 0
جلسة عمل نظيفة تعيين إلى FALSE لجلسة عمل مستمرة. المطلوب FALSE FALSE
الموضوع الموضوع الذي يجب الاشتراك فيه للحصول على البيانات. المطلوب غير متوفرة contoso/site1/asset1, contoso/site1/asset2

لمعرفة المزيد حول الأسرار، راجع إدارة الأسرار لنشر Azure IoT Operations Preview.

لا يعيد معالج البيانات ترتيب البيانات خارج الترتيب الواردة من وسيط MQTT. إذا تم تلقي البيانات خارج الترتيب من الوسيط، فإنها تظل كذلك في البنية الأساسية لبرنامج ربط العمليات التجارية.

تحديد تنسيق البيانات

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

تصف الجداول التالية خيارات تكوين إلغاء التسلسل المختلفة:

الحقل ‏‏الوصف مطلوبة افتراضي القيمة‬
تنسيق البيانات نوع تنسيق البيانات. ‏‏نعم‬ Raw Raw JSON jsonStream MessagePack CBOR CSV Protobuf

Data Format الحقل إلزامي وتحدد قيمته الحقول المطلوبة الأخرى.

لإلغاء تسلسل رسائل CSV، تحتاج أيضا إلى تحديد الحقول التالية:

الحقل ‏‏الوصف مطلوب القيمة‬ مثال
الرأس ما إذا كانت بيانات CSV تتضمن سطر رأس. ‏‏نعم‬ Yes No No
الاسم اسم العمود في CSV ‏‏نعم‬ - temp, asset
المسار مسار jq في الرسالة حيث تتم إضافة معلومات العمود. لا - مسار jq الافتراضي هو اسم العمود
نوع البيانات نوع بيانات البيانات في العمود وكيفية تمثيلها داخل البنية الأساسية لبرنامج ربط العمليات التجارية لمعالج البيانات. لا String، Float، Integer، ، BooleanBytes الافتراضي: String

لإلغاء تسلسل رسائل Protobuf، تحتاج أيضا إلى تحديد الحقول التالية:

الحقل ‏‏الوصف مطلوب القيمة‬ مثال
الواصف واصف base64 المشفرة لتعريف protobuf. ‏‏نعم‬ - Zhf...
رسالة اسم نوع الرسالة المستخدم لتنسيق البيانات. ‏‏نعم‬ - pipeline
الحزمة اسم الحزمة في الواصف حيث يتم تعريف النوع. ‏‏نعم‬ - schedulerv1

إشعار

يدعم معالج البيانات نوع رسالة واحد فقط في كل ملف .proto .

تكوين التقسيم

يقسم التقسيم في البنية الأساسية لبرنامج ربط العمليات التجارية البيانات الواردة إلى أقسام منفصلة. يتيح التقسيم توازي البيانات في البنية الأساسية لبرنامج ربط العمليات التجارية، ما يمكن أن يحسن معدل النقل ويقلل من زمن الانتقال. تؤثر استراتيجيات التقسيم على كيفية معالجة البيانات في المراحل الأخرى من البنية الأساسية لبرنامج ربط العمليات التجارية. على سبيل المثال، تعمل مرحلة القيمة الأخيرة المعروفة والمرحلة التجميعية على كل قسم منطقي.

لتقسيم بياناتك، حدد استراتيجية التقسيم وعدد الأقسام التي يجب استخدامها:

الحقل ‏‏الوصف مطلوبة افتراضي مثال
نوع القسم نوع التقسيم الذي سيتم استخدامه: القسم ID أو القسم Key المطلوب Key Key
تعبير القسم تعبير jq المراد استخدامه في الرسالة الواردة لحساب القسم ID أو القسمKey المطلوب .topic .topic
عدد الأقسام عدد الأقسام في البنية الأساسية لبرنامج ربط العمليات التجارية لمعالج البيانات. المطلوب 2 2

يضيف معالج البيانات بيانات تعريف إضافية إلى الرسالة الواردة. راجع نظرة عامة على بنية رسالة معالج البيانات لفهم كيفية تحديد تعبير التقسيم الذي يتم تشغيله على الرسالة الواردة بشكل صحيح. بشكل افتراضي، يتم تعيين تعبير التقسيم إلى 0 مع نوع القسم لإرسال ID كافة البيانات الواردة إلى قسم واحد.

للحصول على توصيات ولمعرفة المزيد، راجع ما هو التقسيم؟.

عينة التكوين

يوضح ما يلي مثالا لتكوين المرحلة:

المعلمة القيمة
الاسم input data
الوسيط tls://aio-mq-dmqtt-frontend:8883
المصادقة Service Account Token (SAT)
الموضوع azure-iot-operations/data/opc-ua-connector-0/#
تنسيق البيانات JSON

يقوم هذا التكوين بعد ذلك بإنشاء رسائل تبدو مثل المثال التالي:

{
    "Timestamp": "2023-08-10T00:54:58.6572007Z", 
    "MessageType": "ua-deltaframe",
    "payload": {
      "temperature": {
        "SourceTimestamp": "2023-08-10T00:54:58.2543129Z",
        "Value": 7109
      },
      "Tag 10": {
        "SourceTimestamp": "2023-08-10T00:54:58.2543482Z",
        "Value": 7109
      }
    },
    "DataSetWriterName": "oven",
    "SequenceNumber": 4660
}

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