使用 Step Functions 创建活动状态机

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

选择创建活动。

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

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

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

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

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

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

选择选择。这将在设计模式中打开 Workflow Studio。

在本教程中，您将在代码编辑器中编写状态机的 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
    }
  }
}

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

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

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

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

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

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

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

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

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

创建一个名为 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. （可选）要识别您的执行，您可以在名称框中为其指定一个名称。默认情况下，Step Functions 会自动生成一个唯一的执行名称。

   注意

   Step Functions 允许您为状态机、执行、活动、速率控制和包含非 ASCII 字符的标签创建名称。这些非 ASCII 名称不适用于亚马逊。 CloudWatch为确保您可以跟踪 CloudWatch 指标，请选择仅使用 ASCII 字符的名称。

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

   {
     "who": "Amazon Step Functions"
   }

3. 选择启动执行。

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

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

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

要使用 Amazon SDK，请将lib和third-party目录的完整路径添加到构建文件的依赖项和 Java 中CLASSPATH。有关更多信息，请参阅《Amazon SDK for Java 开发人员指南》中的下载和解压缩开发工具包。

编译文件。

$ javac GreeterActivities.java

运行文件。

$ java GreeterActivities

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

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

停止工作线程。