تصدير بيانات IoT إلى Blob Storage

مقالة
03/05/2024

توضح هذه المقالة كيفية تكوين تصدير البيانات لإرسال البيانات إلى خدمة Blob Storage.

استخدم هذه الميزة لتصدير بيانات IoT المصفاة والمثرية باستمرار من تطبيق IoT Central. يدفع تصدير البيانات التغييرات في الوقت الحقيقي تقريباً إلى أجزاء أخرى من الحل السحابة للحصول على نتيجة تحليلات المسار السريع والتحليلات والتخزين.

على سبيل المثال، يمكنك:

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

تلميح

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

إشعار

في بعض الحالات قد يستغرق تصدير الرسائل ما يصل إلى 60 ثانية. يتم قياس هذه المرة من عندما يتلقى IoT Central الرسالة من مركز IoT الأساسي إلى وقت تسليم الرسالة إلى نقطة النهاية الوجهة.

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

لاستخدام ميزات تصدير البيانات، يجب أن يكون لديك إذن تصدير البيانات.

لمعرفة كيفية إدارة تصدير البيانات باستخدام واجهة برمجة تطبيقات REST ل IoT Central، راجع كيفية استخدام واجهة برمجة تطبيقات REST ل IoT Central لإدارة عمليات تصدير البيانات.

إعداد وجهة تصدير Blob Storage

يصدر IoT Central البيانات مرة واحدة في الدقيقة، مع كل ملف يحتوي على دفعة من التغييرات منذ التصدير السابق. يتم حفظ البيانات المصدرة بتنسيق JSON. المسارات الافتراضية للبيانات المصدرة في حساب التخزين الخاص بك هي:

بيانات تتبع الاستخدام: {container}/{app-id}/{partition_id}/{YYYY}/{MM}/{dd}/{hh}/{mm}/{filename}
تغييرات الخاصية: {container}/{app-id}/{partition_id}/{YYYY}/{MM}/{dd}/{hh}/{mm}/{filename}

لاستعراض الملفات المصدرة في مدخل Microsoft Azure، انتقل إلى الملف وحدد Edit blob.

خيارات الاتصال

تتيح لك وجهات Blob Storage تكوين الاتصال باستخدام سلسلة الاتصال أو هوية مدارة.

تلميح

إذا كانت وجهة Blob Storage محمية بجدار حماية، فيجب عليك استخدام هوية مدارة للاتصال بها.

الهويات المدارة أكثر أمانا لأن:

لا تقوم بتخزين بيانات الاعتماد لموردك في سلسلة الاتصال في تطبيق IoT Central.
ترتبط بيانات الاعتماد تلقائيا بمدة بقاء تطبيق IoT Central الخاص بك.
تقوم الهويات المدارة تلقائيا بتدوير مفاتيح الأمان الخاصة بها بانتظام.

يستخدم IoT Central حاليا الهويات المدارة المعينة من قبل النظام.

عند تكوين هوية مدارة، يتضمن التكوين نطاقا ودورا:

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

يوفر الفيديو التالي المزيد من المعلومات حول الهويات المدارة المعينة من قبل النظام:

تنبيه

للتصدير إلى تخزين كائن ثنائي كبير الحجم، لا تستخدم مساهم حساب التخزين كما هو موضح في الفيديو. استخدم دور Storage Blob Data Contributor بدلا من ذلك.

توضح هذه المقالة كيفية إنشاء هوية مدارة باستخدام Azure CLI. يمكنك أيضا استخدام مدخل Microsoft Azure لإنشاء هوية مدارة.

إذا لم يكن لديك حساب تخزين Azure موجود للتصدير إليه، فقم بتشغيل البرنامج النصي التالي في بيئة Bash Azure Cloud Shell. ينشئ البرنامج النصي مجموعة موارد وحساب Azure Storage وحاوية كائن ثنائي كبير الحجم. ثم يمكن البرنامج النصي الهوية المدارة لتطبيق IoT Central الخاص بك ويعين الدور الذي يحتاجه للوصول إلى حساب التخزين الخاص بك:

