Delen via


Door Azure Data Factory en Azure Synapse Analytics ondersteunde systeemvariabelen

Van toepassing op: Azure Data Factory Azure Synapse Analytics

Tip

Probeer Data Factory in Microsoft Fabric, een alles-in-één analyseoplossing voor ondernemingen. Microsoft Fabric omvat alles van gegevensverplaatsing tot datawetenschap, realtime-analyse, bedrijfsinformatie en rapportage. Meer informatie over het gratis starten van een nieuwe proefversie .

Dit artikel beschrijft systeemvariabelen die worden ondersteund door Azure Data Factory en Azure Synapse. U kunt deze variabelen in uitdrukkingen gebruiken bij het definiëren van entiteiten binnen beide diensten.

Pipeline scope

Deze systeemvariabelen kunnen overal in de pipeline JSON worden gebruikt.

Variable Name Description
@pipeline().DataFactory Naam van de gegevens of Synapse-werkruimte waarin de pipeline-uitvoering plaatsvindt
@pipeline().Pipeline Naam van de pijplijn
@pipeline().RunId ID van de specifieke pijplijnuitvoering
@pipeline().TriggerType Het type trigger dat de pijplijn in werking heeft gesteld (bijvoorbeeld, ScheduleTrigger, BlobEventsTrigger). Voor een lijst van ondersteunde trigger types, zie Pipeline-executie en triggers. Een trigger type van Manual geeft aan dat de pijplijn handmatig is gestart.
@pipeline().TriggerId ID van de trigger die de pijplijn heeft aangeroepen
@pipeline().TriggerName Naam van de trigger die de pijplijn heeft opgeroepen
@pipeline().TriggerTime Tijd van de triggeruitvoering die de pijplijn heeft opgeroepen. Dit is het tijdstip waarop de trigger daadwerkelijk wordt geactiveerd om de pijplijnuitvoering aan te roepen. Dit kan enigszins verschillen van de geplande tijd van de trigger.
@pipeline().GroupId ID van de groep waartoe de pijplijnrun behoort.
@pipeline()?.TriggeredByPipelineName Naam van de pijplijn die de uitvoering van de pijplijn triggert. Van toepassing wanneer de pijplijnuitvoering wordt geactiveerd door een ExecutePipeline-activiteit. Beoordeel als Null wanneer gebruikt in andere omstandigheden. Let op het vraagteken na @pipeline()
@pipeline()?.TriggeredByPipelineRunId De run-ID van de pijplijn die de pijplijnrun activeert. Van toepassing wanneer de pijplijnuitvoering wordt geactiveerd door een ExecutePipeline-activiteit. Beoordeel als Null wanneer gebruikt in andere omstandigheden. Let op het vraagteken na @pipeline()

Note

Systeemvariabelen gerelateerd aan de trigger voor datum/tijd (in zowel de pijplijn- als de triggervelden) geven UTC-datums terug in ISO 8601-formaat, bijvoorbeeld 2017-06-01T22:20:00.4061448Z.

Schema triggerbereik

Naar deze systeemvariabelen kan overal in de trigger-JSON worden verwezen voor triggers van het type ScheduleTrigger.

Variable Name Description
@trigger().scheduledTime Het tijdstip waarop de trigger was gepland om de pipeline-run te starten.
@trigger().startTime Tijdstip waarop de trigger actually werd geactiveerd om de pipeline-run te starten. Dit kan enigszins afwijken van de geplande tijd van de trigger.

Bereik van tuimelvenster-trigger

Deze systeemvariabelen kunnen overal in de trigger-JSON worden gebruikt voor triggers van het type TumblingWindowTrigger.

Variable Name Description
@trigger().outputs.windowStartTime Begin van het venster dat verband houdt met de triggeruitvoering.
@trigger().outputs.windowEndTime Eindpunt van het venster dat geassocieerd is met de trigger run.
@trigger().scheduledTime Het tijdstip waarop de trigger was gepland om de pipeline-run te starten.
@trigger().startTime Tijdstip waarop de trigger actually werd geactiveerd om de pipeline-run te starten. Dit kan enigszins afwijken van de geplande tijd van de trigger.

Opslagevenement-triggerbereik

Deze systeemvariabelen kunnen overal in de trigger JSON worden gereferenceerd voor triggers van het type BlobEventsTrigger.

Variable Name Description
@triggerBody().fileName Naam van het bestand waarvan de aanmaak of verwijdering ervoor zorgde dat de trigger afging.
@triggerBody().folderPath Pad naar de map die het bestand bevat gespecificeerd door @triggerBody().fileName. Het eerste segment van het map pad is de naam van de Azure Blob Storage-container.
@trigger().startTime Tijdstip waarop de trigger werd geactiveerd om de uitvoering van de pijplijn te starten.

Note

Als u uw pijplijn en trigger maakt in Azure Synapse Analytics, moet u @trigger().outputs.body.fileName en @trigger().outputs.body.folderPath als parameters gebruiken. Die twee eigenschappen vangen blob-informatie op. Gebruik die eigenschappen in plaats van en @triggerBody().fileNamete gebruiken@triggerBody().folderPath.

Aangepaste gebeurtenis-triggerbereik

Deze systeemvariabelen kunnen overal worden verwezen in de trigger JSON voor triggers van het type CustomEventsTrigger.

Note

De service verwacht dat aangepaste gebeurtenissen worden opgemaakt volgens het Azure Event Grid-gebeurtenisschema.

Variable Name Description
@triggerBody().event.eventType Type gebeurtenissen die de uitvoering van de Aangepaste Gebeurtenistrigger activeerden. Het evenementtype is een door de klant gedefinieerd veld en kan elke waarde van het type string aannemen.
@triggerBody().event.subject Onderwerp van de aangepaste gebeurtenis die ervoor zorgde dat de trigger werd geactiveerd.
@triggerBody().event.data._keyName_ Het gegevensveld in een aangepast evenement is een vrij JSON-blok, dat de klant kan gebruiken om berichten en gegevens te verzenden. Gegevens gebruiken. keyName om naar elk veld te verwijzen. Bijvoorbeeld, @triggerBody().event.data.callback retourneert de waarde voor het callback veld dat is opgeslagen onder data.
@trigger().startTime Tijdstip waarop de trigger werd geactiveerd om de uitvoering van de pijplijn te starten.

Note

Als u uw pijplijn en trigger maakt in Azure Synapse Analytics, moet u @trigger().outputs.body.event als parameters gebruiken. Deze eigenschap legt evenementinformatie vast. Gebruik deze eigenschap in plaats van @triggerBody().event te gebruiken.

  • Voor informatie over hoe deze variabelen in expressies worden gebruikt, zie Expressietaal & functies.
  • Om triggerbereik systeemvariabelen in de pijplijn te gebruiken, zie Referentie trigger metadata in pijplijn