Crear una máquina de estado de actividad con Step Functions

En la consola de Step Functions, en el panel de navegación de la izquierda, elija Actividades.

Seleccione Crear actividad.

Escriba un Nombre de la actividad, por ejemplo, get-greeting y, a continuación, elija Crear actividad.

Cuando se cree la tarea de actividad, anote la mismaARN, como se muestra en el siguiente ejemplo.

arn:aws:states:us-east-1:123456789012:activity:get-greeting

En la consola de Step Functions, en el panel de navegación de la izquierda, elija Máquinas de estado.

En la página Máquinas de estado, elija Crear máquina de estado.

En el cuadro de diálogo Elegir una plantilla, seleccione En blanco.

Elija Seleccionar para abrir Workflow StudioModo Diseño.

Para este tutorial, escribirá la definición Amazon States Language (ASL) de su máquina de estados en el editor de código. Para ello, elija Código.

Elimine el código reutilizable existente y pegue el siguiente código. Recuerde reemplazar el ejemplo ARN de este código por el ARN de la tarea de actividad que creó anteriormente en el Resource campo.

{
  "Comment": "An example using a Task state.",
  "StartAt": "getGreeting",
  "Version": "1.0",
  "TimeoutSeconds": 300,
  "States":
  {
    "getGreeting": {
      "Type": "Task",
      "Resource": "arn:aws:states:us-east-1:123456789012:activity:get-greeting",
      "End": true
    }
  }
}

Esta es una descripción de su máquina de estados mediante el comando Amazon States Language (ASL). Define un único estado Task llamado getGreeting. Para obtener más información, consulte Estructura de las máquinas de estado.

En elVisualización de gráficos, asegúrese de que el gráfico de flujo de trabajo de la ASL definición que ha agregado tiene un aspecto similar al siguiente gráfico.

Especifique un nombre para la máquina de estado. Para ello, seleccione el icono de edición situado junto al nombre de la máquina de estados predeterminada de MyStateMachine. A continuación, en Configuración de máquina de estado, especifique un nombre en el cuadro Nombre de la máquina de estado.

En este tutorial, ingrese el nombre ActivityStateMachine.

(Opcional) En Configuración de máquina de estado, especifique otros ajustes del flujo de trabajo, como el tipo de máquina de estado y su función de ejecución.

Para este tutorial, mantenga todas las selecciones predeterminadas en Configuración de máquina de estado.

Si ya ha creado un IAM rol con los permisos correctos para su máquina estatal y desea usarlo, en Permisos, seleccione Elegir un rol existente y, a continuación, seleccione un rol de la lista. O selecciona Introducir un rol ARN y, a continuación, proporciona ARN uno para ese IAM rol.

En el cuadro de diálogo Confirmar creación de rol, elija Confirmar para continuar.

También puede seleccionar Ver configuración de rol para volver a Configuración de máquina de estado.

Cree un archivo denominado GreeterActivities.java.

Agréguele el código siguiente.

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.EnvironmentVariableCredentialsProvider;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.stepfunctions.AWSStepFunctions;
import com.amazonaws.services.stepfunctions.AWSStepFunctionsClientBuilder;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskRequest;
import com.amazonaws.services.stepfunctions.model.GetActivityTaskResult;
import com.amazonaws.services.stepfunctions.model.SendTaskFailureRequest;
import com.amazonaws.services.stepfunctions.model.SendTaskSuccessRequest;
import com.amazonaws.util.json.Jackson;
import com.fasterxml.jackson.databind.JsonNode;
import java.util.concurrent.TimeUnit;


public class GreeterActivities {

    public String getGreeting(String who) throws Exception {
        return "{\"Hello\": \"" + who + "\"}";
    }

    public static void main(final String[] args) throws Exception {
        GreeterActivities greeterActivities = new GreeterActivities();
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setSocketTimeout((int)TimeUnit.SECONDS.toMillis(70));

        AWSStepFunctions client = AWSStepFunctionsClientBuilder.standard()
                .withRegion(Regions.US_EAST_1)
                .withCredentials(new EnvironmentVariableCredentialsProvider())
                .withClientConfiguration(clientConfiguration)
                .build();

        while (true) {
            GetActivityTaskResult getActivityTaskResult =
                    client.getActivityTask(
                            new GetActivityTaskRequest().withActivityArn(ACTIVITY_ARN));

            if (getActivityTaskResult.getTaskToken() != null) {
                try {
                    JsonNode json = Jackson.jsonNodeOf(getActivityTaskResult.getInput());
                    String greetingResult =
                            greeterActivities.getGreeting(json.get("who").textValue());
                    client.sendTaskSuccess(
                            new SendTaskSuccessRequest().withOutput(
                                    greetingResult).withTaskToken(getActivityTaskResult.getTaskToken()));
                } catch (Exception e) {
                    client.sendTaskFailure(new SendTaskFailureRequest().withTaskToken(
                            getActivityTaskResult.getTaskToken()));
                }
            } else {
                Thread.sleep(1000);
            }
        }
    }
}

En la lista de parámetros del GetActivityTaskRequest().withActivityArn() constructor, sustituya el ACTIVITY_ARN valor por el ARN de la tarea de actividad que creó anteriormente.

En la página ActivityStateMachineEn esta página, elija Iniciar la ejecución.

Aparece el cuadro de diálogo Iniciar ejecución.

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. En el cuadro de entrada, introduce la siguiente JSON entrada para ejecutar tu flujo de trabajo.

   {
     "who": "AWS Step Functions"
   }

3. Seleccione Iniciar ejecución.

4. La consola de Step Functions le dirige a una página cuyo título es su ID de ejecución. Esta página se conoce como Detalles de la ejecución. En esta página, puede revisar los resultados de la ejecución a medida que avanza la ejecución o una vez finalizada.

   Para revisar los resultados de la ejecución, elija los estados individuales en la Vista de gráfico y, a continuación, elija las pestañas individuales del panel Detalles del paso para ver los detalles de cada estado, incluidas la entrada, la salida y la definición, respectivamente. Para obtener más información sobre la ejecución que puede ver en la página Detalles de la ejecución, consulte Descripción general de los detalles de ejecución.

En la línea de comandos, vaya al directorio en el que creó GreeterActivities.java.

Para utilizar el AWS SDK, añada la ruta completa de los third-party directorios lib y a las dependencias de su archivo de compilación y a su JavaCLASSPATH. Para obtener más información, consulta Descargar y extraer el contenido en el SDK AWS SDK for Java Guía para desarrolladores.

Compile el archivo.

$ javac GreeterActivities.java

Ejecute el archivo .

$ java GreeterActivities

En la consola de Step Functions, vaya a la página Detalles de ejecución.

Cuando se complete la ejecución, examine los resultados.

Detenga el proceso de trabajo.