# Replace the storage account name with your own unique value.
SA=yourstorageaccount$RANDOM

# Replace the IoT Central app name with the name of your
# IoT Central application.
CA=your-iot-central-app

CN=exportdata
RG=centralexportresources
LOCATION=eastus

az group create -n $RG --location $LOCATION
SAID=$(az storage account create --name $SA --resource-group $RG --location $LOCATION --sku Standard_LRS --query "id" --output tsv)
az storage container create --account-name $SA --resource-group $RG --name $CN

# This assumes your IoT Central application is in the 
# default `IOTC` resource group.
az iot central app identity assign --name $CA --resource-group IOTC --system-assigned
PI=$(az iot central app identity show --name $CA --resource-group IOTC --query "principalId" --output tsv)

az role assignment create --assignee $PI --role "Storage Blob Data Contributor" --scope $SAID

az role assignment list --assignee $PI --all -o table

echo "Endpoint URI: https://$SA.blob.core.windows.net/"
echo "Container: $CN"

يمكنك معرفة المزيد حول إنشاء حسابات تخزين Azure Blob جديدة أو حسابات تخزين Azure Data Lake Storage v2. يمكن لتصدير البيانات كتابة البيانات فقط إلى حسابات التخزين التي تدعم الكائنات الثنائية كبيرة الحجم للكتلة. يعرض الجدول التالي أنواع حسابات التخزين المتوافقة المعروفة:

مستوى الأداء	نوع الحساب
قياسي	الغرض العام V2
قياسي	الغرض العام V1
قياسي	مساحة تخزين Blob
متميز	تخزين كائن ثنائي كبير الحجم للكتلة

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

لإنشاء وجهة Blob Storage في IoT Central في صفحة تصدير البيانات:

حدد + وجهة جديدة.
حدد Azure Blob Storage كنوع الوجهة.
حدد الهوية المدارة المعينة من قبل النظام كنوع التخويل.
أدخل URI نقطة النهاية لحساب التخزين واسم الحاوية الحساسة لحالة الأحرف. يبدو عنوان URI لنقطة النهاية كما يلي: https://contosowaste.blob.core.windows.net.
حدد حفظ.

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

إذا لم يكن لديك حساب تخزين Azure موجود للتصدير إليه، فقم بتشغيل البرنامج النصي التالي في بيئة Bash Azure Cloud Shell. ينشئ البرنامج النصي مجموعة موارد وحساب Azure Storage وحاوية كائن ثنائي كبير الحجم. ثم يطبع سلسلة الاتصال لاستخدامها عند تكوين تصدير البيانات في IoT Central:

# Replace the storage account name with your own unique value
SA=yourstorageaccount$RANDOM
CN=exportdata
RG=centralexportresources
LOCATION=eastus

az group create -n $RG --location $LOCATION
az storage account create --name $SA --resource-group $RG --location $LOCATION --sku Standard_LRS
az storage container create --account-name $SA --resource-group $RG --name $CN

CS=$(az storage account show-connection-string --resource-group $RG --name $SA --query "connectionString" --output tsv)

echo "Storage connection string: $CS"

مستوى الأداء	نوع الحساب
قياسي	الغرض العام V2
قياسي	الغرض العام V1
قياسي	مساحة تخزين Blob
متميز	تخزين كائن ثنائي كبير الحجم للكتلة

لإنشاء وجهة Blob Storage في IoT Central في صفحة تصدير البيانات:

حدد + وجهة جديدة.
حدد Azure Blob Storage كنوع الوجهة.
حدد الاتصال سلسلة كنوع التخويل.
الصق في سلسلة الاتصال لمورد Blob Storage، وأدخل اسم الحاوية الحساسة لحالة الأحرف إذا لزم الأمر.
حدد حفظ.

إعداد تصدير البيانات

الآن بعد أن أصبح لديك وجهة لتصدير بياناتك إليها، قم بإعداد تصدير البيانات في تطبيق IoT Central الخاص بك:

سجل الدخول إلى تطبيق IoT Central.
في الجزء الأيمن، حدد تصدير البيانات.

تلميح

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

