مشاركة عبر

استخدام القيم المعروفة الأخيرة في البنية الأساسية لبرنامج ربط العمليات التجارية Azure IoT Data Processor Preview

  • مقالة

هام

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

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

استخدم مرحلة القيمة المعروفة الأخيرة (LKV) في مسار معالج البيانات للحفاظ على سجل محدث وكامل لبياناتك. تتعقب مرحلة LKV أحدث قيم أزواج قيم المفاتيح للرسائل في البنية الأساسية لبرنامج ربط العمليات التجارية. يمكن للمرحلة بعد ذلك إثراء الرسائل باستخدام قيم LKV المتعقبة. آخر تعقب وإثراء معروفين للقيمة مهمان لعمليات انتقال البيانات من الخادم التي تعتمد على:

  • نقاط بيانات سلسلة زمنية متعددة في طابع زمني محدد.
  • الحمولات التي تحتوي دائما على قيمة لمفتاح معين.

في مسار معالجة البيانات، تكون مرحلة LKV مرحلة اختيارية. عند استخدام مرحلة LKV، يمكنك:

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

تحافظ مرحلة LKV على تكامل البيانات الزمنية. تضمن المرحلة عدم تجاوز الرسائل ذات الطوابع الزمنية السابقة أو استبدال LKVs بالرسائل التي تحتوي على طوابع زمنية لاحقة.

تثري مرحلة LKV الرسائل الواردة بآخر القيم المعروفة التي تتعقبها. تمثل هذه القيم المحسنة البيانات المسجلة مسبقا، ولا تمثل بالضرورة القيم الحالية في الوقت الحقيقي. تأكد من أن هذا السلوك يتوافق مع توقعات معالجة البيانات.

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

لتكوين مرحلة تدفق تجميعية واستخدامها، تحتاج إلى مثيل منشور من Azure IoT Data Processor Preview.

تكوين المرحلة

يحدد تكوين JSON لمرحلة LKV تفاصيل المرحلة. لتأليف المرحلة، يمكنك إما التفاعل مع واجهة المستخدم المستندة إلى النموذج، أو توفير تكوين JSON في علامة التبويب خيارات متقدمة:

الحقل ‏‏الوصف مطلوبة افتراضي مثال
الاسم اسم معرف من قبل المستخدم للمرحلة. ‏‏نعم‬ - lkv1
‏‏الوصف وصف معرف من قبل المستخدم للمرحلة. لا - lkv1
مسار إدخال الخصائص > مسار المفتاح المراد تعقبه. ‏‏نعم‬ - .payload.temperature
مسار إخراج الخصائص > المسار إلى الموقع في رسالة الإخراج لكتابة LKV. ‏‏نعم‬ - .payload.temperature_lkv
وقت انتهاء صلاحية الخصائص > تكون LKVs المتعقبة صالحة فقط للفاصل الزمني المحدد من قبل المستخدم، وبعد ذلك لا يتم إثراء رسالة الإخراج بالقيمة المخزنة. يتم تعقب انتهاء الصلاحية لكل مفتاح LKV. لا - 10h
مسار الطابع الزمني للخصائص > المسار إلى الموقع في رسالة الإخراج لكتابة الطابع الزمني لآخر تحديث ل LKV. لا خطأ -

إذا قمت بتضمين مسار الطابع الزمني، فإنه يساعدك على فهم بدقة عند تسجيل LKVs ويعزز الشفافية وقابلية التتبع.

inputPath يساوي outputPath

الرسالة الصادرة هي إما قيمة الرسالة الفعلية أو LKV إذا كان المفتاح المتعقب مفقودا من حمولة الرسالة. تأخذ أي قيمة واردة الأولوية ولا تتجاوزها المرحلة باستخدام LKV. لتحديد ما إذا كانت قيمة الرسالة قيمة LKV، استخدم مسار الطابع الزمني. يتم تضمين مسار الطابع الزمني فقط في الرسالة الصادرة إذا كانت القيمة في الرسالة هي LKV المتعقب.

inputPath لا يساوي outputPath

تكتب المرحلة LKV إلى outputPath لكافة الرسائل الواردة. استخدم هذا التكوين لتتبع الفرق بين القيم في حمولات الرسائل اللاحقة.

عينة التكوين

يوضح المثال التالي نموذج رسالة لمرحلة LKV مع وصول الرسالة في 10:02 ومع حمولة تحتوي على قيمة LKV المتعقبة .payload.temperature :

{ 
  { 
    "systemProperties":{ 
        "partitionKey":"pump", 
        "partitionId":5, 
        "timestamp":"2023-01-11T10:02:07Z" 
    }, 
    "qos":1, 
    "topic":"/assets/pump/#" 
    }, 
    "payload":{ 
        "humidity": 10, 
        "temperature":250, 
        "pressure":30, 
        "runningState": true 
    } 
}

تكوين LKV:

الحقل القيمة
مسار الإدخال* .payload.temperature
مسار الإخراج .payload.lkvtemperature
تاريخ انتهاء الصلاحية 10h
مسار الطابع الزمني .payload.lkvtemperature_timestamp

قيم LKV المتعقبة هي:

  • .payload.temperature هو 250.
  • الطابع الزمني ل LKV هو 2023-01-11T10:02:07Z

بالنسبة لرسالة تصل في الساعة 11:05 مع حمولة لا تحتوي على خاصية درجة الحرارة، تثري مرحلة LKV الرسالة بالقيم المتعقبة:

مثال على الإدخال إلى مرحلة LKV في 11:05:

{ 
    "systemProperties":{ 
        "partitionKey":"pump", 
        "partitionId":5, 
        "timestamp":"2023-01-11T11:05:00Z" 
    }, 
    "qos":1, 
    "topic":"/assets/pump/#" 
    }, 
    "payload":{ 
        "runningState": true 
    } 
}

مثال على الإخراج من مرحلة LKV في 11:05:

{ 
    "systemProperties":{ 
        "partitionKey":"pump", 
        "partitionId":5, 
        "timestamp":"2023-01-11T11:05:00Z" 
    }, 
    "qos":1, 
    "topic":"/assets/pump/#" 
    }, 
    "payload":{ 
        "lkvtemperature":250, 
        "lkvtemperature_timestamp"":"2023-01-11T10:02:07Z" 
        "runningState": true 
    } 
}

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