Системные переменные, поддерживаемые Фабрикой данных Azure и Azure Synapse Analytics

  • Статья

Область применения:Фабрика данных Azure Azure Synapse Analytics

Совет

Попробуйте использовать фабрику данных в Microsoft Fabric, решение для аналитики с одним интерфейсом для предприятий. Microsoft Fabric охватывает все, от перемещения данных до обработки и анализа данных в режиме реального времени, бизнес-аналитики и отчетности. Узнайте, как бесплатно запустить новую пробную версию !

В этой статье описываются системные переменные, поддерживаемые Фабрикой данных Azure и Azure Synapse. Эти переменные можно использовать в выражениях при определении сущностей в любой службе.

Область конвейера

Ссылки на эти системные переменные можно добавлять в любой части JSON конвейера.

Имя переменной Description
@pipeline().DataFactory Имя данных или рабочая область Synapse, в которой выполняется конвейер.
@pipeline().Pipeline Имя конвейера
@pipeline().RunId ИД определенного запуска конвейера
@pipeline().TriggerType Тип триггера, вызвавшего конвейер (например, ScheduleTrigger, BlobEventsTrigger). Список поддерживаемых типов триггеров см. в статье Выполнение конвейера и триггеры. Тип триггера Manual указывает, что конвейер был активирован вручную.
@pipeline().TriggerId Идентификатор триггера, который вызвал конвейер.
@pipeline().TriggerName Имя триггера, который вызвал конвейер.
@pipeline().TriggerTime Время выполнения триггера, который вызвал конвейер. Это время, когда триггер реально срабатывает для вызова выполнения конвейера и может немного отличаться от запланированного времени срабатывания.
@pipeline().GroupId Идентификатор группы, к которой принадлежит выполнение конвейера.
@pipeline()?.TriggeredByPipelineName Имя конвейера, активирующее выполнение конвейера. Применяется, когда выполнение конвейера активируется действием ExecutePipeline. При использовании в других обстоятельствах будет иметь значение NULL. Обратите внимание на вопросительный знак после @pipeline()
@pipeline()?.TriggeredByPipelineRunId Идентификатор выполнения конвейера, активирующий выполнение конвейера. Применяется, когда выполнение конвейера активируется действием ExecutePipeline. При использовании в других обстоятельствах будет иметь значение NULL. Обратите внимание на вопросительный знак после @pipeline()

Примечание.

Системные переменные даты и времени, связанные с триггерами (в областях конвейера и триггера), возвращают даты по Гринвичу в формате ISO 8601, например 2017-06-01T22:20:00.4061448Z.

Область триггера расписания

Ссылки на эти системные переменные можно добавлять в любой части JSON триггера, если это триггер типа ScheduleTrigger.

Имя переменной Description
@trigger().scheduledTime Время, на которое запланирован вызов запуска конвейера.
@trigger().startTime Время, в которое реально произошел вызов запуска конвейера. Оно может немного отличаться от запланированного времени срабатывания триггера.

Область триггера "переворачивающегося" окна

Ссылки на эти системные переменные можно добавлять в любой части JSON триггера, если это триггер типа TumblingWindowTrigger.

Имя переменной Description
@trigger().outputs.windowStartTime Начало окна, связанного с выполнением триггера.
@trigger().outputs.windowEndTime Конец окна, связанного с выполнением триггера.
@trigger().scheduledTime Время, на которое запланирован вызов запуска конвейера.
@trigger().startTime Время, в которое реально произошел вызов запуска конвейера. Оно может немного отличаться от запланированного времени срабатывания триггера.

Область триггера событий хранилища

Ссылки на эти системные переменные можно добавлять в любой части JSON триггера, если это триггер типа BlobEventsTrigger.

Имя переменной Description
@triggerBody().fileName Имя файла, создание или удаление которого вызвало срабатывание триггера.
@triggerBody().folderPath Путь к папке, содержащей файл, указанный @triggerBody().fileName. Первый сегмент пути к папке — это имя контейнера хранилища BLOB-объектов Azure.
@trigger().startTime Время, когда сработал триггер, вызвавший запуск конвейера.

Примечание.

При создании конвейера и триггера в Azure Synapse Analytics необходимо использовать @trigger().outputs.body.fileName и @trigger().outputs.body.folderPath в качестве параметров. Эти два свойства захватывают данные большого двоичного объекта. Используйте эти свойства вместо @triggerBody().fileName и @triggerBody().folderPath.

Область триггера настраиваемых событий

Ссылки на эти системные переменные можно добавлять в любой части JSON триггера, если это триггер типа CustomEventsTrigger.

Примечание.

Служба ждет, что пользовательские события будут отформатированы с помощью схемы событий службы "Сетка событий Azure".

Имя переменной Description
@triggerBody().event.eventType Тип событий, вызвавших запуск триггера пользовательского события. Тип события является полем, определяемым клиентом, и принимает любые значения строкового типа.
@triggerBody().event.subject Тема пользовательского события, вызвавшего запуск триггера.
@triggerBody().event.data._keyName_ Поле данных в пользовательском событии доступно бесплатно из большого двоичного объекта JSON, который клиент может использовать для отправки сообщений и данных. Используйте данные keyName для ссылки на каждое из полей. Например, @triggerBody().event.data.callback возвращает значение для поля callback, хранящегося в разделе data.
@trigger().startTime Время, когда сработал триггер, вызвавший запуск конвейера.

Связанный контент