الإشارة إلى بيانات تعريف المشغل في عمليات تشغيل التدفق

ينطبق على:Azure Data Factory Azure Synapse Analytics

تلميح

جرب Data Factory في Microsoft Fabric، وهو حل تحليلي متكامل للمؤسسات. يغطي Microsoft Fabric كل شيء بدءا من حركة البيانات إلى علم البيانات والتحليلات في الوقت الحقيقي والمعلومات المهنية وإعداد التقارير. تعرف على كيفية بدء إصدار تجريبي جديد مجانا!

توضح هذه المقالة كيف يمكن استخدام بيانات تعريف المشغل، مثل وقت بدء المشغل، في عملية تشغيل التدفق.

يحتاج التدفق أحياناً إلى فهم بيانات التعريف وقراءتها من المشغل الذي يستدعيها. على سبيل المثال، مع تشغيل مشغل نافذة التدوير، استناداً إلى وقت بدء النافذة ووقت انتهائها، سيعالج التدفق شرائح أو مجلدات بيانات مختلفة. في Azure Data Factory، نستخدم المعلمات ومتغير النظام لتمرير بيانات التعريف من المشغل إلى تدفق.

يُفيد هذا النمط بشكل خاص مشغل نافذة التدوير، حيث يوفر المشغل وقت البدء والانتهاء للنافذة ومشغل الحدث المخصص، حيث يتم تشغيل قيم التحليل والعملية في حقل البيانات المعرفة المخصصة.

إشعار

يوفر نوع المشغل المختلف معلومات بيانات تعريف مختلفة. لمزيد من المعلومات، راجع متغير النظام

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

يوضح هذا القسم كيفية تمرير معلومات بيانات التعريف من المشغل إلى التدفق، ضمن واجهة مستخدم Azure Data Factory.

1. انتقل إلى Authoring Canvas وحرر التدفق

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

3. حدد قسم Parameters وحدد + New لإضافة معلمات

   

4. أضف مشغلات للتدفق، من خلال النقر على + Trigger.

5. قم بإنشاء أو إرفاق مشغل بالبنية الأساسية لبرنامج ربط العمليات التجارية، وحدد OK

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

   

7. لاستخدام القيم في البنية الأساسية لبرنامج ربط العمليات التجارية، استخدم المعلمات pipeline (). parameters.parameterName ، وليس متغير النظام، في تعريفات البنية الأساسية لبرنامج ربط العمليات التجارية. على سبيل المثال، في حالتنا، لقراءة وقت بدء التشغيل، سنشير إلى @pipeline().parameters.parameter_1.

مخطط JSON

لتمرير معلومات المشغل لعمليات تشغيل تدفق، تحتاج كلاً من المشغل وjson للتدفق إلى تحديث لقسم parameters.

تعريف المسار

ضمن قسم properties، أضف تعريفات المعلمات إلى قسم parameters

{
    "name": "demo_pipeline",
    "properties": {
        "activities": [
            {
                "name": "demo_activity",
                "type": "WebActivity",
                "dependsOn": [],
                "policy": {
                    "timeout": "7.00:00:00",
                    "retry": 0,
                    "retryIntervalInSeconds": 30,
                    "secureOutput": false,
                    "secureInput": false
                },
                "userProperties": [],
                "typeProperties": {
                    "url": {
                        "value": "@pipeline().parameters.parameter_2",
                        "type": "Expression"
                    },
                    "method": "GET"
                }
            }
        ],
        "parameters": {
            "parameter_1": {
                "type": "string"
            },
            "parameter_2": {
                "type": "string"
            },
            "parameter_3": {
                "type": "string"
            },
            "parameter_4": {
                "type": "string"
            },
            "parameter_5": {
                "type": "string"
            }
        },
        "annotations": [],
        "lastPublishTime": "2021-02-24T03:06:23Z"
    },
    "type": "Microsoft.DataFactory/factories/pipelines"
}

تعريف المشغل

ضمن قسم pipelines، قم بتعيين قيم المعلمات في قسم parameters. لا تحتاج إلى ملء المعلومات لجميع المعلمات، فقط تلك التي ستفترض قيم بيانات تعريف المشغل.

{
    "name": "trigger1",
    "properties": {
        "annotations": [],
        "runtimeState": "Started",
        "pipelines": [
            {
                "pipelineReference": {
                    "referenceName": "demo_pipeline",
                    "type": "PipelineReference"
                },
                "parameters": {
                    "parameter_1": "@trigger().startTime"
                }
            }
        ],
        "type": "ScheduleTrigger",
        "typeProperties": {
            "recurrence": {
                "frequency": "Minute",
                "interval": 15,
                "startTime": "2021-03-03T04:38:00Z",
                "timeZone": "UTC"
            }
        }
    }
}

استخدام معلومات المشغل في التدفق

لاستخدام القيم في البنية الأساسية لبرنامج ربط العمليات التجارية، استخدم المعلمات pipeline (). parameters.parameterName ، وليس متغير النظام، في تعريفات البنية الأساسية لبرنامج ربط العمليات التجارية.

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

للحصول على معلومات مفصلة حول المشغلات، راجع تنفيذ خط التدفق والمشغلات.