Прочитать на английском

Поделиться через

Системные переменные, поддерживаемые Azure Data Factory и Azure Synapse Analytics

  • Статья
  • 22.04.2025

ПРИМЕНЯЕТСЯ К: Azure Data Factory Azure Synapse Analytics

Совет

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

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

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

Эти системные переменные могут быть использованы в любом месте внутри JSON конвейера.

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

Примечание

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

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

Эти системные переменные могут использоваться в любом месте в JSON триггера для триггеров типа ScheduleTrigger.

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

Область действия запуска окна сдвига

Эти системные переменные могут быть использованы в любом месте JSON триггера для триггеров типа TumblingWindowTrigger.

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

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

Эти системные переменные могут использоваться в любой части JSON триггера для триггеров типа BlobEventsTrigger.

Имя переменной Описание
@triggerBody().fileName Имя файла, создание или удаление которого вызвало срабатывание триггера.
@triggerBody().folderPath Путь к папке, содержащей файл, указанный @triggerBody().fileName. Первый сегмент пути к папке является именем контейнера Azure Blob Storage.
@trigger().startTime Время, когда сработал триггер для вызова запуска конвейера.

Примечание

Если вы создаете свой конвейер и триггер в Azure Synapse Analytics, вы должны использовать @trigger().outputs.body.fileName и @trigger().outputs.body.folderPath в качестве параметров. Эти два свойства фиксируют информацию о блобе. Используйте эти свойства вместо использования @triggerBody().fileName и @triggerBody().folderPath.

Область действия пользовательского триггера события

Эти системные переменные могут использоваться в любом месте JSON триггера для триггеров типа CustomEventsTrigger.

Примечание

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

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

Примечание

Если вы создаёте конвейер и триггер в Azure Synapse Analytics, вы должны использовать @trigger().outputs.body.event в качестве параметров. Это свойство захватывает информацию о событии. Используйте это свойство вместо использования @triggerBody().event.

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