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 crea la tarea de actividad, tome nota de su ARN, como se muestra en el siguiente ejemplo.

arn:aws:states:region: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.

Elija Crear desde cero.

Asigne un nombre a la máquina de estado y, a continuación, elija Continuar para editarla en Workflow Studio.

Para este tutorial, escribirá la definición de Amazon States Language (ASL) de su máquina de estado 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 ARN de ejemplo en el campo Resource con el ARN de la actividad que creó anteriormente en Paso 1: Crear una actividad.

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

Esta es una descripción de la máquina de estado realizada mediante el 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 el Visualización de gráficos, asegúrese de que el gráfico de flujo de trabajo de la definición de ASL que ha agregado tiene un aspecto similar al siguiente gráfico.

Especifique un nombre para la máquina de estado. Para ello, elija el icono de edición situado junto al nombre predeterminado de máquina de estado 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 rol de IAM con los permisos correctos para su máquina de estado y desea utilizarlo, en Permisos, seleccione Elegir un rol existente y, a continuación, seleccione un rol de la lista. O seleccione Escribir un ARN de rol y, a continuación, proporcione un ARN para ese rol de IAM.

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 constructor GetActivityTaskRequest().withActivityArn(), sustituya el valor ACTIVITY_ARN por el ARN de la tarea de actividad que creó anteriormente en Paso 1: Crear una actividad.

En la página ActivityStateMachine, seleccione Iniciar 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.

   Nombres y registros con caracteres no ASCII

   Step Functions acepta nombres para máquinas de estado, ejecuciones, actividades y etiquetas que contengan caracteres no ASCII. Dado que estos caracteres impedirán que Amazon CloudWatch registre datos, le recomendamos que utilice únicamente caracteres ASCII para poder realizar un seguimiento de las métricas en Step Functions.

2. En el cuadro Entrada, introduzca la siguiente entrada de JSON para ejecutar el 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 Información general sobre los detalles de ejecución.

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

Si desea utilizar el SDK de AWS, agregue la ruta completa de los directorios lib y third-party a las dependencias del archivo de compilación y a CLASSPATH de Java. Para obtener más información, consulte Descargue y extraiga el SDK (no se recomienda) en la Guía para desarrolladores de AWS SDK para Java.

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.