Luo ja suorita käyttäjätietofunktioiden aktiviteetti putkissa

Aja omat Python-funktiot osana automatisoituja datatyönkulkuja lisäämällä käyttäjätietotoimintojen toiminnon Fabric-putkeen. Tämä integraatio mahdollistaa liiketoimintalogiikan keskittämisen funktioihin ja niiden kutsumisen aikataulutettujen ETL-prosessien aikana, jolloin koodia ei tarvitse kopioida muistikirjojen ja skriptien välillä.

Milloin funktioita kannattaa käyttää putkistoissa

Lisää käyttäjätietofunktioiden aktiviteetti pipelineesi, kun tarvitset:

• Sovella liiketoimintasääntöjä datan siirron aikana: Validoi, puhdista tai muunna dataa sen kulkiessa putkessasi. Esimerkiksi standardoi tuotekategoriat tai sovelletaan hinnoittelusääntöjä ennen lastauksen varastoon.
• Aikatauluta uudelleenkäytettävä logiikka: Suorita sama liiketoimintalogiikka aikataululla ilman erillistä infrastruktuuria.

Ennakkovaatimukset

Jotta voit aloittaa, sinun on täytettävä seuraavat edellytykset:

• Kangastyötila, jossa on aktiivinen kapasiteetti tai koekapasiteetti.
• Käyttäjätietofunktioilla on vähintään yksi funktio.

Lisää Functions-toiminto putkeen

Fabric-putket tarjoavat visuaalisen tavan ohjata datan siirtoa ja muunnostoimia. Tässä osiossa luot putkiston ja lisäät siihen funktio-aktiviteetin. Myöhemmässä osiossa konfiguroit aktiviteetin nimenomaan käyttäjädatan funktioita varten.

Pipelinen luominen funktio-toiminnolla:

1. Valitse työtilassasi + Uusi kohde -.

2. Uusi kohde -valintaikkunasta etsi Pipeline ja valitse se.

3. Uusi putki -valintaikkunassa syötä putkiston nimi ja valitse Luo.

4. Putken etusivulla valitse Toiminnot-välilehti.

5. Aktiviteetit-nauhasta valitse ... (ellipsi) -kuvake nähdäksesi lisää aktiviteetteja.

6. Etsi funktiot toimintojen listasta Orchestrate-kohdasta ja valitse se lisätäksesi funktioaktiviteetit putkistolle.

   

Määritä toiminta käyttäjätietofunktioille

Kun olet lisännyt funktioiden aktiviteetin kankaaseen, määritä se kutsumaan käyttäjätietofunktiotasi.

Yleisten asetusten määrittäminen

1. Valitse funktioiden aktiviteetti kankaalla.

2. Valitse Yleinen-välilehti.

3. Syötä aktiviteetille nimi .

   

4. Halutessasi voit säätää uudelleenyrittämisasetukset ja määrittää, välitätkö turvallisen syötteen vai ulostulon.

Määritä toimintoasetukset

1. Valitse Asetukset-välilehti.

2. Valitse Fabric-käyttäjätiedot toimiiType-toimintona.

3. Connection-pudotusvalikosta valitse yhteys, jota haluat käyttää. Jos et näe haluamaasi yhteyttä, valitse Selaa kaikkia.

4. Valitse tietolähde aloittaaksesi -valintaikkunassa etsi User Data Functions ja valitse se. Sinun pitäisi nähdä se listattuna Uusien lähteiden kohdassa.

5. Yhdistä tietolähteeseen -valintaikkunassa voit säilyttää oletusyhteyden nimen ja tunnistetiedot. Varmista, että olet kirjautuneena sisään, valitse sitten Yhdistä.

   

   Note

   Jos sinulla on jo yhteys, se saattaa olla esivalittuna dialogissa. Voit pitää olemassa olevan yhteyden tai valita Luo uusi yhteys pudotusvalikosta luodaksesi uuden.

6. Takaisin aktiviteettiasetuksista valitse UserDataFunctions Connection-pudotusvalikosta. Tämä on se yhteys, jonka juuri loit.

   

7. Valitse työtila , joka sisältää käyttäjätietofunktioiden kohteen.

8. Valitse käyttäjätietofunktioiden kohteen nimi.

9. Valitse funktio , jonka haluat kutsua.

10. Anna valitulle funktiolle syöteparametrit. Voit käyttää staattisia arvoja tai dynaamista sisältöä putkilausekkeista.

    

    Note

    Syöttääksesi dynaamisen sisällön, valitse haluamasi kenttä ja paina sitten Alt+Shift+D avataksesi ilmaisurakentajan.

Läpäisevät dynaamiset parametrit

Muiden putkitoimintojen tai muuttujien arvojen siirtämiseksi funktioosi:

1. Valitse kenttä, joka tukee dynaamista sisältöä, kuten Arvo-kenttä aiemmin esitetylle name parametrille.

2. Paina Alt+Shift+D avataksesi lausekkeenrakentajan.

3. Käytä putkilausekkeita viitataksesi muuttujiin, parametreihin tai aiempien toimintojen tuotoksiin. Esimerkiksi käytä @pipeline().parameters.PipelineName pipeline-parametrin välittämiseen funktiollesi.

   

Lisätietoja putkilausekkeista löytyy kohdasta Lausekkeet ja funktiot.

Käytä funktiotuotosta alavirran toiminnoissa

Funktiosi palautusarvo on saatavilla toiminnan tulosteessa. Viitataksemme myöhempien toimintojen tulokseen:

1. Lisää toinen aktiviteetti pipelineesi Functions-toiminnon jälkeen.

2. Valitse Functions-aktiviteetti ja vedä sen On-onnistumisen tulos (vihreä valintamerkki aktiviteetin oikealla puolella) uuteen aktiviteettiin. Tämä luo riippuvuuden, jolloin uusi toiminto käynnistyy funktion onnistuneen valmistumisen jälkeen.

3. Valitse uusi aktiviteetti ja etsi kenttä, joka tukee dynaamista sisältöä.

4. Paina Alt+Shift+D avataksesi lausekkeenrakentajan.

5. Käytä lauseketta @activity('YourFunctionActivityName').output viittaamaan funktion palautusarvoon. Esimerkiksi funktiotoiminnan nimi on Functions1, jota voit käyttää @activity('Functions1').output viitataksesi sen ulostuloon.

   

Tuloksen tarkka rakenne riippuu siitä, mitä funktio palauttaa. Esimerkiksi, jos funktiosi palauttaa sanakirjan, voit käyttää tiettyjä ominaisuuksia kuten @activity('YourFunctionActivityName').output.propertyName.

Tallenna ja aja putki

Kun olet konfiguroinut Functions-toiminnon ja muut toiminnot putkellesi:

1. Valitse Koti-välilehti putkenmuokkaajan yläosasta.
2. Tallenna putki valitsemalla Tallenna .
3. Valitse Ajo käynnistääksesi putken välittömästi, tai valitse Ajasta asettaaksesi toistuvan aikataulun.

Suorituksen jälkeen voit seurata putkiston suoritusta ja katsoa suoritushistoriaa Output-välilehdeltä kankaan alapuolella. Lisätietoja on kohdassa Putken suoritusten valvonta.

Aiheeseen liittyvä sisältö

• Lisätietoja käyttäjätietofunktioiden ohjelmointimallista
• Parametrien käyttäminen Fabric Data Factory -putkissa
• Ymmärrä putken ajokonsepti
• Putkien suoritusten seuranta Microsoft Fabricissa