Compartir vía

Variables del sistema compatibles con Azure Data Factory y Azure Synapse Analytics

  • Artículo

SE APLICA A: Azure Data Factory Azure Synapse Analytics

Sugerencia

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.

Ámbito de canalización

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()

Nota

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.

Ámbito del desencadenador de programación

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.

Ámbito de desencadenador periódico

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.

Ámbito de desencadenador de eventos de almacenamiento

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.

Nota

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.

Ámbito de desencadenador de eventos de personalización

Se puede hacer referencia a estas variables del sistema en cualquier parte del JSON de desencadenador para los desencadenadores de tipo CustomEventsTrigger.

Nota

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.

Contenido relacionado