اختر نوع البيانات المراد تصديرها. يسرد الجدول التالي أنواع تصدير البيانات المدعومة:

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

اختياريا، أضف عوامل تصفية لتقليل كمية البيانات المصدرة. هناك أنواع مختلفة من عوامل التصفية المتوفرة لكل نوع من أنواع تصدير البيانات:

نوع البيانات	عوامل التصفية المتاحة‬
القياس عن بعد	تصفية حسب اسم الجهاز ومعرف الجهاز وقالب الجهاز وإذا تمت محاكاة الجهاز تدفق التصفية ليحتوي فقط على بيانات تتبع الاستخدام التي تفي بشروط التصفية تدفق التصفية ليحتوي فقط على بيانات تتبع الاستخدام من الأجهزة ذات الخصائص المطابقة لشروط التصفية تدفق التصفية ليحتوي فقط على بيانات تتبع الاستخدام التي تحتوي على خصائص رسالة تفي بشرط عامل التصفية. يتم إرسال خصائص الرسالة (المعروفة أيضا باسم خصائص التطبيق) في حقيبة من أزواج قيمة المفتاح في كل رسالة بيانات تتبع الاستخدام. لإنشاء عامل تصفية خاصية رسالة، أدخل مفتاح خاصية الرسالة الذي تبحث عنه، وحدد شرطا. يتم تصدير رسائل بيانات تتبع الاستخدام التي تحتوي على خصائص تطابق شرط عامل التصفية المحدد فقط. تعرف على المزيد حول خصائص التطبيق من مستندات IoT Hub
تغييرات الخاصية	تصفية حسب اسم الجهاز ومعرف الجهاز وقالب الجهاز وإذا تمت محاكاة الجهاز تصفية الدفق لتحتوي فقط على تغييرات الخاصية التي تفي بشروط التصفية
اتصال الجهاز	التصفية حسب اسم الجهاز ومعرف الجهاز وقالب الجهاز والمؤسسات وإذا تمت محاكاة الجهاز تصفية الدفق لتحتوي فقط على تغييرات من الأجهزة ذات الخصائص المطابقة لشروط التصفية
دورة حياة الجهاز	تصفية حسب اسم الجهاز، ومعرف الجهاز، وقالب الجهاز، وإذا تم توفير الجهاز أو تمكينه أو محاكاته تصفية الدفق لتحتوي فقط على تغييرات من الأجهزة ذات الخصائص المطابقة لشروط التصفية
دورة حياة قالب الجهاز	التصفية حسب قالب الجهاز
سجلات التدقيق	‏‫غير متوفر‬

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

تكوين وجهة التصدير:

حدد + الوجهة لإضافة وجهة قمت بإنشائها بالفعل أو حدد إنشاء وجهة جديدة.
لتحويل بياناتك قبل تصديرها، حدد + Transform. لمعرفة المزيد، راجع تحويل البيانات داخل تطبيق IoT Central للتصدير.
حدد + Destination لإضافة ما يصل إلى خمس وجهات إلى تصدير واحد.
عند الانتهاء من إعداد التصدير، حدد حفظ. بعد بضع دقائق، تظهر بياناتك في وجهاتك.

مراقبة التصدير

في IoT Central، تتيح لك صفحة تصدير البيانات التحقق من حالة عمليات التصدير الخاصة بك. يمكنك أيضا استخدام Azure Monitor لمعرفة مقدار البيانات التي تقوم بتصديرها وأي أخطاء في التصدير. يمكنك الوصول إلى مقاييس التصدير وصحة الجهاز في المخططات في مدخل Microsoft Azure باستخدام أو واجهة برمجة تطبيقات REST أو الاستعلامات في PowerShell أو Azure CLI. حاليا، يمكنك مراقبة مقاييس تصدير البيانات التالية في Azure Monitor:

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

لمعرفة المزيد، راجع مراقبة صحة التطبيق.

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

تصف الأقسام التالية تنسيقات البيانات المصدرة:

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

