Visualización de un mapa distribuido Ejecute la ejecución en Step Functions - AWS Step Functions

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Visualización de un mapa distribuido Ejecute la ejecución en Step Functions

La consola de Step Functions proporciona una página Detalles de Map Run que muestra toda la información relacionada con la ejecución de un estado Map Distributed. Por ejemplo, puede ver el estado de la ejecución del estado del mapa distribuido, la ejecución del ARN mapa y los estados de los elementos procesados en las ejecuciones del flujo de trabajo secundario iniciadas por el estado del mapa distribuido. También puede ver una lista de todas las ejecuciones de flujos de trabajo secundarios y acceder a sus detalles. Si su ejecución del mapa fue redriven, verás redrive detalles también en el resumen de ejecución de Map Run.

Cuando se ejecuta un estado Map en modo distribuido, Step Functions crea un recurso Map Run. Map Run hace referencia a un conjunto de ejecuciones de flujos de trabajo secundarios que inicia un estado Map Distributed y a la configuración de tiempo de ejecución que controla estas ejecuciones. Step Functions asigna un nombre de recurso de Amazon (ARN) a su Map Run. Puede examinar un Map Run en la consola de Step Functions. También puede invocar la DescribeMapRun API acción. A Map Run también emite métricas a. CloudWatch

Los detalles de la ejecución del mapa tienen tres secciones: el resumen de la ejecución del mapa, el estado del procesamiento del elemento y la lista de ejecuciones.

Resumen de ejecución de Map Run

El resumen de la ejecución de Map Run proporciona una visión general de los detalles de ejecución del estado del mapa distribuido.

Detalles

Muestra el estado de ejecución del estado del mapa distribuido, la ejecución ARN del mapa y el tipo de ejecuciones del flujo de trabajo secundario iniciadas por el estado del mapa distribuido. Puede ver configuraciones adicionales, como el umbral de error tolerado para el Map Run y la simultaneidad máxima especificada para las ejecuciones de flujos de trabajo secundarios.

Entrada y salida

Muestra la entrada recibida por el estado Map Distributed y la salida correspondiente que genera.

Puede ver el conjunto de datos de entrada y su ubicación, así como los filtros de entrada aplicados a los elementos de datos individuales de ese conjunto de datos. Si exporta el resultado de la ejecución del estado Map Distributed, esta pestaña muestra la ruta al bucket de Amazon S3 que contiene los resultados de la ejecución. De lo contrario, lo dirigirá a la página Detalles de ejecución del flujo de trabajo principal para ver el resultado de la ejecución.

Mensaje de error

Si el Map Run produce un error, la página Detalles de Map Run muestra un mensaje de error con el motivo del error.

Desde el botón desplegable Recuperar de este mensaje de error, puedes hacer lo siguiente: redrive las ejecuciones fallidas del flujo de trabajo secundario iniciadas por este Map Run o iniciar una nueva ejecución del flujo de trabajo principal.

Consulte Redriving El mapa se ejecuta para obtener información sobre cómo reiniciar su flujo de trabajo.

Estado del procesamiento de elementos

La sección Estado del procesamiento de elementos muestra el estado de los elementos procesados en un Map Run. Por ejemplo, Pendiente indica que la ejecución de un flujo de trabajo secundario aún no ha empezado a procesar el elemento.

Los estados de los elementos dependen del estado de las ejecuciones de los flujos de trabajo secundarios que procesan los elementos. Si se produce un error en la ejecución de un flujo de trabajo secundario, se agota el tiempo de espera o un usuario cancela la ejecución, Step Functions no recibe ninguna información sobre el resultado del procesamiento de los elementos incluidos en la ejecución del flujo de trabajo secundario. Todos los elementos procesados por esa ejecución comparten el estado de ejecución del flujo de trabajo secundario.

Por ejemplo, supongamos que desea procesar 100 elementos en dos ejecuciones de flujos de trabajo secundarios, en las que cada ejecución procesa un lote de 50 elementos. Si una de las ejecuciones produce un error y la otra se realiza correctamente, tendrá 50 elementos correctos y 50 con error.

