使用 Step Functions 建立活動狀態機器

在 Step Functions 主控台的左側導覽窗格中，選擇活動。

選擇 Create activity (建立活動)。

輸入活動的名稱，例如 get-greeting，然後選擇建立活動。

建立活動任務時，請記下其 ARN，如以下範例所示。

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

在 Step Functions 主控台的左側導覽窗格中，選擇狀態機器。

在狀態機器頁面上，選擇建立狀態機器。

在選擇範本對話方塊中，選取空白。

選擇選取以在 中開啟工作流程 Studio設計模式。

在本教學課程中，您將在程式碼編輯器中寫入狀態機器的 Amazon States Language(ASL) 定義。若要執行此操作，請選擇程式碼。

移除現有的樣板程式碼並貼上下列程式碼。請記得將 Resource 欄位中的範例 ARN 取代為您稍早在 中建立的活動任務 ARN步驟 1：建立活動。

{
  "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，然後為該 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步驟 1：建立活動。

在 ActivityStateMachine 頁面上，選擇 Start execution (開始執行)。

隨即顯示開始執行對話方塊。

在開始執行對話方塊中，執行下列動作：

1. （選用） 輸入自訂執行名稱以覆寫產生的預設值。

   非 ASCII 名稱和記錄

   Step Functions 接受包含非 ASCII 字元的狀態機器、執行、活動和標籤名稱。由於這類字元不適用於 Amazon CloudWatch，因此我們建議您僅使用 ASCII 字元，以便在 CloudWatch 中追蹤指標。

2. 在輸入方塊中，輸入下列 JSON 輸入來執行您的工作流程。

   {
     "who": "AWS Step Functions"
   }

3. 選擇 Start execution (開始執行)。

4. Step Functions 主控台會引導您前往標題為執行 ID 的頁面。此頁面稱為執行詳細資訊頁面。在此頁面上，您可以在執行進行時或完成後檢閱執行結果。

   若要檢閱執行結果，請在圖形檢視中選擇個別狀態，然後選擇步驟詳細資訊窗格上的個別索引標籤，分別檢視每個狀態的詳細資訊，包括輸入、輸出和定義。如需您可以在執行詳細資訊頁面上檢視之執行資訊的詳細資訊，請參閱 執行詳細資訊概觀。

在命令列上，導覽至您建立 GreeterActivities.java 的目錄。

若要使用 AWS SDK，請將 lib和 third-party 目錄的完整路徑新增至建置檔案的相依性，以及 Java CLASSPATH。如需詳細資訊，請參閱《 適用於 Java 的 AWS SDK 開發人員指南》中的下載和擷取 SDK。

編譯檔案。

$ javac GreeterActivities.java

執行 檔案。

$ java GreeterActivities

在 Step Functions 主控台上，導覽至執行詳細資訊頁面。

執行完成時，請檢查執行的結果。

停用工作者。