تحتوي كل رسالة تم تصديرها على نموذج تمت تسويته للرسالة الكاملة التي أرسلها الجهاز في نص الرسالة. الرسالة بتنسيق JSON ويتم ترميزها ك UTF-8. تتضمن المعلومات الواردة في كل رسالة ما يلي:

applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - telemetry.
deviceId: معرف الجهاز الذي أرسل رسالة بيانات تتبع الاستخدام.
schema: اسم وإصدار مخطط الحمولة.
templateId: معرف قالب الجهاز المعين للجهاز.
enqueuedTime: الوقت الذي تلقى فيه IoT Central هذه الرسالة.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.
module: وحدة IoT Edge التي أرسلت هذه الرسالة. يظهر هذا الحقل فقط إذا كانت الرسالة واردة من وحدة IoT Edge.
component: المكون الذي أرسل هذه الرسالة. يظهر هذا الحقل فقط إذا تم تصميم الإمكانات المرسلة في الرسالة كمكون في قالب الجهاز
messageProperties: الخصائص الأخرى التي أرسلها الجهاز مع الرسالة. يشار إلى هذه الخصائص أحيانا باسم خصائص التطبيق. تعرف على المزيد من مستندات IoT Hub.

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

يوضح المثال التالي رسالة بيانات تتبع الاستخدام التي تم تصديرها:


{
    "applicationId": "1dffa667-9bee-4f16-b243-25ad4151475e",
    "messageSource": "telemetry",
    "deviceId": "1vzb5ghlsg1",
    "schema": "default@v1",
    "templateId": "urn:qugj6vbw5:___qbj_27r",
    "enqueuedTime": "2020-08-05T22:26:55.455Z",
    "telemetry": {
        "Activity": "running",
        "BloodPressure": {
            "Diastolic": 7,
            "Systolic": 71
        },
        "BodyTemperature": 98.73447010562934,
        "HeartRate": 88,
        "HeartRateVariability": 17,
        "RespiratoryRate": 13
    },
    "enrichments": {
      "userSpecifiedKey": "sampleValue"
    },
    "module": "VitalsModule",
    "component": "DeviceComponent",
    "messageProperties": {
      "messageProp": "value"
    }
}

خصائص الرسالة

تحتوي رسائل بيانات تتبع الاستخدام على خصائص لبيانات التعريف بالإضافة إلى حمولة بيانات تتبع الاستخدام. تعرض القصاصة البرمجية السابقة أمثلة على رسائل النظام مثل deviceId و enqueuedTime. لمعرفة المزيد حول خصائص رسالة النظام، راجع خصائص النظام لرسائل مركز IoT D2C.

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

توضح القصاصة البرمجية التالية كيفية إضافة الخاصية iothub-creation-time-utc إلى الرسالة عند إنشائها على الجهاز:

هام

يجب أن يكون تنسيق هذا الطابع الزمني بالتوقيت العالمي المتفق عليه دون معلومات عن المنطقة الزمنية. على سبيل المثال، 2021-04-21T11:30:16Z صالح، و2021-04-21T11:30:16-07:00 غير صالح.

async function sendTelemetry(deviceClient, index) {
  console.log('Sending telemetry message %d...', index);
  const msg = new Message(
    JSON.stringify(
      deviceTemperatureSensor.updateSensor().getCurrentTemperatureObject()
    )
  );
  msg.properties.add("iothub-creation-time-utc", new Date().toISOString());
  msg.contentType = 'application/json';
  msg.contentEncoding = 'utf-8';
  await deviceClient.sendEvent(msg);
}

private static void sendTemperatureTelemetry() {
  String telemetryName = "temperature";
  String telemetryPayload = String.format("{\"%s\": %f}", telemetryName, temperature);

  Message message = new Message(telemetryPayload);
  message.setContentEncoding(StandardCharsets.UTF_8.name());
  message.setContentTypeFinal("application/json");
  message.setProperty("iothub-creation-time-utc", Instant.now().toString());

  deviceClient.sendEventAsync(message, new MessageIotHubEventCallback(), message);
  log.debug("My Telemetry: Sent - {\"{}\": {}°C} with message Id {}.", telemetryName, temperature, message.getMessageId());
  temperatureReadings.put(new Date(), temperature);
}

