使用 Step Functions 创建活动状态机

在 Step Functions 控制台左侧的导航窗格中，选择活动。

选择创建活动。

输入活动的名称，例如 get-greeting，然后选择创建活动。

创建活动任务后，请记下其内容ARN，如以下示例所示。

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

在 Step Functions 控制台左侧的导航窗格中，选择状态机。

在状态机页面上，选择创建状态机。

在 选择模板对话框中，选择空白。

选择 “选择” 以在中打开 “工作流工作室” 设计模式。

在本教程中，你将在代码编辑器中编写状态机的 Amazon States Language (ASL) 定义。要执行此操作，请选择代码。

删除现有的样板代码并粘贴以下代码。请记住将此代码ARN中的示例替换为您之前在该Resource字段中创建ARN的活动任务的示例。

{
  "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
    }
  }
}

这是使用 Amazon States Language (ASL) 对状态机的描述。它定义了名为 getGreeting 的单个 Task 状态。有关更多信息，请参阅状态机结构。

在上图形可视化，确保您添加的ASL定义的工作流程图表与下图相似。

为状态机指定一个名称。为此，请选择默认状态机名称旁边的编辑图标MyStateMachine。然后，找到状态机配置，在状态机名称框中指定一个名称。

对于本教程，请输入名称 ActivityStateMachine。

（可选）在状态机配置中，指定其他工作流设置，例如状态机类型及其执行角色。

在本教程中，请保留状态机设置中的所有默认选项。

如果您之前为状态机创建了一个具有正确权限的IAM角色并想使用该角色，请在权限中选择 “选择现有角色”，然后从列表中选择一个角色。或者选择 “输入角色”，ARN然后ARN为该IAM角色提供。

在确认角色创建对话框中，选择确认继续。

您也可以选择查看角色设置，返回至状态机配置。

创建一个名为 GreeterActivities.java的文件。

将以下代码添加到其中。

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

在GetActivityTaskRequest().withActivityArn()构造函数的参数列表中，将该ACTIVITY_ARN值替换为您之前创建ARN的活动任务的值。

在存储库的 ActivityStateMachine页面上，选择开始执行。

随即显示启动执行对话框。

在启动执行对话框中，执行以下操作：

1. （可选）输入自定义执行名称以覆盖生成的默认执行名称。

   非ASCII姓名和日志

   Step Functions 接受状态机、执行、活动和包含非ASCII字符的标签的名称。由于此类字符不适用于亚马逊 CloudWatch，因此我们建议您仅使用ASCII字符，以便您可以跟踪中的指标 CloudWatch。

2. 在 “输入” 框中，输入以下JSON输入以运行您的工作流程。

   {
     "who": "AWS Step Functions"
   }

3. 选择启动执行。

4. Step Functions 控制台会将您引导到一个以您的执行 ID 为标题的页面。该页面被称为执行详细信息页面。在此页面上，您可以随着执行的进展或者在执行完成后查看执行结果。

   要查看执行结果，请在图表视图上选择各个状态，然后在步骤详细信息窗格中选择各个选项卡，分别查看每个状态的详细信息，包括输入、输出和定义。有关可在执行详细信息页面上查看的执行信息的详细信息，请参阅执行详情概述。

在命令行上，导航到您在其中创建 GreeterActivities.java 的目录。

要再次使用 AWS SDK，将lib和third-party目录的完整路径添加到生成文件的依赖项和 Java 中CLASSPATH。有关更多信息，请参阅SDK中的 “下载和解压缩” AWS SDK for Java 开发者指南。

编译文件。

$ javac GreeterActivities.java

运行文件。

$ java GreeterActivities

在 Step Functions 控制台中，导航到执行详细信息页面。

执行完成后，检查执行结果。

停止工作线程。