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

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

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

بناء الجملة

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

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

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

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

   

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

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

   

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

   

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

   

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

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

خصائص النوع

مثال

في هذا المثال، يحتوي المسار على نشاطين: عامل التصفية و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": []
    }
}

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

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

• نشاط If Condition
• تنفيذ نشاط البنية الأساسية لبرنامج ربط العمليات التجارية
• لكل نشاط
• نشاط الحصول على بيانات تعريف
• نشاط البحث
• نشاط الويب
• حتى النشاط