Activiteit filteren in Azure Data Factory- en Synapse Analytics-pijplijnen

U kunt een filteractiviteit in een pijplijn gebruiken om een filterexpressie toe te passen op een invoermatrix.

VAN TOEPASSING OP: Azure Data Factory Azure Synapse Analytics

Tip

Probeer Data Factory uit in Microsoft Fabric, een alles-in-één analyseoplossing voor ondernemingen. Microsoft Fabric omvat alles, van gegevensverplaatsing tot gegevenswetenschap, realtime analyses, business intelligence en rapportage. Meer informatie over het gratis starten van een nieuwe proefversie .

Syntaxis

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

Een filteractiviteit maken met de gebruikersinterface

Voer de volgende stappen uit om een filteractiviteit in een pijplijn te gebruiken:

1. U kunt elke matrixtypevariabele of uitvoer van andere activiteiten gebruiken als invoer voor uw filtervoorwaarde. Als u een matrixvariabele wilt maken, selecteert u de achtergrond van het pijplijncanvas en selecteert u vervolgens het tabblad Variabelen om een matrixtypevariabele toe te voegen, zoals hieronder wordt weergegeven.

   

2. Zoek naar Filter in het deelvenster Activiteiten van de pijplijn en sleep een filteractiviteit naar het pijplijncanvas.

3. Selecteer de nieuwe filteractiviteit op het canvas als deze nog niet is geselecteerd en het tabblad Instellingen om de details ervan te bewerken.

   

4. Selecteer het veld Items en selecteer vervolgens de koppeling Dynamische inhoud toevoegen om het deelvenster dynamische inhoudseditor te openen.

   

5. Selecteer de invoermatrix die u wilt filteren in de dynamische inhoudseditor. In dit voorbeeld selecteren we de variabele die in de eerste stap is gemaakt.

   

6. Gebruik de editor voor dynamische inhoud opnieuw om een filtervoorwaarde op te geven voor de eigenschap Voorwaarde, zoals hierboven wordt weergegeven.

7. U kunt de uitvoer van de filteractiviteit gebruiken als invoer voor andere activiteiten, zoals de ForEach-activiteit.

Typeeigenschappen

Eigenschappen	Beschrijving	Toegestane waarden	Vereist
naam	Naam van de Filter activiteit.	String	Ja
type	Moet worden ingesteld op filteren.	String	Ja
voorwaarde	Voorwaarde die moet worden gebruikt voor het filteren van de invoer.	Expression	Ja
items	Invoermatrix waarop het filter moet worden toegepast.	Expression	Ja

Opmerking

In dit voorbeeld heeft de pijplijn twee activiteiten: Filteren en ForEach. De filteractiviteit is geconfigureerd voor het filteren van de invoermatrix voor items met een waarde die groter is dan 3. De ForEach-activiteit herhaalt vervolgens de gefilterde waarden en stelt de variabeletest in op de huidige waarde.

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

Gerelateerde inhoud

Bekijk andere ondersteunde controlestroomactiviteiten:

• If Condition Activity
• Execute Pipeline Activity
• Voor elke activiteit
• Get Metadata Activity
• Lookup Activity
• Webactiviteit
• Until Activity