Megosztás a következőn keresztül:

Az Azure Data Factory és az Azure Synapse Analytics által támogatott rendszerváltozók

  • Cikk

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Ez a cikk az Azure Data Factory és az Azure Synapse által támogatott rendszerváltozókat ismerteti. Ezeket a változókat kifejezésekben használhatja az entitások bármelyik szolgáltatáson belüli definiálásakor.

Folyamat hatóköre

Ezek a rendszerváltozók a folyamat JSON-jában bárhol hivatkozhatók.

Változó neve Leírás
@pipeline().DataFactory Annak az adatnak vagy Synapse-munkaterületnek a neve, amelyben a folyamat fut
@pipeline().Pipeline A folyamat neve
@pipeline().RunId Az adott folyamatfuttatás azonosítója
@pipeline().TriggerType A folyamatot meghívó eseményindító típusa (például ScheduleTrigger: ; BlobEventsTrigger). A támogatott eseményindító-típusok listáját a folyamatvégrehajtás és az eseményindítók című témakörben találja. Az eseményindító típusa Manual azt jelzi, hogy a folyamat manuálisan lett aktiválva.
@pipeline().TriggerId A folyamatot meghívó eseményindító azonosítója
@pipeline().TriggerName A folyamatot meghívó eseményindító neve
@pipeline().TriggerTime A folyamatot meghívó eseményindító futtatásának időpontja. Ez az az időpont, amikor az eseményindító ténylegesen aktiválódott a folyamatfuttatás meghívásához, és kissé eltérhet az eseményindító ütemezett időpontjától.
@pipeline().GroupId Annak a csoportnak az azonosítója, amelyhez a folyamatfuttatás tartozik.
@pipeline()?. TriggerByPipelineName A folyamatfuttatást kiváltó folyamat neve. Akkor alkalmazható, ha a folyamatfuttatást egy ExecutePipeline-tevékenység aktiválja. Kiértékelése null értékre, ha más körülmények között használják. Jegyezze fel a kérdőjelet a következő után: @pipeline()
@pipeline()?. TriggerByPipelineRunId A folyamatfuttatást kiváltó folyamat futtatási azonosítója. Akkor alkalmazható, ha a folyamatfuttatást egy ExecutePipeline-tevékenység aktiválja. Kiértékelése null értékre, ha más körülmények között használják. Jegyezze fel a kérdőjelet a következő után: @pipeline()

Feljegyzés

Az eseményindítóhoz kapcsolódó dátum- és időrendszerváltozók (mind a folyamat, mind az eseményindító hatókörében) AZ UTC dátumokat ad vissza ISO 8601 formátumban, például 2017-06-01T22:20:00.4061448Z.

Eseményindító hatókörének ütemezése

Ezek a rendszerváltozók a JSON eseményindítóban bárhol hivatkozhatók ScheduleTrigger típusú eseményindítókhoz.

Változó neve Leírás
@trigger().scheduledTime Az eseményindító ütemezésének időpontja a folyamatfuttatás meghívására.
@trigger().startTime Az az időpont, amikor az eseményindító ténylegesen aktiválódott a folyamatfuttatás meghívásához. Ez kissé eltérhet az eseményindító ütemezett időpontjától.

Átfedésmentes ablak eseményindító hatóköre

Ezek a rendszerváltozók a JSON eseményindítóban bárhol hivatkozhatók a TumblingWindowTrigger típusú triggerekhez.

Változó neve Leírás
@trigger().outputs.windowStartTime Az eseményindító futtatásához társított ablak kezdete.
@trigger().outputs.windowEndTime Az eseményindító futtatásához társított ablak vége.
@trigger().scheduledTime Az eseményindító ütemezésének időpontja a folyamatfuttatás meghívására.
@trigger().startTime Az az időpont, amikor az eseményindító ténylegesen aktiválódott a folyamatfuttatás meghívásához. Ez kissé eltérhet az eseményindító ütemezett időpontjától.

Storage eseményindító hatóköre

Ezek a rendszerváltozók a JSON eseményindítóban bárhol hivatkozhatók a BlobEventsTrigger típusú triggerekhez.

Változó neve Leírás
@triggerBody().fileName Annak a fájlnak a neve, amelynek létrehozása vagy törlése miatt az eseményindító aktiválódott.
@triggerBody().folderPath A megadott fájlt @triggerBody().fileNametartalmazó mappa elérési útja. A mappa elérési útjának első szegmense az Azure Blob Storage-tároló neve.
@trigger().startTime Amikor az eseményindító aktiválódott a folyamatfuttatás meghívásához.

Feljegyzés

Ha a folyamatot és az eseményindítót az Azure Synapse Analyticsben hozza létre, paraméterekként és @trigger().outputs.body.folderPath paraméterekként kell használnia@trigger().outputs.body.fileName. Ez a két tulajdonság rögzíti a blobadatokat. Használja ezeket a tulajdonságokat ahelyett, hogy használ és @triggerBody().fileName@triggerBody().folderPath.

Egyéni eseményindító hatóköre

Ezek a rendszerváltozók a JSON eseményindítóban bárhol hivatkozhatók a CustomEventsTrigger típusú triggerekhez.

Feljegyzés

A szolgáltatás elvárja, hogy az egyéni események az Azure Event Grid eseménysémával legyenek formázva.

Változó neve Leírás
@triggerBody().event.eventType Az egyéni eseményindító futtatását kiváltó események típusa. Az eseménytípus egy ügyfél által definiált mező, amely a sztring típusú értékeket veszi figyelembe.
@triggerBody().event.subject Az eseményindítót kiváltó egyéni esemény tárgya.
@triggerBody().event.data._keyName_ Az egyéni esemény adatmezője ingyenes JSON-blob, amellyel az ügyfél üzeneteket és adatokat küldhet. Használjon adatokat.keyName az egyes mezőkre való hivatkozáshoz. Például @triggerBody().event.data.callback az adatok alatt tárolt visszahívási mező értékét adja vissza.
@trigger().startTime Amikor az eseményindító aktiválódott a folyamatfuttatás meghívásához.

Feljegyzés

Ha a folyamatot és az eseményindítót az Azure Synapse Analyticsben hozza létre, paraméterekként kell használnia@trigger().outputs.body.event. Ez a tulajdonság rögzíti az eseményadatokat. A tulajdonság használata helyett használja ezt a tulajdonságot @triggerBody().event.

Kapcsolódó tartalom