Warunkowa transformacja podziału w przepływie danych mapowania

DOTYCZY: Azure Data Factory Azure Synapse Analytics

Napiwek

Wypróbuj usługę Data Factory w usłudze Microsoft Fabric — rozwiązanie analityczne typu all-in-one dla przedsiębiorstw. Usługa Microsoft Fabric obejmuje wszystko, od przenoszenia danych do nauki o danych, analizy w czasie rzeczywistym, analizy biznesowej i raportowania. Dowiedz się, jak bezpłatnie rozpocząć nową wersję próbną !

Przepływy danych są dostępne zarówno w usłudze Azure Data Factory, jak i w potokach usługi Azure Synapse. Ten artykuł dotyczy przepływów danych mapowania. Jeśli dopiero zaczynasz transformacje, zapoznaj się z artykułem wprowadzającym Przekształcanie danych przy użyciu przepływu danych mapowania.

Warunkowa transformacja podziału kieruje wiersze danych do różnych strumieni w oparciu o pasujące warunki. Transformacja podziału warunkowego jest podobna do struktury decyzyjnej CASE w języku programowania. Przekształcenie oblicza wyrażenia i na podstawie wyników kieruje wiersz danych do określonego strumienia.

Konfigurowanie

Ustawienie Podziel według określa, czy wiersz danych przepływa do pierwszego pasującego strumienia, czy każdego zgodnego strumienia.

Użyj konstruktora wyrażeń przepływu danych, aby wprowadzić wyrażenie dla warunku podziału. Aby dodać nowy warunek, kliknij ikonę znaku plus w istniejącym wierszu. Można również dodać strumień domyślny dla wierszy, które nie są zgodne z żadnym warunkiem.

Skrypt przepływu danych

Składnia

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

Przykład

Poniższy przykład to warunkowa transformacja podziału o nazwie SplitByYear , która przyjmuje strumień CleanDataprzychodzący . Ta transformacja ma dwa warunki year < 1960 podziału i year > 1980. disjoint jest fałsz, ponieważ dane przechodzą do pierwszego zgodnego warunku, a nie do wszystkich pasujących warunków. Każdy wiersz pasujący do pierwszego warunku przechodzi do strumienia moviesBefore1960wyjściowego . Wszystkie pozostałe wiersze pasujące do drugiego warunku przechodzą do strumienia moviesAFter1980wyjściowego . Wszystkie inne wiersze przepływają przez strumień AllOtherMoviesdomyślny .

W interfejsie użytkownika usługi ta transformacja wygląda jak na poniższej ilustracji:

Skrypt przepływu danych dla tej transformacji znajduje się w poniższym fragmencie kodu:

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

Powiązana zawartość

Typowe przekształcenia przepływu danych używane z podziałem warunkowym to przekształcenie sprzężenia, przekształcenie odnośnika i transformacja wybierania