private async Task SendTemperatureTelemetryAsync()
{
  const string telemetryName = "temperature";

  string telemetryPayload = $"{{ \"{telemetryName}\": {_temperature} }}";
  using var message = new Message(Encoding.UTF8.GetBytes(telemetryPayload))
  {
      ContentEncoding = "utf-8",
      ContentType = "application/json",
  };
  message.Properties.Add("iothub-creation-time-utc", DateTime.UtcNow.ToString("yyyy-MM-ddTHH:mm:ssZ"));
  await _deviceClient.SendEventAsync(message);
  _logger.LogDebug($"Telemetry: Sent - {{ \"{telemetryName}\": {_temperature}°C }}.");
}

async def send_telemetry_from_thermostat(device_client, telemetry_msg):
    msg = Message(json.dumps(telemetry_msg))
    msg.custom_properties["iothub-creation-time-utc"] = datetime.now(timezone.utc).isoformat()
    msg.content_encoding = "utf-8"
    msg.content_type = "application/json"
    print("Sent message")
    await device_client.send_message(msg)

تنسيق تغييرات الخاصية

يمثل كل رسالة أو سجل تغييرات على خصائص الجهاز والسحابة. تتضمن المعلومات الواردة في الرسالة المصدرة ما يلي:

applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - properties.
messageType: إما cloudPropertyChangeأو devicePropertyDesiredChangeأو devicePropertyReportedChange.
deviceId: معرف الجهاز الذي أرسل رسالة بيانات تتبع الاستخدام.
schema: اسم وإصدار مخطط الحمولة.
enqueuedTime: الوقت الذي اكتشف فيه IoT Central هذا التغيير.
templateId: معرف قالب الجهاز المعين للجهاز.
properties: صفيف من الخصائص التي تغيرت، بما في ذلك أسماء الخصائص والقيم التي تغيرت. يتم تضمين معلومات المكون والوحدة النمطية إذا تم تصميم الخاصية داخل مكون أو وحدة IoT Edge.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.

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

تعرض القصاصة البرمجية التالية رسالة تغيير خاصية تم تصديرها إلى Blob Storage:

{
    "applicationId": "fb74969c-8682-4708-af01-33499a7f7d98",
    "messageSource": "properties",
    "deviceId": "Pepjmh1Hcc",
    "enqueuedTime": "2023-03-02T10:35:39.281Z",
    "enrichments": {},
    "messageType": "devicePropertyReportedChange",
    "schema": "default@v1",
    "templateId": "dtmi:azureiot:ddzig4ascxz",
    "properties": [
        {
            "component": "device_info",
            "name": "swVersion",
            "value": "12"
        },
        {
            "component": "device_info",
            "name": "osName",
            "value": "Android"
        },
        {
            "component": "device_info",
            "name": "processorArchitecture",
            "value": "arm64-v8a"
        },
        {
            "component": "device_info",
            "name": "processorManufacturer",
            "value": "unknown"
        }
    ]
}

تنسيق تغييرات اتصال الجهاز

يمثل كل رسالة أو سجل حدث اتصال من جهاز واحد. تتضمن المعلومات الواردة في الرسالة المصدرة ما يلي:

applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - deviceConnectivity.
messageType: إما connected أو disconnected.
deviceId: معرف الجهاز الذي تم تغييره.
schema: اسم وإصدار مخطط الحمولة.
templateId: معرف قالب الجهاز المعين للجهاز.
enqueuedTime: الوقت الذي حدث فيه هذا التغيير في IoT Central.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.

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

يوضح المثال التالي رسالة اتصال جهاز تم تصديرها تم تلقيها في Azure Blob Storage.

