Parámetros de JobContext - Microservices Engine - Centro de documentación de Alibaba Cloud

Cuando se ejecuta un trabajo de SchedulerX, el sistema pasa un objeto JobContext al controlador del trabajo. Este objeto proporciona metadatos de tiempo de ejecución (identificadores de trabajo e instancia, horarios de programación, estado de reintentos, configuración de fragmentación y datos del flujo de trabajo) que se usan para implementar lógica condicional, rastrear el estado de ejecución y coordinar tareas distribuidas.

Identificadores

Estos parámetros identifican de forma única el trabajo, su instancia de ejecución y cualquier tarea o flujo de trabajo asociado.

Tipo	Parámetro	Descripción
`long`	`jobId`	Identificador único del trabajo.
`long`	`jobInstanceId`	Identificador único de esta instancia de ejecución.
`Long`	`workflowId`	Identificador del flujo de trabajo que contiene este trabajo.
`long`	`wfInstanceId`	Identificador de la instancia de ejecución actual del flujo de trabajo.
`long`	`taskId`	Identificador de la tarea dentro de un trabajo distribuido. El ID de la tarea raíz es `0`.

workflowId usa el tipo envolvente anulable Long, mientras que los demás parámetros de ID usan el tipo primitivo long.

Programación

Tipo	Parámetro	Descripción
`DateTime`	`scheduleTime`	Hora de activación programada para esta instancia de trabajo.
`DateTime`	`dataTime`	Hora en la que se ejecuta el trabajo en la instancia.

Configuración del trabajo

Tipo	Parámetro	Descripción
`String`	`jobType`	Tipo del trabajo.
`String`	`taskName`	Nombre de la tarea.
`Object`	`task`	Cuerpo de la tarea.
`String`	`jobParameters`	Parámetros estáticos configurados en la consola de SchedulerX. Tamaño máximo: 10,000 bytes.
`String`	`instanceParameters`	Parámetros dinámicos pasados mediante la API al activar una instancia de trabajo.

Estado de reintentos

SchedulerX rastrea los intentos de reintento tanto en la instancia de trabajo como en la tarea.

Tipo	Parámetro	Descripción
`int`	`maxAttempt`	Número máximo de reintentos para la instancia de trabajo.
`int`	`attempt`	Número de intento de reintento actual para la instancia de trabajo.
`int`	`taskMaxAttempt`	Número máximo de reintentos para la tarea actual.
`int`	`taskAttempt`	Número de intento de reintento actual para la tarea actual.

Use attempt y maxAttempt para implementar lógica de reintentos personalizada; por ejemplo, para aumentar los intervalos de espera o enviar alertas en el último intento.

Fragmentación

Estos parámetros están disponibles solo cuando el Execution mode del trabajo se establece en Broadcast run o Shard run.

Tipo	Parámetro	Descripción	Disponibilidad
`Long`	`shardingId`	ID del fragmento asignado a este worker.	Broadcast run, Shard run
`String`	`shardingParameter`	Parámetro de fragmentación que define cómo se divide el trabajo.	Solo Shard run
`int`	`shardingNum`	Número total de fragmentos.	Broadcast run, Shard run

Datos del flujo de trabajo

Tipo	Parámetro	Descripción
`List<JobInstanceData>`	`upstreamData`	Datos provenientes de instancias de trabajo anteriores en el flujo de trabajo. Un flujo de trabajo puede tener varias instancias anteriores.