Procesa datos de una cola con un estado de mapa en Step Functions

En este ejemplo de flujo de trabajo, un Mapa del estado del flujo de trabajo estado procesa los datos de una cola, envía mensajes a los suscriptores y los almacena en una base de datos.

Step Functions utiliza una integración optimizada para extraer mensajes de una SQS cola de Amazon. Cuando los mensajes están disponibles, un Choice estado pasa una serie de JSON mensajes a un Asignación estado para su procesamiento. Para cada mensaje, la máquina de estados escribe el mensaje en DynamoDB, lo elimina de la cola y lo publica en un tema de Amazon. SNS

Este proyecto de muestra incluye los siguientes recursos:

• Un registro AWS Step Functions máquina de estado

• Una SQS cola de Amazon en la que el estado del mapa lee y elimina los mensajes de forma iterativa.

• Una tabla de DynamoDB en la que el estado Map escribe mensajes de forma iterativa.

• Un SNS tema de Amazon en el que Step Functions publica los mensajes que lee de la SQS cola de Amazon.

• Relacionado AWS Identity and Access Management (IAM) roles

Paso 1: Crear la máquina de estado

1. Abra la consola de Step Functions y seleccione Crear máquina de estado.

2. Busque y elija Procesar datos de forma dinámica con un estado de mapa. Elija Siguiente para continuar.

3. Elija Ejecutar una demostración para crear un ready-to-deploy flujo de trabajo y de solo lectura, o elija Construir a partir de ella para crear una definición de máquina de estados editable sobre la que pueda construir e implementar posteriormente.

4. Elija Utilizar plantilla para continuar con la selección.

Los siguientes pasos dependen de la elección anterior:

1. Realice una demostración: puede revisar la máquina de estados antes de crear un proyecto de solo lectura con los recursos desplegados por AWS CloudFormation a tu Cuenta de AWS.

   Puede ver la definición de la máquina de estados y, cuando esté listo, elija Implementar y ejecutar para implementar el proyecto y crear los recursos.

   La creación de recursos y permisos puede tardar hasta 10 minutos en implementarse. Puede utilizar el enlace Stack ID para supervisar el progreso en AWS CloudFormation.

   Una vez completada la implementación, deberías ver tu nueva máquina de estados en la consola.

2. Aproveche esta información: puede revisar y editar la definición del flujo de trabajo. Es posible que tengas que establecer valores para los marcadores de posición en el proyecto de ejemplo antes de intentar ejecutar tu flujo de trabajo personalizado.

nota

Es posible que se apliquen cargos estándar por los servicios implementados en tu cuenta.

Paso 2: Suscríbete al SNS tema de Amazon

sugerencia

Suscríbase al SNS tema de Amazon y añada artículos a la SQS cola de Amazon antes de ejecutar su máquina de estados.

1. Abre la SNSconsola de Amazon.

2. Selecciona Temas y busca el tema que creó el proyecto de muestra.

3. Selecciona Crear suscripción y, en Protocolo, selecciona Correo electrónico.

4. En Endpoint, introduce tu dirección de correo electrónico para suscribirte al tema.

5. Elija Crear una suscripción.

6. Confirme la suscripción en su correo electrónico para activarla.

Paso 3: Añadir mensajes a la SQS cola de Amazon

1. Abre la SQSconsola de Amazon.

2. Elige la cola que creó el proyecto de muestra.

3. Elija Enviar y recibir mensajes, introduzca un mensaje y elija Enviar mensaje. Repita este paso para añadir varios mensajes a la cola.

Paso 4: Ejecutar la máquina de estado

sugerencia

Al final, las colas en Amazon SNS son consistentes. Es posible que tengas que esperar unos minutos después de enviar los mensajes a la cola antes de ejecutar tu máquina de estados.

1. En la página Máquina de estado, elija su proyecto de muestra.

2. En la página del proyecto de muestra, seleccione Iniciar ejecución.

3. En el cuadro de diálogo Iniciar ejecución, haga lo siguiente:

   1. (Opcional) Introduzca un nombre de ejecución personalizado para anular el valor predeterminado generado.

      ASCIINombres no identificables y registro

      Step Functions acepta nombres para máquinas de estados, ejecuciones, actividades y etiquetas que no contengan ASCII caracteres. Como estos personajes no funcionan con Amazon CloudWatch, te recomendamos que utilices solo ASCII caracteres para poder hacer un seguimiento de las métricas CloudWatch.

   2. (Opcional) En el cuadro de entrada, introduce los valores de entrada comoJSON. Puede omitir este paso si está realizando una demostración.

   3. Seleccione Iniciar ejecución.

   La consola Step Functions lo dirigirá a una página de detalles de ejecución en la que puede elegir estados en la vista de gráficos para explorar la información relacionada en el Detalles del paso panel.

¡Enhorabuena!

Ahora debería disponer de una demostración en ejecución o de una definición de máquina de estados que pueda personalizar.