Step Functions を使用してアクティビティステートマシンを作成する

Step Functions コンソール内、左のナビゲーションペインで、[Activities] (アクティビティ) を選択します。

[Create activity] (アクティビティの作成) を選択します。

アクティビティの [名前] (get-greeting など) を入力し、[アクティビティの作成] を選択します。

アクティビティタスクが作成されたら、次の例に示すようにARN、その を書き留めます。

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

Step Functions コンソール内、左のナビゲーションペインで、[State machines] (ステートマシン) を選択します。

[ステートマシン] ページで、[ステートマシンの作成] を選択します。

[テンプレートを選択] ダイアログボックスで [空白] を選択します。

選択 を選択して、 で Workflow Studio を開きますデザインモード。

このチュートリアルでは、コードエディタでステートマシンの Amazon ステートメント言語 (ASL) 定義を記述します。これを行うには、[コード] を選択します。

既存のボイラープレートコードを削除して、次のコードを貼り付けます。このコードの例は、 ResourceフィールドARNで前に作成したアクティビティタスク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 ステートメント言語 () を使用したステートマシンの説明ですASL。getGreeting という名前の単一の Task 状態を定義します。詳細については、「State Machine Structure」を参照してください。

でグラフの視覚化、追加した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. （オプション) 生成されたデフォルトを上書きするカスタム実行名を入力します。

   非ASCII名前とログ記録

   Step Functions は、 以外のASCII文字を含むステートマシン、実行、アクティビティ、およびラベルの名前を受け入れます。このような文字は Amazon では機能しないため CloudWatch、 でメトリクスを追跡できるようにASCII、文字のみを使用することをお勧めします CloudWatch。

2. 入力ボックスに次のJSON入力を入力してワークフローを実行します。

   {
     "who": "AWS Step Functions"
   }

3. [実行のスタート] を選択します。

4. Step Functions コンソールから実行 ID のタイトルが付いたページが表示されます。このページは、[実行の詳細] ページと呼ばれます。このページでは、実行の進行中または完了後に実行結果を確認できます。

   実行結果を確認するには、[グラフビュー] で個々の状態を選択し、ステップの詳細 ペインの個々のタブを選択すると、入力、出力、定義などの各状態の詳細がそれぞれ表示されます。[実行の詳細] ページに表示できる実行情報の詳細については、「実行の詳細の概要」を参照してください。

コマンドラインで、GreeterActivities.java を作成したディレクトリに移動します。

を使用するには AWS SDKビルドファイルの依存関係libと Java に および third-party ディレクトリのフルパスを追加しますCLASSPATH。詳細については、「」の「 のダウンロードと抽出SDK」を参照してください。 AWS SDK for Java デベロッパーガイド 。

ファイルをコンパイルします。

$ javac GreeterActivities.java

ファイルを実行します。

$ java GreeterActivities

Step Functions コンソールで、[実行の詳細] ページに移動します。

実行が完了したら、実行結果を確認します。

ワーカーを停止します。