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

  • Artykuł

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ść