Como criar uma máquina de estado de Atividade usando o Step Functions

No console do Step Functions, no painel de navegação à esquerda, escolha Atividades.

Escolha Create activity (Criar atividade).

Insira um Nome para a atividade, como get-greeting por exemplo, e escolha Criar atividade.

Quando sua tarefa de atividade for criada, anote-aARN, conforme mostrado no exemplo a seguir.

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

No console do Step Functions, no painel de navegação à esquerda, escolha Máquinas de estado.

Na página Máquinas de estado, selecione Criar máquina de estado.

Na caixa de diálogo Escolher um modelo, selecione Em branco.

Escolha Selecionar para abrir o Workflow Studio emModo de design.

Neste tutorial, você escreverá a definição Amazon States Language (ASL) da sua máquina de estado no editor de código. Para isso, clique em Código.

Remova o código clichê existente e cole o código a seguir. Lembre-se de substituir o exemplo ARN nesse código pelo ARN da tarefa de atividade que você criou anteriormente no 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 é uma descrição da sua máquina de estado usando o Amazon States Language (ASL). Ela define um estado Task específico denominado getGreeting. Para obter mais informações, consulte Estrutura da máquina de estado.

NoVisualização de grafos, verifique se o gráfico do fluxo de trabalho da ASL definição que você adicionou é semelhante ao gráfico a seguir.

Especifique um nome para a máquina de estado. Para fazer isso, escolha o ícone de edição ao lado do nome padrão da máquina de estado de MyStateMachine. Em seguida, em Configuração da máquina de estado, insira um nome na caixa Nome da máquina de estado.

Para este tutorial, insira o nome ActivityStateMachine.

(Opcional) Em Configuração da máquina de estado, especifique outras configurações do fluxo de trabalho, como o tipo de máquina de estado e a função de execução.

Para este tutorial, mantenha todas as seleções padrão nas Configurações da máquina de estado.

Se você já criou uma IAM função com as permissões corretas para sua máquina de estado e deseja usá-la, em Permissões, selecione Escolher uma função existente e selecione uma função na lista. Ou selecione Inserir uma função ARN e, em seguida, forneça uma ARN para essa IAM função.

Na caixa de diálogo Confirmar criação do perfil, selecione Confirmar para continuar.

Você também pode escolher Exibir configurações do perfil para voltar às Configurações da máquina de estado.

Crie um arquivo chamado GreeterActivities.java.

Adicione a ele o código a seguir.

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);
            }
        }
    }
}

Na lista de parâmetros do GetActivityTaskRequest().withActivityArn() construtor, substitua o ACTIVITY_ARN valor pelo da tarefa ARN de atividade que você criou anteriormente.

Sobre o ActivityStateMachinepágina, escolha Iniciar execução.

A caixa de diálogo Iniciar execução é exibida.

Na caixa de diálogo Iniciar execução, faça o seguinte:

1. (Opcional) Insira um nome de execução personalizado para substituir o padrão gerado.

   ASCIINão-nomes e registro

   Step Functions aceita nomes para máquinas de estado, execuções, atividades e rótulos que não contenham ASCII caracteres. Como esses caracteres não funcionarão com a Amazon CloudWatch, recomendamos usar somente ASCII caracteres para que você possa acompanhar as métricas CloudWatch.

2. Na caixa Entrada, insira a seguinte JSON entrada para executar seu fluxo de trabalho.

   {
     "who": "AWS Step Functions"
   }

3. Selecione Iniciar execução.

4. O console do Step Functions direciona você para uma página em que o título é o ID da execução. Essa página é conhecida como página de Detalhes da execução. Nesta página, você pode revisar os resultados da execução à medida que a execução avança ou após a conclusão.

   Para revisar os resultados da execução, escolha estados individuais na Exibição em gráfico e, em seguida, escolha as guias individuais no painel Detalhes da etapa para visualizar os detalhes de cada estado, incluindo entrada, saída e definição, respectivamente. Para obter detalhes sobre as informações de execução que você pode visualizar na página Detalhes da execução, consulte Visão geral dos detalhes da execução.

Na linha de comando, vá até o diretório em que você criou GreeterActivities.java.

Para usar o AWS SDK, adicione o caminho completo dos third-party diretórios lib e às dependências do seu arquivo de compilação e ao seu Java. CLASSPATH Para obter mais informações, consulte Baixando e extraindo o SDK no AWS SDK for Java Guia do desenvolvedor.

Compile o arquivo.

$ javac GreeterActivities.java

Execute o arquivo.

$ java GreeterActivities

No console do Step Functions, vá até a página Detalhes da execução.

Quando a execução for concluída, examine os resultados da execução.

Interrompa o operador.