使用 Step Functions 創建活動狀態機

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

選擇 Create activity (建立活動)。

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

當您建立活動任務時，請記下它ARN，如下列範例所示。

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

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

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

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

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

在本教程中，您將在代碼編輯器中編寫狀態機的Amazon States Language（ASL）定義。若要這麼做，請選擇 [程式碼]。

刪除現有的樣板代碼並粘貼以下代碼。請記得將此程式碼ARN中ARN的範例取代為您先前在Resource欄位中建立的活動任務。

{
  "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字元的狀態機器、執行項目、活動和標籤的名稱。由於此類字元不適用於 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。如需詳細資訊，請參閱SDK中的下載和解壓縮 AWS SDK for Java 開發人員指南。

編譯檔案。

$ javac GreeterActivities.java

執行 檔案。

$ java GreeterActivities

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

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

停用工作者。