تصفية النشاط في Azure Data Factory والمسار Synapse Analytics

يمكنك استخدام نشاط عامل التصفية في مسار لتطبيق تعبير مرشح على مصفوفة إدخال.

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

تلميح

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

بناء الجملة

{
    "name": "MyFilterActivity",
    "type": "filter",
    "typeProperties": {
        "condition": "<condition>",
        "items": "<input array>"
    }
}

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

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

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

    تظهر لوحة البنية الأساسية لبرنامج ربط العمليات التجارية فارغة مع إضافة متغير نوع مصفوفة إلى البنية الأساسية لبرنامج ربط العمليات التجارية.

  2. ابحث عن Filter في جزء Pipeline Activities، واسحب نشاط Filter إلى لوحة البنية الأساسية.

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

    يظهر واجهة المستخدم لنشاط Filter.

  4. حدد حقل Items ثم حدد الرابط Add dynamic content لفتح جزء محرر المحتوى الديناميكي.

    إظهار   إضافة محتوى ديناميكي&ة; ارتباط للخاصية Items.

  5. حدد صفيف الإدخال لتتم تصفيتها في محرر المحتوى الديناميكي. في هذا المثال، نختار المتغير الذي تم إنشاؤه في الخطوة الأولى.

    يعرض محرر المحتوى الديناميكي مع المتغير الذي تم إنشاؤه في الخطوة الأولى المحددة

  6. استخدم محرر المحتوى الديناميكي مرة أخرى لتحديد شرط عامل تصفية لخاصية Condition، كما هو موضح أعلاه.

  7. يمكنك استخدام الإخراج من نشاط Filter كمدخل لأنشطة أخرى مثل نشاط ForEach.

خصائص النوع

الخاصية ‏‏الوصف القيم المسموح بها المطلوب
الاسم اسم النشاط Filter. السلسلة‬ ‏‏نعم‬
النوع يجب التعيين على عامل التصفية. السلسلة‬ ‏‏نعم‬
condition الشرط المراد استخدامه لتصفية المدخلات. Expression ‏‏نعم‬
العناصر مصفوفة الإدخال التي يجب تطبيق المرشح عليها. Expression ‏‏نعم‬

مثال

في هذا المثال، يحتوي المسار على نشاطين: عامل التصفية وForEach. يتم تكوين نشاط عامل التصفية لتصفية مصفوفة الإدخال للعناصر ذات القيمة الأكبر من 3. يتكرر نشاط ForEach بعد ذلك عبر القيم التي تمت تصفيتها ويضبط المتغير test على القيمة الحالية.

{
    "name": "PipelineName",
    "properties": {
        "activities": [{
                "name": "MyFilterActivity",
                "type": "filter",
                "typeProperties": {
                    "condition": "@greater(item(),3)",
                    "items": "@pipeline().parameters.inputs"
                }
            },
            {
            "name": "MyForEach",
            "type": "ForEach",
            "dependsOn": [
                {
                    "activity": "MyFilterActivity",
                    "dependencyConditions": [
                        "Succeeded"
                    ]
                }
            ],
            "userProperties": [],
            "typeProperties": {
                "items": {
                    "value": "@activity('MyFilterActivity').output.value",
                    "type": "Expression"
                },
                "isSequential": "false",
                "batchCount": 1,
                "activities": [
                    {
                        "name": "Set Variable1",
                        "type": "SetVariable",
                        "dependsOn": [],
                        "userProperties": [],
                        "typeProperties": {
                            "variableName": "test",
                            "value": {
                                "value": "@string(item())",
                                "type": "Expression"
                            }
                        }
                    }
                ]
            }
        }],
        "parameters": {
            "inputs": {
                "type": "Array",
                "defaultValue": [1, 2, 3, 4, 5, 6]
            }
        },
        "variables": {
            "test": {
                "type": "String"
            }
        },
        "annotations": []
    }
}

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