{
  "applicationId": "1dffa667-9bee-4f16-b243-25ad4151475e",
  "messageSource": "deviceConnectivity",
  "messageType": "connected",
  "deviceId": "1vzb5ghlsg1",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-04-05T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

تنسيق تغييرات دورة حياة الجهاز

يمثل كل رسالة أو سجل تغييرا واحدا على جهاز واحد. تتضمن المعلومات الواردة في الرسالة المصدرة ما يلي:

applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - deviceLifecycle.
messageType: نوع التغيير الذي حدث. واحد من: registeredو deletedو provisionedenabledو. disableddeviceTemplateChangeddisplayNameChanged
deviceId: معرف الجهاز الذي تم تغييره.
schema: اسم وإصدار مخطط الحمولة.
templateId: معرف قالب الجهاز المعين للجهاز.
enqueuedTime: الوقت الذي حدث فيه هذا التغيير في IoT Central.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.

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

يوضح المثال التالي رسالة دورة حياة الجهاز المصدرة المستلمة في Azure Blob Storage.

{
  "applicationId": "1dffa667-9bee-4f16-b243-25ad4151475e",
  "messageSource": "deviceLifecycle",
  "messageType": "registered",
  "deviceId": "1vzb5ghlsg1",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-01-01T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

تنسيق تغييرات دورة حياة قالب الجهاز

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

applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - deviceTemplateLifecycle.
messageType: إما createdأو updatedأو deleted.
schema: اسم وإصدار مخطط الحمولة.
templateId: معرف قالب الجهاز المعين للجهاز.
enqueuedTime: الوقت الذي حدث فيه هذا التغيير في IoT Central.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.

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

يوضح المثال التالي رسالة دورة حياة الجهاز المصدرة المستلمة في Azure Blob Storage.

{
  "applicationId": "1dffa667-9bee-4f16-b243-25ad4151475e",
  "messageSource": "deviceTemplateLifecycle",
  "messageType": "created",
  "schema": "default@v1",
  "templateId": "urn:qugj6vbw5:___qbj_27r",
  "enqueuedTime": "2021-01-01T22:26:55.455Z",
  "enrichments": {
    "userSpecifiedKey": "sampleValue"
  }
}

تنسيق سجل التدقيق

تمثل كل رسالة سجل تدقيق تغييرا بدأه المستخدم إلى كيان قابل للتدقيق داخل تطبيق IoT Central. تتضمن المعلومات الواردة في الرسالة المصدرة ما يلي:

actor: معلومات حول المستخدم الذي قام بتعديل الكيان.
applicationId: معرف تطبيق IoT Central.
messageSource: مصدر الرسالة - audit.
messageType: نوع التغيير الذي حدث. واحد من: updated، ، created. deleted
updated: موجود فقط إذا كان messageType هو updated. يوفر المزيد من التفاصيل حول التحديث.
resource: تفاصيل الكيان المعدل.
schema: اسم وإصدار مخطط الحمولة.
deviceId: معرف الجهاز الذي تم تغييره.
enqueuedTime: الوقت الذي حدث فيه هذا التغيير في IoT Central.
enrichments: أي عمليات إثراء تم إعدادها على التصدير.

يوضح المثال التالي رسالة سجل تدقيق تم تصديرها تم تلقيها في Azure Blob Storage:

{
  "actor": {
    "id": "test-audit",
    "type": "apiToken"
    },
  "applicationId": "570c2d7b-1111-2222-abcd-000000000000",
  "enqueuedTime": "2022-07-25T21:54:40.000Z",
  "enrichments": {},
  "messageSource": "audit",
  "messageType": "created",
  "resource": {
    "displayName": "Sensor 1",
    "id": "sensor",
    "type": "device"    
  },
  "schema": "default@v1"
}

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

الآن بعد أن عرفت كيفية التصدير إلى Blob Storage، فإن الخطوة التالية المقترحة هي تعلم التصدير إلى ناقل خدمة Microsoft Azure.

تصدير بيانات IoT إلى Blob Storage

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

إعداد وجهة تصدير Blob Storage

خيارات الاتصال

إنشاء وجهة Azure Blob Storage

إعداد تصدير البيانات

مراقبة التصدير

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

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

خصائص الرسالة

تنسيق تغييرات الخاصية

تنسيق تغييرات اتصال الجهاز

تنسيق تغييرات دورة حياة الجهاز

تنسيق تغييرات دورة حياة قالب الجهاز

تنسيق سجل التدقيق

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

الموارد الإضافية