Variables del sistema compatibles con Azure Data Factory y Azure Synapse Analytics
SE APLICA A: Azure Data Factory Azure Synapse Analytics
Argibidea
Pruebe Data Factory en Microsoft Fabric, una solución de análisis todo en uno para empresas. Microsoft Fabric abarca todo, desde el movimiento de datos hasta la ciencia de datos, el análisis en tiempo real, la inteligencia empresarial y los informes. ¡Obtenga más información sobre cómo iniciar una nueva evaluación gratuita!
En este artículo se describen las variables del sistema compatibles con Azure Data Factory y Azure Synapse. Puede usar estas variables en expresiones al definir entidades en cualquiera de los dos servicios.
Se puede hacer referencia a estas variables del sistema en cualquier JSON de la canalización.
Nombre de la variable | Descripción |
---|---|
@pipeline().DataFactory | Nombre de los datos o el área de trabajo de Synapse donde se realiza la ejecución de la canalización |
@pipeline().Pipeline | Nombre de la canalización |
@pipeline().RunId | Id. de la ejecución de canalización específica |
@pipeline().TriggerType | Tipo de desencadenador que ha invocado la canalización (por ejemplo, ScheduleTrigger , BlobEventsTrigger ). Para obtener una lista de los tipos de desencadenadores compatibles, vea Ejecución y desencadenadores de canalización. Un tipo de desencadenador Manual indica que la canalización se desencadenó manualmente. |
@pipeline().TriggerId | Id. del desencadenador que ha invocado la canalización. |
@pipeline().TriggerName | Nombre del desencadenador que ha invocado la canalización. |
@pipeline().TriggerTime | Hora de la ejecución de desencadenador que ha invocado la canalización. Esta es la hora a la que el desencadenador realmente se activó para invocar la ejecución de la canalización y puede diferir ligeramente de la hora programada del desencadenador. |
@pipeline().GroupId | Identificador del grupo al que pertenece la ejecución de canalización. |
@pipeline()?.TriggeredByPipelineName | Nombre de la canalización que desencadena la ejecución de canalización. Se puede aplicar cuando una actividad ExecutePipeline desencadena la ejecución de canalización. Se evalúa como NULL cuando se usa en otras circunstancias. Observe el signo de interrogación después de @pipeline() |
@pipeline()?.TriggeredByPipelineRunId | Identificador de ejecución de la canalización que desencadena la ejecución de canalización. Se puede aplicar cuando una actividad ExecutePipeline desencadena la ejecución de canalización. Se evalúa como NULL cuando se usa en otras circunstancias. Observe el signo de interrogación después de @pipeline() |
Oharra
Las variables del sistema de fecha y hora relacionadas con el desencadenador (en los ámbitos de la canalización y el desencadenador) devuelven las fechas locales en formato ISO 8601; por ejemplo, 2017-06-01T22:20:00.4061448Z
.
Se puede hacer referencia a estas variables del sistema en cualquier parte del JSON de desencadenador para los desencadenadores de tipo ScheduleTrigger.
Nombre de la variable | Descripción |
---|---|
@trigger().scheduledTime | Hora a la que se programó el desencadenador para invocar la ejecución de la canalización. |
@trigger().startTime | Hora a la que realmente se activó el desencadenador para invocar la ejecución de la canalización. Este valor puede diferir ligeramente de la hora programada del desencadenador. |
Se puede hacer referencia a estas variables del sistema en cualquier parte del JSON del desencadenador para los desencadenadores de tipo TumblingWindowTrigger.
Nombre de la variable | Descripción |
---|---|
@trigger().outputs.windowStartTime | Inicio de la ventana asociada a la ejecución del desencadenador. |
@trigger().outputs.windowEndTime | Finalización de la ventana asociada a la ejecución del desencadenador. |
@trigger().scheduledTime | Hora a la que se programó el desencadenador para invocar la ejecución de la canalización. |
@trigger().startTime | Hora a la que realmente se activó el desencadenador para invocar la ejecución de la canalización. Este valor puede diferir ligeramente de la hora programada del desencadenador. |
Se puede hacer referencia a estas variables del sistema en cualquier parte del JSON de desencadenador para los desencadenadores de tipo BlobEventsTrigger.
Nombre de la variable | Descripción |
---|---|
@triggerBody().fileName | Nombre del archivo cuya creación o eliminación hizo que se activara el desencadenador. |
@triggerBody().folderPath | Ruta de acceso a la carpeta que contiene el archivo especificado en @triggerBody().fileName . El primer segmento de la ruta de acceso de la carpeta es el nombre del contenedor de Azure Blob Storage. |
@trigger().startTime | Hora a la que se activó el desencadenador para invocar la ejecución de la canalización. |
Oharra
Si va a crear la canalización y el desencadenador en Azure Synapse Analytics, debe usar @trigger().outputs.body.fileName
y @trigger().outputs.body.folderPath
como parámetros. Esas dos propiedades capturan información del blob. Utilice esas propiedades en lugar de usar @triggerBody().fileName
y @triggerBody().folderPath
.
Se puede hacer referencia a estas variables del sistema en cualquier parte del JSON de desencadenador para los desencadenadores de tipo CustomEventsTrigger.
Oharra
El servicio espera que los eventos personalizados tengan el formato del Esquema de eventos de Azure Event Grid.
Nombre de la variable | Descripción |
---|---|
@triggerBody().event.eventType | Tipo de eventos que desencadenaron la ejecución del desencadenador de eventos personalizados. El tipo de evento es el campo definido por el cliente y toma cualquier valor de tipo de cadena. |
@triggerBody().event.subject | Asunto del evento personalizado que activó el desencadenador. |
@triggerBody().event.data._keyName_ | El campo de datos de evento personalizado es un blob de JSON gratuito, que el cliente puede usar para enviar mensajes y datos. Use data.keyName para hacer referencia a cada campo. Por ejemplo, @triggerBody().event.data.callback devuelve el valor del campo de devolución de llamada almacenado en datos. |
@trigger().startTime | Hora a la que se activó el desencadenador para invocar la ejecución de la canalización. |
- Para información sobre cómo se usan estas variables en las expresiones, vea Expression language & functions (Lenguaje de expresión y funciones).
- Para usar variables del sistema de ámbito de desencadenador en la canalización, consulte Referencia de metadatos de desencadenador en canalización.