Zmienne systemowe obsługiwane przez usługi Azure Data Factory i Azure Synapse Analytics
DOTYCZY: Azure Data Factory Azure Synapse Analytics
Napiwek
Wypróbuj usługę Data Factory w usłudze Microsoft Fabric — rozwiązanie analityczne typu all-in-one dla przedsiębiorstw. Usługa Microsoft Fabric obejmuje wszystko, od przenoszenia danych do nauki o danych, analizy w czasie rzeczywistym, analizy biznesowej i raportowania. Dowiedz się, jak bezpłatnie rozpocząć nową wersję próbną !
W tym artykule opisano zmienne systemowe obsługiwane przez usługę Azure Data Factory i usługę Azure Synapse. Te zmienne można używać w wyrażeniach podczas definiowania jednostek w ramach jednej z usług.
Zakres potoku
Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu w formacie JSON potoku.
Nazwa zmiennej | opis |
---|---|
@pipeline().DataFactory | Nazwa danych lub obszaru roboczego usługi Synapse, w którym działa przebieg potoku |
@pipeline().Pipeline | Nazwa potoku |
@pipeline().RunId | Identyfikator określonego uruchomienia potoku |
@pipeline().TriggerType | Typ wyzwalacza, który wywołał potok (na przykład ScheduleTrigger , BlobEventsTrigger ). Aby uzyskać listę obsługiwanych typów wyzwalaczy, zobacz Wykonywanie i wyzwalacze potoku. Typ Manual wyzwalacza wskazuje, że potok został wyzwolony ręcznie. |
@pipeline().TriggerId | Identyfikator wyzwalacza, który wywołał potok |
@pipeline().TriggerName | Nazwa wyzwalacza, który wywołał potok |
@pipeline().TriggerTime | Czas uruchomienia wyzwalacza, który wywołał potok. Jest to czas, w którym wyzwalacz rzeczywiście został wyzwolony w celu wywołania uruchomienia potoku i może się nieco różnić od zaplanowanego czasu wyzwalacza. |
@pipeline().GroupId | Identyfikator grupy, do której należy uruchomienie potoku. |
@pipeline()?. TriggeredByPipelineName | Nazwa potoku, który wyzwala uruchomienie potoku. Ma zastosowanie, gdy uruchomienie potoku jest wyzwalane przez działanie ExecutePipeline. Oblicz wartość null , jeśli jest używana w innych okolicznościach. Zanotuj znak zapytania po @pipeline() |
@pipeline()?. TriggeredByPipelineRunId | Identyfikator uruchomienia potoku, który wyzwala uruchomienie potoku. Ma zastosowanie, gdy uruchomienie potoku jest wyzwalane przez działanie ExecutePipeline. Oblicz wartość null , jeśli jest używana w innych okolicznościach. Zanotuj znak zapytania po @pipeline() |
Uwaga
Zmienne systemowe daty/godziny związane z wyzwalaczem (w zakresach potoku i wyzwalacza) zwracają daty UTC w formacie ISO 8601, na przykład 2017-06-01T22:20:00.4061448Z
.
Zakres wyzwalacza harmonogramu
Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu wyzwalacza JSON dla wyzwalaczy typu ScheduleTrigger.
Nazwa zmiennej | opis |
---|---|
@trigger().scheduledTime | Czas, w którym wyzwalacz został zaplanowany do wywołania uruchomienia potoku. |
@trigger().startTime | Czas, w którym wyzwalacz rzeczywiście został wyzwolony w celu wywołania uruchomienia potoku. Może się to nieco różnić od zaplanowanego czasu wyzwalacza. |
Zakres wyzwalacza okna wirowania
Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu wyzwalacza JSON dla wyzwalaczy typu TumblingWindowTrigger.
Nazwa zmiennej | opis |
---|---|
@trigger().outputs.windowStartTime | Początek okna skojarzonego z uruchomieniem wyzwalacza. |
@trigger().outputs.windowEndTime | Koniec okna skojarzonego z uruchomieniem wyzwalacza. |
@trigger().scheduledTime | Czas, w którym wyzwalacz został zaplanowany do wywołania uruchomienia potoku. |
@trigger().startTime | Czas, w którym wyzwalacz rzeczywiście został wyzwolony w celu wywołania uruchomienia potoku. Może się to nieco różnić od zaplanowanego czasu wyzwalacza. |
Zakres wyzwalacza zdarzeń magazynu
Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu wyzwalacza JSON dla wyzwalaczy typu BlobEventsTrigger.
Nazwa zmiennej | opis |
---|---|
@triggerBody().fileName | Nazwa pliku, którego utworzenie lub usunięcie spowodowało uruchomienie wyzwalacza. |
@triggerBody().folderPath | Ścieżka do folderu zawierającego plik określony przez @triggerBody().fileName . Pierwszy segment ścieżki folderu to nazwa kontenera usługi Azure Blob Storage. |
@trigger().startTime | Czas, w którym wyzwalacz został wyzwolony w celu wywołania uruchomienia potoku. |
Uwaga
Jeśli tworzysz potok i wyzwalacz w usłudze Azure Synapse Analytics, musisz użyć parametrów @trigger().outputs.body.fileName
i @trigger().outputs.body.folderPath
jako parametrów. Te dwie właściwości przechwytują informacje o obiekcie blob. Użyj tych właściwości zamiast używać poleceń @triggerBody().fileName
i @triggerBody().folderPath
.
Niestandardowy zakres wyzwalacza zdarzeń
Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu wyzwalacza JSON dla wyzwalaczy typu CustomEventsTrigger.
Uwaga
Usługa oczekuje, że zdarzenia niestandardowe będą formatowane przy użyciu schematu zdarzeń usługi Azure Event Grid.
Nazwa zmiennej | opis |
---|---|
@triggerBody().event.eventType | Typ zdarzeń, które wyzwoliły uruchomienie wyzwalacza zdarzenia niestandardowego. Typ zdarzenia to pole zdefiniowane przez klienta i przyjmują dowolne wartości typu ciągu. |
@triggerBody().event.subject | Temat zdarzenia niestandardowego, które spowodowało wyzwolenie wyzwalacza. |
@triggerBody().event.data._keyName_ | Pole danych w zdarzeniu niestandardowym to bezpłatny obiekt blob JSON, którego klient może użyć do wysyłania komunikatów i danych. Użyj danych.keyName , aby odwołać się do każdego pola. Na przykład @triggerBody().event.data.callback zwraca wartość pola wywołania zwrotnego przechowywanego w danych. |
@trigger().startTime | Czas, w którym wyzwalacz został wyzwolony w celu wywołania uruchomienia potoku. |
Powiązana zawartość
- Aby uzyskać informacje na temat sposobu użycia tych zmiennych w wyrażeniach, zobacz Język wyrażeń i funkcje.
- Aby użyć zmiennych systemowych zakresu wyzwalacza w potoku, zobacz Odwołania do metadanych wyzwalacza w potoku