Tevékenység szűrése az Azure Data Factoryben és a Synapse Analytics-folyamatokban

  • Cikk

A folyamat szűrőtevékenységeivel szűrőkifejezést alkalmazhat egy bemeneti tömbre.

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Syntax

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

Szűrőtevékenység létrehozása felhasználói felülettel

Ha szűrőtevékenységet szeretne használni egy folyamatban, hajtsa végre a következő lépéseket:

  1. A szűrőfeltétel bemeneteként bármilyen tömbtípus-változót vagy más tevékenység kimenetét használhatja. Tömbváltozó létrehozásához válassza ki a folyamatvászon hátterét, majd a Változók lapon adjon hozzá egy tömbtípus változót az alább látható módon.

    Shows an empty pipeline canvas with an array type variable added to the pipeline.

  2. Keressen szűrőt a folyamattevékenységek panelen, és húzza a szűrőtevékenységet a folyamatvászonra.

  3. Ha még nincs kijelölve, jelölje ki az új szűrőtevékenységet a vásznon, és a Gépház lapot a részletek szerkesztéséhez.

    Shows the UI for a Filter activity.

  4. Jelölje ki az Elemek mezőt, majd a Dinamikus tartalom hozzáadása hivatkozásra kattintva nyissa meg a dinamikus tartalomszerkesztő panelt.

    Shows the  Add dynamic content  link for the Items property.

  5. Válassza ki a dinamikus tartalomszerkesztőben szűrni kívánt bemeneti tömböt. Ebben a példában az első lépésben létrehozott változót választjuk ki.

    Shows the dynamic content editor with the variable created in the first step selected

  6. Használja ismét a dinamikus tartalomszerkesztőt a Feltétel tulajdonság szűrőfeltételének megadásához, a fent látható módon.

  7. A Szűrő tevékenység kimenetét más tevékenységek, például a ForEach-tevékenység bemeneteként használhatja.

Típustulajdonságok

Property Leírás Megengedett értékek Szükséges
név Filter A tevékenység neve. Sztring Igen
típus Szűrésre kell beállítani. Sztring Igen
feltétel A bemenet szűréséhez használandó feltétel. Expression Igen
elem Bemeneti tömb, amelyre a szűrőt alkalmazni kell. Expression Igen

Példa

Ebben a példában a folyamat két tevékenységgel rendelkezik: Szűrő és ForEach. A szűrőtevékenység úgy van konfigurálva, hogy szűrje a bemeneti tömböt a 3-nál nagyobb értékű elemekre. A ForEach-tevékenység ezután iterálja a szűrt értékeket, és beállítja a változótesztet az aktuális értékre.

{
    "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": []
    }
}

Kapcsolódó tartalom

Lásd az egyéb támogatott vezérlési folyamatokat: