Microsoft Fabricin Data Factory -parametrit

Tässä artikkelissa näytetään, miten voit käyttää parametreja Data Factoryn putkistoissa Fabric-ohjelmassa, jotta voit rakentaa joustavia, uudelleenkäytettäviä työnkulkuja.

Käytä parametreja, lausekkeita ja funktioita Data Factory -putkistoissa

Tässä osiossa käydään läpi perusteet parametrisoitujen putkien luomisesta Data Factoryssa Fabric -ohjelmassa, käyttäen selkeitä esimerkkejä matkan varrella. Parametrit ja dynaamiset lausekkeet säästävät aikaa ja mahdollistavat joustavien Extract, Transform, Load (ETL) tai Extract, Load, Transform (ELT) -ratkaisujen rakentamisen. Ne vähentävät kovakoodausta ja mahdollistavat objektien ja prosessien uudelleenkäytön, mikä helpottaa putkien ylläpitoa ja nopeuttaa uusien ominaisuuksien julkaisua.

Parametri- ja lausekekäsitteet

Parametrien avulla voit välittää ulkoisia arvoja putkiin. Kun asetat parametrin, sen arvo pysyy samana koko pelin ajan. Parametreilla voit käyttää samaa putkea uudelleen eri arvoilla joka kerta. Voit käyttää parametreja itsenäisinä tai sisäisiä lausekkeita, joiden arvot ovat joko kiinteitä tai laskettuja, kun putki käynnistyy.

Lausekkeet voivat mennä mihin tahansa merkkijonon arvoon ja palauttaa aina toisen merkkijonoarvon. Jos esimerkiksi käytät @password, putki käsittelee salasanaa parametrina. Jos arvo on lauseke, poista @ saadaksesi varsinaisen sisällön. Jos haluat käyttää merkkijonon, joka alkaa kirjaimella @, pääse siitä pois kirjoittamalla @@. Seuraavat esimerkit osoittavat, miten tämä toimii käytännössä.

Parametrin arvo Result
"parameters" Merkit "parametrit" palautetaan.
"parameters[1]" Merkit "parameters[1]" palautetaan.
"@@" Yksi merkkimerkkijono, joka sisältää merkin @, palautetaan.
" @" Palautetaan 2 merkkimerkkijono, jonka sisällä on merkki @.

Lausekkeet voivat myös esiintyä merkkijonojen sisällä merkkijonointerpoloinnin kautta, jossa lausekkeet kääritään .@{ ... } Esimerkiksi seuraava merkkijono sisältää parametriarvot ja literaalimerkkijonon arvot:

"Etunimi: @{pipeline().parameters.firstName} Sukunimi: @{pipeline().parameters.lastName}"

Merkkijonojen interpolointi palauttaa aina merkkijonon. Esimerkiksi, jos määrittelet myNumber muodossa 42 ja myStringfoo:

Parametrin arvo Result
"@pipeline().parameters.myString" Palauttaa foo merkkijonona.
"@{pipeline().parameters.myString}" Palauttaa foo merkkijonona.
"@pipeline().parameters.myNumber" Palauttaa 42lukuna.
"@{pipeline().parameters.myNumber}" Palauttaa 42merkkijonona.
"Vastaus on: @{pipeline().parameters.myNumber}" Palauttaa merkkijonon Answer is: 42.
"@concat('Answer on: ', string(pipeline().parameters.myNumber))" Palauttaa merkkijonon Answer is: 42
"Vastaus on: @@{pipeline().parameters.myNumber}" Palauttaa merkkijonon Answer is: @{pipeline().parameters.myNumber}.

Parametrien lausekkeen esimerkkejä

Luo ja käytä parametreja

Parametrien luomiseksi valitse putkieditorin kankaan tausta ja valitse sitten ominaisuudet-ikkunan parametrit-välilehti alareunasta. Valitse + Uusi lisätäksesi parametrin putkeen ja antaaksesi sille nimen, tietotyypin ja oletusarvon:

Näyttökuva, jossa parametrieditori näkyy putken ominaisuussivuilla.

Voit sitten käyttää parametria missä tahansa, missä putkistosi tukee dynaamista sisältöä. Tässä esimerkissä parametri antaa dynaamisesti järvenrakennuksen tietovaraston nimen Copy activity:n ominaisuussivujen Source-välilehdellä.

Näyttökuva, joka näyttää kopiointiaktiviteetin ominaisuussivujen Lähde-välilehden ja korostaa Lisää dynaaminen sisältö -vaihtoehtoa.

Lisää dynaaminen sisältö -ikkuna avautuu. Käytä sitä minkä tahansa dynaamisen sisällön määrittämiseen, mukaan lukien parametrit, järjestelmämuuttujat, funktiot tai putkimuuttujat. Tässä esimerkissä valitset aiemmin määrittelemäsi parametrin, ja dynaaminen sisältöikkuna täyttyy automaattisesti oikealla lausekkeella, joka viittaa siihen.

Näyttökuva, jossa näkyy Lisää dynaaminen sisältö -ikkuna, jossa on valittuna putkiparametri.

Parametrisoi yhteydet

Putkistoyhteyksien parametrisointiin käytä dynaamisesti korvattavan yhteyden globaalia yksilöllistä tunnistetta (GUID).

  1. Ennen kuin muokkaat yhteyttä dynaamisesti putkessasi, hanki haluamasi yhteyden GUID.
  2. Mene kohtaan Asetukset>Hallinnoi yhteyksiä ja yhdyskäytävät.
  3. Etsi yhteyden nimi ja valitse sen vieressä oleva ellipsi (...).
  4. Valitse asetukset ja kopioi yhteystunnus.
  5. Liitä GUID merkkijonoparametriin ja viittaa siihen parametriin dynaamisessa lausekkeessasi.

Esimerkki monimutkaisesta lausekkeesta

Seuraava lauseke viittaa syvään toiminnan alakenttään. Viitataksesi putkistoparametriin, joka arvioi alikenttään, käytetään [] syntaksia pisteoperaattorin (.) sijaan, kuten ja subfield1subfield2.

@activity('*activityName*').output.*subfield1*.*subfield2*[pipeline().parameters.*subfield3*].*subfield4*

Dynaaminen sisältöeditori

Dynaaminen sisältöeditori ohittaa sisällön merkit automaattisesti, kun olet lopettanut muokkauksen. Esimerkiksi seuraava sisältö sisältöeditorissa on merkkijonon interpolointi lausekefunktiolla:

@{toUpper('myData')}

Dynaaminen sisältöeditori muuntaa edellisen sisällön seuraavaksi lausekkeeksi:

MYDATA

Käytä funktioita ja muuttujia lausekkeissa

Voit kutsua funktioita ja käyttää muuttujia lausekkeissa. Seuraavissa osissa on tietoja funktioista, joita voidaan käyttää lausekkeessa.

Putken vaikutusalueen muuttujat

Voit viitata näihin järjestelmämuuttujiin missä tahansa JSON-putkessa.

Muuttujan nimi Description
@pipeline().DataFactory Työtilan nimi, jossa putkisto ajetaan
@pipeline().Pipeline Putken nimi
@pipeline().RunId Tietyn jakson suorituksen tunnus
@pipeline().TriggerId Putken käynnistämen käynnistimen tunnus
@pipeline().TriggerName Putken käynnistämen käynnistimen nimi
@pipeline().TriggerTime Putken käynnistämen käynnistimen suorituksen aika. Tämä arvo on aika, jolloin liipaisin todella laukaisi käynnistääkseen putkiston, ja se voi hieman poiketa laukaisijan aikataulutetusta ajasta.
@pipeline().GroupId Ryhmän tunnus, johon putkisto kuuluu. Microsoft Fabric -pelissä ryhmä on kokoelma toisiinsa liittyviä resursseja, joita hallinnoitte yhdessä. Ryhmät järjestävät ja hallitsevat pääsyä resursseihin, mikä helpottaa käyttöoikeuksien hallintaa ja toimintojen seurantaa useiden putkien välillä.
@pipeline()? TriggeredByPipelineName Sen putken nimen, joka käynnistää putken suorituksen. Se pätee, kun Execute Pipeline -toiminto laukaisee putkiston suorituksen. Arvioi muissa tapauksissa Nulliksi . Huomaa kysymysmerkki jälkeen @pipeline().
@pipeline()? TriggeredByPipelineRunId Suorita sen putken tunnus, joka käynnistää putken suorituksen. Se pätee, kun Execute Pipeline -toiminto laukaisee putkiston suorituksen. Arvioi muissa tapauksissa Nulliksi . Huomaa kysymysmerkki jälkeen @pipeline().

Note

Laukaisimeen liittyvät päivämäärä/aika-järjestelmämuuttujat (sekä putkisto- että laukaisualueissa) palauttavat koordinoidun universaalin ajan (UTC) päivämäärät ISO 8601 -muodossa, esimerkiksi, 2017-06-01T22:20:00.4061448Z.

Merkkijono-funktiot

Merkkijonojen kanssa työskentelyyn käytä näitä merkkijonofunktioita sekä joitakin kokoelmafunktioita. Merkkijonofunktiot toimivat vain merkkijonoissa.

Merkkijonofunktio Task
concat Yhdistä vähintään kaksi merkkijonoa ja palauta yhdistetty merkkijono.
endsWith Tarkista, päättyykö merkkijono määritettyyn alimerkkijonoon.
guid Luo guiD-tunnus merkkijonona.
indexOf Palauta alimerkkijonon aloituskohta.
lastIndexOf Palauta alimerkkijonon viimeisen esiintymän aloituskohta.
replace Korvaa alimerkkijono määritetyllä merkkijonolla ja palauta päivitetty merkkijono.
split Palauta matriisi, joka sisältää pilkuilla eroteltuja alimerkkijonoja, suuremmasta merkkijonosta alkuperäisen merkkijonon määritetyn erottimen perusteella.
startsWith Tarkista, alkaako merkkijono tietyllä alimerkkijonolla.
substring Palauta merkit merkkijonosta aloittaen määritetystä sijainnista.
toLower Palauta merkkijono pienin kirjaimin.
toUpper Palauta merkkijono isoilla kirjaimilla.
trim Poista alussa ja lopussa olevat välilyönnit merkkijonosta ja palauta päivitetty merkkijono.

Kokoelmafunktiot

Kokoelmien, kuten taulukoiden, merkkijonojen ja sanakirjojen kanssa työskentelyyn, käytä näitä kokoelmafunktioita.

Collection-funktio Task
contains Tarkista, onko kokoelmalla tietty kohde.
empty Tarkista, onko kokoelma tyhjä.
first Palauta kokoelman ensimmäinen kohde.
intersection Palauta kokoelma, jossa on vain yleisiä kohteita määritetyissä kokoelmissa.
join Palauta merkkijono, joka on kaikki kohteet matriisissa määritetyllä meerillä eroteltuna.
last Palauta viimeinen kohde kokoelmasta.
length Palauta merkkijonon tai matriisin kohteiden määrä.
skip Poista kohteita kokoelman edestä ja palauta kaikki muut kohteet.
take Palauta kohteet kokoelman edestä.
union Palauta kokoelma, jossa on kaikki kohteita määritetyistä kokoelmista.

Loogiset toiminnot

Käytä näitä funktioita ehtojen sisällä minkä tahansa logiikan arvioimiseksi.

Looginen vertailufunktio Task
and Tarkista, onko kaikki lausekkeet tosia.
equals Tarkista, ovatko molemmat arvot toisiaan vastaavia.
greater Tarkista, onko ensimmäinen arvo suurempi kuin toinen arvo.
greaterOrEquals Tarkista, onko ensimmäinen arvo suurempi tai yhtä suuri kuin toinen arvo.
if Tarkista, onko lauseke tosi vai epätosi. Palauta määritetty arvo tuloksen perusteella.
less Tarkista, onko ensimmäinen arvo pienempi kuin toinen arvo.
lessOrEquals Tarkista, onko ensimmäinen arvo pienempi tai yhtä suuri kuin toinen arvo.
not Tarkista, onko lauseke epätosi.
or Tarkista, onko vähintään yksi lauseke tosi.

Muuntifunktiot

Käytä näitä funktioita muuntaaksesi kunkin kielen alkuperäisen tyypin välillä:

  • merkkijono
  • kokonaisluku
  • liukuluku
  • boolean
  • arrays
  • dictionaries
Muuntamisfunktio Task
array Palauta matriisi yksittäisestä määritetystä syötteestä. Katso useita syötteitä kohdasta createArray.
base64 Palauta merkkijonolle base64-koodattu versio.
base64ToBinary Palauta base64-koodatun merkkijonon binaariversio.
base64ToString Palauta base64-koodatun merkkijonon merkkijonoversio.
binary Palauta syötearvon binaariversio.
bool Palauta syötearvon totuusarvoversio.
coalesce Palauta ensimmäinen muu kuin tyhjäarvo yhdestä tai useammasta parametrista.
createArray Palauta matriisi useista syötettä.
dataUri Palauta syötearvon tietojen URI-osoite.
dataUriToBinary Palauta datan URI-ohjaimen binaariversio.
dataUriToString Palauta datan URI-ohjaimen merkkijonoversio.
decodeBase64 Palauta base64-koodatun merkkijonon merkkijonoversio.
decodeDataUri Palauta datan URI-ohjaimen binaariversio.
decodeUriComponent Palauta merkkijono, joka korvaa escape-merkit koodatuilla versioilla.
encodeUriComponent Palauta merkkijono, joka korvaa URL-osoitteet suojaattomat merkit escape-merkeillä.
float Palauta liukuluku syötearvolle.
int Palauta merkkijonon kokonaislukuversio.
json Palauta JavaScript Object Notation (JSON) -tyyppiarvo tai -objekti merkkijonolle tai XML:lle.
string Palauta syötearvon merkkijonoversio.
uriComponent Palauta syötearvon URI-koodattu versio korvaamalla URL-suojaamattomia merkkejä escape-merkeillä.
uriComponentToBinary Palauta URI-koodatun merkkijonon binaariversio.
uriComponentToString Palauta URI-koodatun merkkijonon merkkijonoversio.
xml Palauta merkkijonon XML-versio.
xpath Tarkista XML:stä solmut tai arvot, jotka vastaavat XPath (XML Path Language) -lauseketta, ja palauta vastaavat solmut tai arvot.

Matemaattiset funktiot

Käytä näitä funktioita molempien lukutyyppien kanssa: kokonaislukujen ja kellukkeiden kanssa.

Matemaattinen funktio Task
add Palauta tulos kahden numeron lisäämisen jälkeen.
div Palauta tulos kahden numeron jakamisesta.
max Palauta suurin arvo lukujen tai matriisin joukosta.
min Palauta pienin arvo lukujen tai matriisin joukosta.
mod Palauta jakojääne kahden numeron jakamisesta.
mul Palauta tuote kahden numeron kertomisesta.
rand Palauta satunnainen kokonaisluku määritetyltä alueelta.
range Palauta kokonaislukumatriisi, joka alkaa määritetystä kokonaisluvusta.
sub Palauta tulos toisen luvun vähentämästä ensimmäisestä luvusta.

Päivämääräfunktiot

Päivämäärä- tai aikafunktio Task
addDays Lisää aikaleimaan päivien määrä.
addHours Lisää aikaleimaan tuntimäärä.
addMinutes Lisää aikaleimaan minuuttien määrä.
addSeconds Lisää aikaleimaan sekuntien määrä.
addToTime Lisää aikayksiköiden määrä aikaleimaan. Katso myös getFutureTime.
convertFromUtc Muunna aikaleima koordinoidusta universaalista ajasta (UTC) tavoiteaikavyöhykkeeksi.
convertTimeZone Muunna aikaleima lähdeaikavyöhykkeestä kohdeaikavyöhykkeeksi.
convertToUtc Muunna aikaleima lähdeaikavyöhykkeeltä koordinoiduksi universaaliksi aikaksi (UTC).
dayOfMonth Palauta kuukauden päivän osa aikaleimasta.
dayOfWeek Palauta viikonpäiväosa aikaleimasta.
dayOfYear Palauta vuoden päiväosa aikaleimasta.
formatDateTime Palauta aikaleima merkkijonona valinnaisessa muodossa.
getFutureTime Palauta nykyinen aikaleima ja määritetyt aikayksiköt. Katso myös LisääToTime.
getPastTime Palauta nykyinen aikaleima vähennettynä määritetyillä aikayksiköillä. Katso myös subtractFromTime.
startOfDay Palauta aikaleima päivän alkuun.
startOfHour Palauta tunnin alku aikaleimalle.
startOfMonth Palauta aikaleima kuukauden alkuun.
subtractFromTime Vähentää aikayksiköiden määrän aikaleimasta. Katso myös getPastTime.
ticks Palauta määritetyn aikaleiman ticks-ominaisuuden arvo.
utcNow Palauta nykyinen aikaleima merkkijonona.

Aiheeseen liittyvä sisältö

  • Last updated on