Системные переменные, поддерживаемые Фабрикой данных 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 | Время, когда сработал триггер, вызвавший запуск конвейера. |
Связанный контент
- Сведения о том, как эти переменные используются в выражениях, см. в статье Выражения и функции в фабрике данных Azure.
- Сведения об использовании системных переменных области триггера в конвейере см. в Метаданные триггера ссылки в конвейере.