Feltételes felosztás átalakítása a leképezési adatfolyamban

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Az adatfolyamok az Azure Data Factoryben és az Azure Synapse Pipelinesban is elérhetők. Ez a cikk az adatfolyamok leképezésére vonatkozik. Ha még nem használta az átalakításokat, tekintse meg az adatok leképezési adatfolyam használatával történő átalakításáról szóló bevezető cikket.

A feltételes felosztásos átalakítás az adatsorokat különböző adatfolyamokhoz irányítja az egyeztetési feltételek alapján. A feltételes felosztás átalakítása hasonló a CASE döntési struktúrához egy programozási nyelven. Az átalakítás kiértékeli a kifejezéseket, és az eredmények alapján az adatsort a megadott adatfolyamhoz irányítja.

Konfiguráció

A Felosztás beállítás határozza meg, hogy az adatfolyamok sora az első egyező adatfolyamra vagy minden egyes adatfolyamra egyezik-e.

Az adatfolyam-kifejezésszerkesztő használatával adjon meg egy kifejezést a felosztási feltételhez. Új feltétel hozzáadásához kattintson a plusz ikonra egy meglévő sorban. Egy alapértelmezett stream is hozzáadható olyan sorokhoz, amelyek nem egyeznek semmilyen feltétellel.

Adatfolyamszkript

Syntax

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

Példa

Az alábbi példa egy feltételes felosztású transzformáció, SplitByYear amely a bejövő streambe CleanDatakerül. Ez az átalakítás két felosztási feltételt year < 1960 és year > 1980. disjoint hamis, mert az adatok az első egyező feltételre kerülnek, nem pedig az összes egyező feltételre. Az első feltételnek megfelelő összes sor a kimeneti adatfolyamba moviesBefore1960kerül. A második feltételnek megfelelő összes többi sor a kimeneti streamre moviesAFter1980kerül. Az összes többi sor végigfolyik az alapértelmezett adatfolyamon AllOtherMovies.

A szolgáltatás felhasználói felületén ez az átalakítás az alábbi képhez hasonlóan néz ki:

Az átalakítás adatfolyam-szkriptje az alábbi kódrészletben található:

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

Kapcsolódó tartalom

A feltételes felosztással gyakran használt adatfolyam-átalakítások az illesztési átalakítás, a keresési átalakítás és a kiválasztási átalakítás