Opprett og kjør aktivitet for brukerdatafunksjoner i pipeliner

Kjør dine tilpassede Python-funksjoner som en del av automatiserte dataflyter ved å legge til en user data functions-aktivitet i en Fabric-pipeline. Denne integrasjonen lar deg sentralisere forretningslogikk i funksjoner og kalle dem under planlagte ETL-prosesser, noe som eliminerer behovet for å duplisere kode på tvers av notatbøker og skript.

Når man skal bruke funksjoner i pipelines

Legg til en aktivitetsaktivitet med user data functions i pipelinen din når du trenger:

• Bruk forretningsregler under dataflyt: Valider, rens eller transformer data mens de flyter gjennom pipelinen din. For eksempel, standardiser produktkategorier eller bruk prisregler før lasting til et lager.
• Tidsplan gjenbrukbar logikk: Kjør samme forretningslogikk på en tidsplan uten å opprettholde separat infrastruktur.

Forutsetninger

Du må fullføre følgende forutsetninger for å komme i gang:

• Et Fabric-arbeidsområde med aktiv kapasitet eller prøvekapasitet.
• Et brukerdata-funksjonselement med minst én funksjon.

Legg til Functions-aktiviteten i en pipeline

Fabric-pipelines gir en visuell måte å orkestrere databevegelse og transformasjonsaktiviteter på. I denne seksjonen oppretter du en pipeline og legger til en Functions-aktivitet i den. I en senere seksjon konfigurerer du aktiviteten spesifikt for brukerdatafunksjoner.

For å lage en pipeline med en Functions-aktivitet:

1. Velg + Nytt elementi arbeidsområdet.

2. I dialogen Nytt element , søk etter Pipeline og velg den.

3. I dialogen Ny pipeline , skriv inn et navn på pipelinen og velg Opprett.

4. På pipeline-hjemmesiden, velg fanen Aktiviteter .

5. I Aktiviteter-båndet, velg ... (ellipse)-ikonet for å se flere aktiviteter.

6. Søk etter Functions i aktivitetslisten under Orchestrate, og velg deretter for å legge til funksjonsaktiviteten på pipeline-lerretet.

   

Konfigurer aktiviteten for user data-funksjoner

Etter at du har lagt til funksjonsaktiviteten på lerretet, konfigurerer du det til å kalle brukerdatafunksjonen din.

Konfigurer generelle innstillinger

1. Velg funksjonsaktiviteten på lerretet.

2. Velg Generelt-fanen .

3. Skriv inn et navn for aktiviteten.

   

4. Eventuelt, konfigurer innstillinger for forsøk på nytt og spesifiser om du sender sikker input eller output.

Konfigurer funksjonsinnstillinger

1. Velg fanen Innstillinger.

2. Select Fabric-brukerdata fungerer som Type.

3. I nedtrekksmenyen for forbindelse velger du en tilkobling du vil bruke. Hvis du ikke ser forbindelsen du ønsker, velg Bla gjennom alle.

4. I dialogen Velg en datakilde for å komme i gang , søk etter User Data Functions og velg den. Du bør se det listet under Nye kilder.

5. I dialogen Connect to data source kan du beholde standard tilkoblingsnavn og legitimasjon. Sørg for at du er innlogget, og velg deretter Koble til.

   

   Note

   Hvis du allerede har en tilkobling, kan den være forhåndsvalgt i dialogen. Du kan beholde den eksisterende tilkoblingen eller velge Opprett ny tilkobling fra nedtrekksmenyen for å opprette en ny.

6. Tilbake i aktivitetsinnstillingene, velg UserDataFunctions fra nedtrekksmenyen Tilkobling . Dette er forbindelsen du nettopp har skapt.

   

7. Velg Workspace som inneholder dine user data functions-element.

8. Velg navnet på brukerdatafunksjonene for oppgaven.

9. Velg funksjonen du vil påkalle.

10. Oppgi inputparametere for den valgte funksjonen du har valgt. Du kan bruke statiske verdier eller dynamisk innhold fra pipeline-uttrykk.

    

    Note

    For å legge inn dynamisk innhold, velg feltet du vil fylle ut, og trykk deretter Alt+Shift+D for å åpne uttrykksbyggeren.

Passdynamiske parametere

For å sende verdier fra andre pipeline-aktiviteter eller variabler til funksjonen din:

1. Velg et felt som støtter dynamisk innhold, for eksempel Verdi-feltet for parameteren name vist tidligere.

2. Trykk Alt+Shift+D for å åpne uttrykksbyggeren.

3. Bruk pipeline-uttrykk for å referere til variabler, parametere eller output fra tidligere aktiviteter. For eksempel, bruk @pipeline().parameters.PipelineName den til å sende en pipeline-parameter til funksjonen din.

   

For mer informasjon om pipeline-uttrykk, se Uttrykk og funksjoner.

Bruk funksjonsutdata i nedstrømsaktiviteter

Funksjonens returverdi er tilgjengelig i aktivitetsutgangen. For å referere til resultatet i påfølgende aktiviteter:

1. Legg til en annen aktivitet i pipelinen din etter Functions-aktiviteten.

2. Velg Funksjoner-aktiviteten og dra dens På suksess-utgang (det grønne hakemerket på høyre side av aktiviteten) til den nye aktiviteten. Dette skaper en avhengighet slik at den nye aktiviteten kjører etter at funksjonen er fullført med suksess.

3. Velg den nye aktiviteten og finn et felt som støtter dynamisk innhold.

4. Trykk Alt+Shift+D for å åpne uttrykksbyggeren.

5. Bruk uttrykket @activity('YourFunctionActivityName').output for å referere funksjonens returverdi. For eksempel er Functions1navnet på funksjonsaktiviteten , som du kan bruke @activity('Functions1').output for å referere til utdata.

   

Den eksakte strukturen på utdataene avhenger av hva funksjonen din returnerer. For eksempel, hvis funksjonen din returnerer en ordbok, kan du få tilgang til spesifikke egenskaper som @activity('YourFunctionActivityName').output.propertyName.

Lagre og kjør rørledningen

Etter at du har konfigureret Functions-aktiviteten og andre aktiviteter for pipelinen din:

1. Velg Hjem-fanen øverst i pipeline-editoren.
2. Velg Lagre for å lagre datasamlebåndet.
3. Velg Kjør for å kjøre pipelinen umiddelbart, eller velg Planlegg for å sette opp en gjentakende tidsplan.

Etter kjøring kan du overvåke pipeline-kjøringen og se kjørehistorikk fra Output-fanen under lerretet. Hvis du vil ha mer informasjon, kan du se Overvåke pipelinekjøringer.

Relatert innhold

• Finn ut mer om programmeringsmodellen for brukerdatafunksjoner
• Bruk parametere i datafabrikkens datafabrikk i Fabric
• Forstå konseptet for pipelinekjøring
• Slik overvåker du datasamlebåndkjøringer i Microsoft Fabric