تنفيذ نشاط Wait في Azure Data Factory وSynapse Analytic

  • مقالة

عند استخدام نشاط Wait في مسار، ينتظر المسار لفترة معينة من الوقت قبل المتابعة في تنفيذ الأنشطة اللاحقة.

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

تلميح

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

إنشاء نشاط Wait باستخدام واجهة المستخدم

لاستخدام نشاط الانتظار في المسار، أكمل الخطوات التالية:

  1. ابحث عن Wait في جزء Pipeline Activities، واسحب نشاط Wait إلى لوحة المسار.

  2. حدد نشاط Wait الجديد على اللوحة إذا لم يكن محدداً بالفعل، وعلامة تبويب الإعدادات الخاصة به، لتحرير تفاصيله.

    Shows the UI for a Wait activity.

  3. أدخل عدداً من الثوان حتى ينتظر النشاط. يمكن أن يكون هذا رقماً حرفياً أو أي مجموعة من التعبيرات الديناميكية أو الوظائف أو متغيرات النظام أو المخرجات من أنشطة أخرى.

بناء الجملة

{
    "name": "MyWaitActivity",
    "type": "Wait",
    "typeProperties": {
        "waitTimeInSeconds": 1
    }
}

خصائص النوع

الخاصية ‏‏الوصف القيم المسموح بها المطلوب
الاسم اسم النشاط Wait. السلسلة‬ ‏‏نعم‬
النوع يتعين تعيينه إلى Wait. السلسلة‬ ‏‏نعم‬
waitTimeInSeconds عدد الثواني التي ينتظرها التدفق قبل المتابعة في المعالجة. Integer ‏‏نعم‬

مثال

إشعار

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

التدفق باستخدام نشاط الانتظار

في هذا المثال، ينفذ المسار نشاطين: Until وWait. وقد تم تكوين نشاط الانتظار للانتظار لمدة ثانية واحدة. عمليات تشغيل التدفق لنشاط ويب في حلقة مستخدمًا ثانية واحدة وقت الانتظار بين كل عملية تشغيل.

{
    "name": "DoUntilPipeline",
    "properties": {
        "activities": [
            {
                "type": "Until",
                "typeProperties": {
                    "expression": {
                        "value": "@equals('Failed', coalesce(body('MyUnauthenticatedActivity')?.status, actions('MyUnauthenticatedActivity')?.status, 'null'))",
                        "type": "Expression"
                    },
                    "timeout": "00:10:00",
                    "activities": [
                        {
                            "name": "MyUnauthenticatedActivity",
                            "type": "WebActivity",
                            "typeProperties": {
                                "method": "get",
                                "url": "https://www.fake.com/",
                                "headers": {
                                    "Content-Type": "application/json"
                                }
                            },
                            "dependsOn": [
                                {
                                    "activity": "MyWaitActivity",
                                    "dependencyConditions": [ "Succeeded" ]
                                }
                            ]
                        },
                        {
                            "type": "Wait",
                            "typeProperties": {
                                "waitTimeInSeconds": 1
                            },
                            "name": "MyWaitActivity"
                        }
                    ]
                },
                "name": "MyUntilActivity"
            }
        ]
    }
}

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

راجع أنشطة تدفق التحكم الأخرى المدعومة: