Del via


Parametre for Data Factory i Microsoft Fabric

I dette dokument beskrives det, hvordan du bruger parametre i dine pipelines til Data Factory i Fabric.

Sådan bruger du parametre, udtryk og funktioner i pipelines til Data Factory i Fabric

I dette dokument fokuserer vi på at lære grundlæggende begreber med forskellige eksempler for at udforske muligheden for at oprette parameteriserede datapipelines i Data Factory i Fabric. Parameterisering og dynamiske udtryk kan spare meget tid og give mulighed for en meget mere fleksibel løsning af typen Extract, Transform, Load (ETL) eller Extract, Load, Transform (ELT), hvilket drastisk reducerer omkostningerne ved vedligeholdelse af løsninger og fremskynder implementeringen af nye funktioner i eksisterende pipelines. Disse gevinster skyldes, at parameterisering minimerer mængden af hård kodning og øger antallet af objekter og processer, der kan genbruges, i en løsning.

Parameter- og udtryksbegreber

Du kan bruge parametre til at overføre eksterne værdier til pipelines. Når parameteren er overført til ressourcen, kan den ikke ændres. Ved at parameterisere ressourcer kan du genbruge dem med forskellige værdier hver gang. Parametre kan bruges enkeltvist eller som en del af udtryk. Parameterværdier i definitionen kan være konstanter eller udtryk, der evalueres på kørselstidspunktet.

Udtryk kan vises hvor som helst i en strengværdi og altid generere en anden strengværdi. Her er adgangskode en pipelineparameter i udtrykket. Hvis en parameterværdi er et udtryk, udtrækkes brødteksten i udtrykket ved at fjerne at-tegnet (@). Hvis der kræves en konstantstreng, der starter med @, skal den være escape-strengen ved hjælp af @@. Følgende eksempler viser, hvordan udtryk evalueres.

Parameterværdi Resultat
"parametre" Tegnene 'parametre' returneres.
"parametre[1]" Tegnene 'parametre[1]' returneres.
"@@" Der returneres en streng på 1 tegn, der indeholder '@'.
" @" En streng på 2 tegn, der indeholder ' @', returneres.

Udtryk kan også vises i strenge ved hjælp af en funktion, der kaldes strenginterpolering, hvor udtryk ombrydes i @{ ... }. Følgende streng indeholder f.eks. parameterværdier og konstantstrengværdier:

"Fornavn: @{pipeline().parameters.firstName} Efternavn: @{pipeline().parameters.lastName}"

Ved hjælp af strenginterpolering er resultatet altid en streng. Hvis du f.eks. har defineret myNumber som 42 og myString som foo:

Parameterværdi Resultat
"@pipeline().parameters.myString" Returnerer foo som en streng.
"@{pipeline().parameters.myString}" Returnerer foo som en streng.
"@pipeline().parameters.myNumber" Returnerer 42 som et tal.
"@{pipeline().parameters.myNumber}" Returnerer 42 som en streng.
"Svaret er: @{pipeline().parameters.myNumber}" Returnerer strengen Answer is: 42.
"@concat('Answer is: ', string(pipeline().parameters.myNumber))" Returnerer strengen Answer is: 42
"Svaret er: @@{pipeline().parameters.myNumber}" Returnerer strengen Answer is: @{pipeline().parameters.myNumber}.

Eksempler på brug af parametre i udtryk

Oprettelse og brug af parametre

Hvis du vil oprette parametre, skal du vælge baggrunden af pipelineeditorens lærred og derefter fanen Parametre i egenskabsvinduet nederst. Vælg knappen + Ny for at føje en ny parameter til pipelinen, give den et navn, en datatype og en standardværdi:

Skærmbillede, der viser parametereditoren på egenskabssiderne for en pipeline.

Du kan derefter bruge parameteren et vilkårligt sted i pipelinen, hvor dynamisk indhold understøttes. I dette eksempel bruges parameteren til dynamisk at angive navnet på et Lakehouse-datalager på fanen Source på en kopiaktivitets egenskabssider.

Skærmbillede, der viser fanen Kilde for en kopiaktivitets egenskabssider, hvor indstillingen Tilføj dynamisk indhold fremhæves.

Vinduet Tilføj dynamisk indhold vises, så du kan angive alle typer dynamisk indhold, herunder parametre, systemvariabler, funktionereller pipelinevariabler. I dette eksempel vælges den tidligere definerede parameter, og vinduet med dynamisk indhold udfyldes automatisk med det korrekte udtryk for at referere til parameteren.

Skærmbillede, der viser vinduet Tilføj dynamisk indhold med en pipelineparameter valgt.

Eksempel på komplekst udtryk

I følgende eksempel vises et komplekst eksempel, der refererer til et dybt underfelt af aktivitetsoutput. Hvis du vil referere til en pipelineparameter, der evalueres til et underfelt, skal du bruge [] syntaks i stedet for operatoren dot(.) (som med subfield1 og subfield2)

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

Dynamisk indholdseditor

Den dynamiske indholdseditor undgår automatisk tegn i dit indhold, når du er færdig med at redigere. Følgende indhold i indholdseditoren er f.eks. en strenginterpolering med en udtryksfunktion:

@{toUpper('myData')}

Editoren til dynamisk indhold konverterer det forrige indhold til følgende udtryk:

MYDATA

Brug af funktioner og variabler i udtryk

Du kan kalde funktioner og bruge variabler i udtryk. Følgende afsnit indeholder oplysninger om de funktioner, der kan bruges i et udtryk.

Variabler for pipelineomfang

Der kan refereres til disse systemvariabler overalt i JSON-pipelinen.

Variabelnavn Beskrivelse
@pipeline().DataFactory Navnet på de data eller Synapse-arbejdsområdet, som pipelinekørslen kører i
@pipeline().Pipeline Navnet på pipelinen
@pipeline().RunId Id for den specifikke pipelinekørsel
@pipeline().TriggerId Id'et for den udløser, der aktiverede pipelinen
@pipeline().TriggerName Navnet på den udløser, der aktiverede pipelinen
@pipeline().TriggerTime Tidspunktet for den kørsel af udløseren, der aktiverede pipelinen. Dette er det tidspunkt, hvor udløseren faktisk udløst for at aktivere pipelinekørslen, og det kan afvige en smule fra udløserens planlagte tidspunkt.
@pipeline().GroupId Id'et for den gruppe, som pipelinekørslen tilhører. I Microsoft Fabric refererer en "gruppe" til en samling relaterede ressourcer, der kan administreres sammen. Grupper bruges til at organisere og styre adgangen til ressourcer, hvilket gør det nemmere at administrere tilladelser og overvåge aktiviteter på tværs af flere pipelines.
@pipeline()?. TriggeredByPipelineName Navnet på den pipeline, der udløser pipelinekørslen. Gælder, når pipelinekørslen udløses af en ExecutePipeline-aktivitet. Evaluer til Null-, når det bruges i andre situationer. Bemærk spørgsmålstegnet efter @pipeline()
@pipeline()?. TriggeredByPipelineRunId Kør id'et for den pipeline, der udløser pipelinekørslen. Gælder, når pipelinekørslen udløses af en ExecutePipeline-aktivitet. Evaluer til Null-, når det bruges i andre situationer. Bemærk spørgsmålstegnet efter @pipeline()

Seddel

Systemvariabler relateret til udløsere (både i pipeline- og udløserområder) returnerer UTC-datoer i ISO 8601-format, f.eks. 2017-06-01T22:20:00.4061448Z.

Strengfunktioner

Hvis du vil arbejde med strenge, kan du bruge disse strengfunktioner og nogle samlingsfunktioner. Strengfunktioner fungerer kun på strenge.

Funktionen String Opgave
sammenkæde Kombiner to eller flere strenge, og returner den kombinerede streng.
sluttermed Kontrollér, om en streng slutter med den angivne understreng.
GUID Opret et globalt entydigt id (GUID) som en streng.
indexOf Returner startpositionen for en understreng.
lastIndexOf Returner startpositionen for den sidste forekomst af en understreng.
erstatte Erstat en understreng med den angivne streng, og returner den opdaterede streng.
opdelt Returnerer en matrix, der indeholder understrenge, adskilt af kommaer, fra en større streng, der er baseret på et angivet afgrænsertegn i den oprindelige streng.
starterMed Kontrollér, om en streng starter med en bestemt understreng.
understreng Returnerer tegn fra en streng med start fra den angivne placering.
Returner en streng med små bogstaver.
toUpper- Returnerer en streng med store bogstaver.
trim Fjern foranstillede og efterstillede mellemrum fra en streng, og returner den opdaterede streng.

Samlingsfunktioner

Hvis du vil arbejde med samlinger, generelt matrixer, strenge og nogle gange ordbøger, kan du bruge disse samlingsfunktioner.

Funktionen Collection Opgave
indeholder Kontrollér, om en samling har et bestemt element.
tom Kontrollér, om en samling er tom.
første Returner det første element fra en samling.
skæringspunkt Returner en samling, der kun har de almindelige elementer på tværs af de angivne samlinger.
deltage i Returner en streng, der har alle elementerne fra en matrix adskilt af det angivne tegn.
sidste Returner det sidste element fra en samling.
længde Returner antallet af elementer i en streng eller matrix.
springe over Fjern elementer fra forsiden af en samling, og returner alle de andre elementer.
tager Returner elementer fra forsiden af en samling.
forenings Returner en samling, der har alle elementerne fra de angivne samlinger.

Logiske funktioner

Disse funktioner er nyttige i forhold. De kan bruges til at evaluere enhver type logik.

Logisk sammenligningsfunktion Opgave
og Kontrollér, om alle udtryk er sande.
er lig med Kontrollér, om begge værdier er ækvivalente.
større Kontrollér, om den første værdi er større end den anden værdi.
større EndEquals Kontrollér, om den første værdi er større end eller lig med den anden værdi.
om Kontrollér, om et udtryk er true eller false. På baggrund af resultatet skal du returnere en angivet værdi.
mindre Kontrollér, om den første værdi er mindre end den anden værdi.
- Kontrollér, om den første værdi er mindre end eller lig med den anden værdi.
ikke Kontrollér, om et udtryk er falsk.
eller Kontrollér, om mindst ét udtryk er sandt.

Konverteringsfunktioner

Disse funktioner bruges til at konvertere mellem hver af de oprindelige typer på sproget:

  • streng
  • heltal
  • flyde
  • Boolesk
  • Arrays
  • Ordbøger
Konverteringsfunktion Opgave
matrix Returnerer en matrix fra et enkelt angivet input. Du kan få flere input under createArray.
Returner den base64-kodede version for en streng.
base64ToBinary- Returner den binære version for en base64-kodet streng.
base64ToString- Returner strengversionen for en base64-kodet streng.
binære Returner den binære version for en inputværdi.
bool Returner den booleske version for en inputværdi.
Returner den første værdi, der ikke er null, fra en eller flere parametre.
createArray- Returner en matrix fra flere input.
dataURI- Returner data-URI'en for en inputværdi.
dataUriToBinary- Returner den binære version for en data-URI.
dataUriToString Returner strengversionen for en data-URI.
afkodeBase64- Returner strengversionen for en base64-kodet streng.
decodeDataUri- Returner den binære version for en data-URI.
decodeUriComponent Returner en streng, der erstatter escape-tegn med afkodede versioner.
encodeUriComponent Returner en streng, der erstatter url-usikre tegn med escape-tegn.
flyder Returnerer et flydende tal for en inputværdi.
Returner heltalsversionen for en streng.
json Returner JSON-typen (JavaScript Object Notation) eller objektet for en streng eller XML.
streng Returner strengversionen for en inputværdi.
URIComponent Returner den URI-kodede version for en inputværdi ved at erstatte URL-usikre tegn med escape-tegn.
uriComponentToBinary- Returner den binære version for en URI-kodet streng.
uriComponentToString Returner strengversionen for en URI-kodet streng.
xml- Returner XML-versionen for en streng.
xpath- Kontrollér XML for noder eller værdier, der svarer til et XPath-udtryk (XML Path Language), og returner de matchende noder eller værdier.

Matematiske funktioner

Disse funktioner kan bruges til begge typer tal: heltal og flyder.

Matematisk funktion Opgave
tilføje Returner resultatet ved at tilføje to tal.
Returnerer resultatet ved at dividere to tal.
maks. Returnerer den højeste værdi fra et sæt tal eller en matrix.
min. Returner den laveste værdi fra et sæt tal eller en matrix.
mod Returnerer resten fra at dividere to tal.
mul Returner produktet ved at multiplicere to tal.
rand Returnerer et tilfældigt heltal fra et angivet område.
område Returner en heltalsmatrix, der starter fra et angivet heltal.
under Returnerer resultatet fra at trække det andet tal fra det første tal.

Datofunktioner

Funktionen Dato eller klokkeslæt Opgave
addDays Føj et antal dage til et tidsstempel.
addHours- Føj et antal timer til et tidsstempel.
addMinutes Føj et antal minutter til et tidsstempel.
addSeconds Føj et antal sekunder til et tidsstempel.
addToTime- Føj et antal tidsenheder til et tidsstempel. Se også getFutureTime.
convertFromUtc- Konvertér et tidsstempel fra UTC (Universal Time Coordinated) til måltidszonen.
convertTimeZone- Konvertér et tidsstempel fra kildetidszonen til måltidszonen.
convertToUtc- Konvertér et tidsstempel fra kildetidszonen til UTC (Universal Time Coordinated).
dagfemmåned Returner dag i månedskomponenten fra et tidsstempel.
Returner ugedagskomponenten fra et tidsstempel.
dagfårs- Returner dag i år-komponenten fra et tidsstempel.
formatDateTime Returner tidsstemplet som en streng i valgfrit format.
getFutureTime- Returner det aktuelle tidsstempel plus de angivne tidsenheder. Se også addToTime.
getPastTime- Returner det aktuelle tidsstempel minus de angivne tidsenheder. Se også subtraherFraTid.
startOfDay- Returner starten af dagen for et tidsstempel.
startOfHour- Returner timestart for et tidsstempel.
startOfMonth- Returner starten af måneden for et tidsstempel.
subtraherFraTid Træk et antal tidsenheder fra et tidsstempel. Se også getPastTime.
akser Returner egenskabsværdien ticks for et angivet tidsstempel.
utcNow Returner det aktuelle tidsstempel som en streng.