Omvandling av villkorsstyrd delning i dataflödesmappning

GÄLLER FÖR: Azure Data Factory Azure Synapse Analytics

Dricks

Prova Data Factory i Microsoft Fabric, en allt-i-ett-analyslösning för företag. Microsoft Fabric omfattar allt från dataflytt till datavetenskap, realtidsanalys, business intelligence och rapportering. Lär dig hur du startar en ny utvärderingsversion kostnadsfritt!

Dataflöden är tillgängliga både i Azure Data Factory och Azure Synapse Pipelines. Den här artikeln gäller för mappning av dataflöden. Om du är nybörjare på transformeringar kan du läsa den inledande artikeln Transformera data med hjälp av ett mappningsdataflöde.

Den villkorliga splittransformeringen dirigerar datarader till olika strömmar baserat på matchande villkor. Omvandlingen av villkorlig delning liknar en CASE-beslutsstruktur på ett programmeringsspråk. Omvandlingen utvärderar uttryck och dirigerar dataraden till den angivna strömmen baserat på resultaten.

Konfiguration

Inställningen Dela på avgör om raden med data flödar till den första matchande dataströmmen eller varje ström som den matchar.

Använd dataflödesuttrycksverktyget för att ange ett uttryck för det delade villkoret. Om du vill lägga till ett nytt villkor klickar du på plusikonen på en befintlig rad. En standardström kan också läggas till för rader som inte matchar något villkor.

Dataflödesskript

Syntax

<incomingStream>
    split(
        <conditionalExpression1>
        <conditionalExpression2>
        ...
        disjoint: {true | false}
    ) ~> <splitTx>@(stream1, stream2, ..., <defaultStream>)

Exempel

Exemplet nedan är en villkorsstyrd splittransformering med namnet SplitByYear som tar in inkommande dataström CleanData. Den här omvandlingen har två delade villkor year < 1960 och year > 1980. disjoint är falskt eftersom data går till det första matchande villkoret i stället för alla matchande villkor. Varje rad som matchar det första villkoret går till utdataströmmen moviesBefore1960. Alla återstående rader som matchar det andra villkoret går till utdataströmmen moviesAFter1980. Alla andra rader flödar via standardströmmen AllOtherMovies.

I tjänstgränssnittet ser den här omvandlingen ut som bilden nedan:

Dataflödesskriptet för den här omvandlingen finns i kodfragmentet nedan:

CleanData
    split(
        year < 1960,
	    year > 1980,
	    disjoint: false
    ) ~> SplitByYear@(moviesBefore1960, moviesAfter1980, AllOtherMovies)

Relaterat innehåll

Vanliga dataflödestransformeringar som används med villkorsstyrd delning är kopplingstransformeringen, uppslagstransformeringen och den valda omvandlingen