Udostępnij przez


Zmienne systemowe obsługiwane przez Azure Data Factory i Azure Synapse Analytics

DOTYCZY: Azure Data Factory Azure Synapse Analytics

Tip

Wypróbuj Data Factory w Microsoft Fabric, kompleksowe rozwiązanie analityczne dla przedsiębiorstw. Microsoft Fabric obejmuje wszystko, od przesyłania danych po naukę o danych, analizy w czasie rzeczywistym, analizy biznesowe i raportowanie. Dowiedz się, jak rozpocząć nową wersję próbną za darmo!

Ten artykuł opisuje zmienne systemowe obsługiwane przez Azure Data Factory i Azure Synapse. Możesz używać tych zmiennych w wyrażeniach podczas definiowania jednostek w obrębie dowolnej usługi.

Pipeline scope

Zmienne systemowe można odwołać w dowolnym miejscu w pliku JSON potoku.

Variable Name Description
@pipeline().DataFactory Nazwa danych lub przestrzeni roboczej Synapse, w której uruchamiany jest przebieg potoku.
@pipeline().Pipeline Nazwa potoku
@pipeline().RunId ID konkretnego przebiegu potoku
@pipeline().TriggerType Typ wyzwalacza, który uruchomił potok (na przykład, ScheduleTrigger, BlobEventsTrigger). Aby uzyskać listę obsługiwanych typów wyzwalaczy, zobacz Wykonanie potoku i wyzwalacze. Typ Manual wyzwalacza wskazuje, że potok został wyzwolony ręcznie.
@pipeline().TriggerId Identyfikator wyzwalacza, który uruchomił potok
@pipeline().TriggerName Nazwa wyzwalacza, który uruchomił potok
@pipeline().TriggerTime Czas uruchomienia wyzwalacza, które uruchomiło 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 ID 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 aktywność ExecutePipeline. Oceń jako Null, gdy używane w innych okolicznościach. Zanotuj znak zapytania po @pipeline()
@pipeline()?.TriggeredByPipelineRunId Identyfikator uruchomienia potoku, który inicjuje uruchomienie potoku. Ma zastosowanie, gdy uruchomienie potoku jest wyzwalane przez aktywność ExecutePipeline. Oceń jako Null, gdy używane w innych okolicznościach. Zanotuj znak zapytania po @pipeline()

Note

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

Zmienne systemowe mogą być odwoływane w dowolnym miejscu w JSON obiektu wyzwalającego dla wyzwalaczy typu ScheduleTrigger.

Variable Name Description
@trigger().scheduledTime Czas, o którym zaplanowano wyzwolenie uruchomienia procesu.
@trigger().startTime Czas, w którym wyzwalacz rzeczywiście uruchomił wykonanie potoku. Może się to nieco różnić od zaplanowanego czasu aktywacji.

Zakres wyzwalacza dla okna przesuwnych

Do tych zmiennych systemowych można odwoływać się w dowolnym miejscu w kodzie JSON wyzwalacza dla wyzwalaczy typu TumblingWindowTrigger.

Variable Name Description
@trigger().outputs.windowStartTime Początek okna powiązanego z uruchomieniem wyzwalacza.
@trigger().outputs.windowEndTime Koniec okna powiązanego z wykonaniem wyzwalacza.
@trigger().scheduledTime Czas, o którym zaplanowano wyzwolenie uruchomienia procesu.
@trigger().startTime Czas, w którym wyzwalacz rzeczywiście uruchomił wykonanie potoku. Może się to nieco różnić od zaplanowanego czasu wyzwalacza.

Zakres wyzwalania zdarzenia magazynowania

Te zmienne systemowe mogą być odwoływane w dowolnym miejscu w obiekcie JSON wyzwalacza dla wyzwalaczy typu BlobEventsTrigger.

Variable Name Description
@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 Azure Blob Storage.
@trigger().startTime Moment, w którym wyzwalacz uruchomił wykonanie potoku.

Note

Jeśli tworzysz potok i wyzwalacz w ramach Azure Synapse Analytics, musisz użyć @trigger().outputs.body.fileName i @trigger().outputs.body.folderPath jako parametry. Te dwie właściwości przechwytują informacje o blobach. Użyj tych właściwości zamiast używać @triggerBody().fileName i @triggerBody().folderPath.

Zakres niestandardowego wyzwalacza zdarzeń

Te zmienne systemowe mogą być odniesione w dowolnym miejscu w pliku JSON wyzwalacza dla wyzwalaczy typu CustomEventsTrigger.

Note

Usługa oczekuje, że zdarzenia niestandardowe zostaną sformatowane przy użyciu schematu zdarzeń Azure Event Grid.

Variable Name Description
@triggerBody().event.eventType Rodzaj zdarzeń, które uruchomiły niestandardowy wyzwalacz zdarzeń. Typ zdarzenia jest polem definiowanym przez klienta i może przyjmować dowolne wartości typu string.
@triggerBody().event.subject Temat niestandardowego zdarzenia, które spowodowało uruchomienie wyzwalacza.
@triggerBody().event.data._keyName_ Pole danych w niestandardowym zdarzeniu to dostępny blob JSON, którego klient może użyć do przesyłania wiadomości i danych. Użyj danych keyName, aby odwoływać się do każdego pola. Na przykład @triggerBody().event.data.callback zwraca wartość dla pola callback przechowywanego w data.
@trigger().startTime Moment, w którym wyzwalacz uruchomił wykonanie potoku.

Note

Jeśli tworzysz potok i wyzwalacz w usłudze Azure Synapse Analytics, musisz użyć @trigger().outputs.body.event jako parametrów. Ta właściwość przechwytuje informacje o zdarzeniu. Użyj tej właściwości zamiast .@triggerBody().event