Flowlettransformatie in gegevensstroom-toewijzing

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 gegevensverwerkingsstromen. Als u nieuw bent met transformaties, raadpleegt u het inleidende artikel Gegevens transformeren met behulp van mapping-dataflows.

Tip

Zie voor de equivalente transformatie (aangepaste functies) in Dataflow Gen2 Een handleiding voor Dataflow Gen2 voor gebruikers van gegevensstromapping.

Gebruik de flowlet-transformatie om een eerder gemaakte flowlet voor gegevensmapping uit te voeren. Zie voor meer informatie over flowlets Flowlets in gegevensstromen toewijzen | Microsoft Docs

Notitie

De stroomlettransformatie in Azure Data Factory- en Synapse Analytics-pijplijnen is momenteel beschikbaar als openbare preview

Configuratie

De stroomlettransformatie bevat de volgende configuratie-instellingen

Schermopname van de configuratie van Flowlet-instellingen.

Flowlet

Selecteer de stroomlet die u wilt uitvoeren. Zodra de flowlet is geselecteerd, kunt u invoerkolommen toewijzen op het tabblad Toewijzing.

Toewijzing

Schermopname waarop het toewijzen van kolommen aan de flowlet-invoer te zien is.

Als de geselecteerde stroomlet invoerkolommen bevat, kunt u kolommen uit de invoerstroom toewijzen aan de verwachte invoerkolommen in de stroomlet. Deze toewijzing van de kolommen voor toewijzingsgegevensstromen aan de stroomlet is wat ervoor zorgt dat de stroomlets kunnen fungeren als herbruikbare fragmenten van toewijzingsgegevensstroomlogica voor mogelijk veel toewijzingsgegevensstromen.

Script voor gegevensstroom

Syntaxis

<incomingStream>
<transformation> ~> <transformationName>
<outputStream>

Voorbeeld

source1 derive(Test = "test") ~> DerivedColumn1
DerivedColumn1 output() ~> output1