Filtertransformatie in gegevensstroommapping

Van toepassing op: Azure Data Factory Azure Synapse Analytics

Tip

Data Factory in Microsoft Fabric is de volgende generatie van Azure Data Factory, met een eenvoudigere architectuur, ingebouwde AI en nieuwe functies. Als u nieuw bent in gegevensintegratie, begint u met Fabric Data Factory. Bestaande ADF-workloads kunnen upgraden naar Fabric om toegang te krijgen tot nieuwe mogelijkheden voor gegevenswetenschap, realtime analyses en rapportage.

Gegevensstromen zijn beschikbaar in zowel Azure Data Factory pijplijnen als Azure Synapse Analytics pijplijnen. Dit artikel is van toepassing op het in kaart brengen van datastromen. Als u nieuw bent met transformaties, raadpleegt u het inleidende artikel Gegevens transformeren met behulp van mapping-dataflows.

Tip

Zie voor de equivalente transformatie (rijen filteren) in Dataflow Gen2, een handleiding voor Gegevensstroom Gen2 voor gebruikers van gegegevensstroom-mapping.

Met de filtertransformatie kunnen rijen worden gefilterd op basis van een voorwaarde. De uitvoerstroom bevat alle rijen die overeenkomen met de filtervoorwaarde. De filtertransformatie is vergelijkbaar met een WHERE-component in SQL.

Configuratie

Gebruik de opbouwfunctie voor gegevensstroomexpressies om een expressie voor de filtervoorwaarde in te voeren. Als u de opbouwfunctie voor expressies wilt openen, selecteert u het blauwe vak. De filtervoorwaarde moet van het type Booleaanse waarde zijn. Zie de documentatie van de opbouwfunctie voor expressies voor meer informatie over het maken van een expressie.

Filtertransformatie

Script voor gegevensstroom

Syntaxis

<incomingStream>
    filter(
        <conditionalExpression>
    ) ~> <filterTransformationName>

Voorbeeld

Het onderstaande voorbeeld is een filtertransformatie met de naam FilterBefore1960 die binnenkomende stroom CleanDatainneemt. De filtervoorwaarde is de expressie year <= 1960.

In de gebruikersinterface ziet deze transformatie eruit als in de onderstaande afbeelding:

Filtertransformatie

Het gegevensstroomscript voor deze transformatie bevindt zich in het onderstaande codefragment:

CleanData
    filter(
        year <= 1960
    ) ~> FilterBefore1960

Verwante inhoud

Kolommen filteren met de selectietransformatie.

  • Last updated on