En la siguiente tabla se explican los tipos de estados de procesamiento disponibles para todos los elementos:

Estado Descripción

Pendiente

Indica un elemento que la ejecución del flujo de trabajo secundario no ha empezado a procesar. Si un Map Run se detiene o produce un error, o un usuario cancela la ejecución antes de que comience el procesamiento de un elemento, el elemento permanece en estado Pendiente.

Por ejemplo, si se produce un error al ejecutar un mapa con 10 elementos sin procesar, estos 10 elementos permanecen en estado Pendiente.

En ejecución

Indica un elemento que se está procesando actualmente en la ejecución del flujo de trabajo secundario.

Correcto

Indica que la ejecución del flujo de trabajo secundario procesó correctamente el elemento.

Una ejecución correcta de un flujo de trabajo secundario no puede tener ningún elemento con error. Si un elemento del conjunto de datos falla durante la ejecución, se produce un error en la ejecución de todo el flujo de trabajo secundario.

Con error

Indica que la ejecución del flujo de trabajo secundario no pudo procesar el elemento o se agotó el tiempo de espera de la ejecución. Si se produce un error en alguno de los elementos procesados por la ejecución de un flujo de trabajo secundario, se produce un error en toda la ejecución del flujo de trabajo secundario.

Por ejemplo, consideremos la ejecución de un flujo de trabajo secundario que procese 1000 elementos. Si algún elemento de ese conjunto de datos produce un error durante la ejecución, Step Functions considera que se ha producido un error en toda la ejecución del flujo de trabajo secundario.

Cuando redriveal ejecutar un mapa, el recuento de elementos con este estado se restablece a 0.

Anulado

Indica que la ejecución del flujo de trabajo secundario comenzó a procesar el elemento, pero el usuario canceló la ejecución o Step Functions detuvo la ejecución porque se produjo un error al ejecutar el mapa.

Por ejemplo, pensemos en la ejecución de un flujo de trabajo secundario En ejecución que procese 50 elementos. Si el Map Run se detiene debido a un error o a que un usuario canceló la ejecución, la ejecución del flujo de trabajo secundario y el estado de los 50 elementos cambiarán a Anulado.

Si utiliza una ejecución de flujo de trabajo secundario de tipo Rápido, no podrá detener la ejecución.

Cuando redriveuna ejecución de mapa que inicia las ejecuciones de flujos de trabajo secundarios del tipo Express, el recuento de elementos con este estado se restablece a 0. Esto se debe a que los flujos de trabajo secundarios de Express se reinician mediante la StartExecutionAPIacción en lugar de redriven.

Listado de ejecuciones

La sección Ejecuciones muestra todas las ejecuciones del flujo de trabajo secundario de un Map Run específico. Utilice el campo Buscar por nombre exacto de ejecución para buscar una ejecución de flujo de trabajo secundario específico. También puede usar el menú desplegable Cualquier estado para filtrar los historiales de ejecución de flujo de trabajo secundario por su estado. Para ver los detalles de una ejecución específica, seleccione una ejecución de flujo de trabajo secundario de la lista y pulse el botón Ver detalles para abrir su página Detalles de ejecución.

importante

La política de retención para las ejecuciones de flujos de trabajo secundarios es de 90 días. Las ejecuciones de flujos de trabajo secundarios finalizadas que tengan una antigüedad superior a este período de retención no se mostrarán en la tabla Ejecuciones. Esto es cierto incluso si el estado Map Distributed o el flujo de trabajo principal siguen ejecutándose durante más tiempo que el período de retención. Puede ver los detalles de ejecución, incluidos los resultados, de estas ejecuciones de flujos de trabajo secundarios si exporta la salida del estado Map Distributed a un bucket de Amazon S3 medianteResultWriter (Mapa).

sugerencia

Pulse el botón de actualización para ver la lista más actualizada de todas las ejecuciones de flujos de trabajo secundarios.