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

A KÖVETKEZŐKRE VONATKOZIK: Azure Data Factory Azure Synapse Analytics

Tip

Data Factory a Microsoft Fabric a Azure Data Factory következő generációja, egyszerűbb architektúrával, beépített AI-vel és új funkciókkal. Ha még nem ismerkedik az adatintegrációval, kezdje a Fabric Data Factoryvel. A meglévő ADF-munkaterhelések a Fabricra frissíthetők az adattudomány, a valós idejű elemzés és a jelentéskészítés új képességeinek eléréséhez.

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 Description
@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()?. KiváltvaPipelineNévÁltal A futtatást elindító csővezeték neve. Akkor alkalmazható, ha a folyamatfuttatást egy ExecutePipeline-tevékenység aktiválja. Más körülmények között használva az értéke null lesz. Figyeljen a kérdőjelre @pipeline() után
@pipeline()?. TriggerByPipelineRunId A folyamatfuttatást elindító folyamat azonosítója. Akkor alkalmazható, ha a folyamatfuttatást egy ExecutePipeline-tevékenység aktiválja. Más körülmények között használva az értéke null lesz. Figyeljen a kérdőjelre @pipeline() után

Note

Az eseményindítóval kapcsolatos dátum-/időrendszerváltozók (mind a folyamat, mind az eseményindító hatókörében) az UTC dátumokat ISO 8601 formátumban adják vissza, 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 Description
@trigger().scheduledTime Az aktiváló időpontja, amikor a folyamatfuttatás elindítására sor került.
@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.

Összeomló 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 Description
@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 aktiváló időpontja, amikor a folyamatfuttatás elindítására sor került.
@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 Description
@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 Az az időpont, amikor az indító aktiválódott a folyamatfuttatás elindításához.

Note

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

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.

Note

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 Description
@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ő, és bármilyen szöveges típusú értéket felvehet.
@triggerBody().event.subject A kiváltó mechanizmust aktiváló egyéni esemény témája.
@triggerBody().event.data._keyName_ Az egyéni esemény adatmezője ingyenes JSON-blob, amellyel az ügyfél üzeneteket és adatokat küldhet. Adatok használata. 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 Az az időpont, amikor az indító aktiválódott a folyamatfuttatás elindításához.

Note

Ha az Azure Synapse Analytics-ban hozza létre és aktiválja a folyamatot és a triggert, akkor @trigger().outputs.body.event-t kell használni paraméterekként. Ez a tulajdonság rögzíti az eseményadatokat. Használja ezt a tulajdonságot a @triggerBody().event helyett.

Kapcsolódó tartalom

  • Last updated on