Share via

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

  • Artikel

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.

    Toont een leeg pijplijncanvas met een variabele van het matrixtype die aan de pijplijn is toegevoegd.

  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.

    Toont de gebruikersinterface voor een filteractiviteit.

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

    Toont de   Dynamische inhoud toevoegen  koppeling voor de eigenschap Items.

  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.

    Toont de dynamische inhoudseditor met 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: