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.

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

  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 bijbehorende tabblad Instellingen om de details ervan te bewerken.

    Shows the UI for a Filter activity.

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

    Shows the  Add dynamic content  link for the Items property.

  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.

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

  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
name 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. Expressie Ja
items Invoermatrix waarop het filter moet worden toegepast. Expressie 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: