Step Functions の使用を開始する方法について

Step Functions サービスを使用すると、複雑なアプリケーションワークフローをオーケストレーションできます。開始するには、Workflow Studio を使用して、組み込みの Hello World ワークフローを作成して実行します。自動生成された Amazon States Language (ASL) 定義をコードで確認します。最後に、サービス統合をdrag-and-dropして感情分析を行います。

このチュートリアルを完了すると、Workflow Studio を使用して、設計モードとコードモードの両方を使用してワークフローを作成、設定、実行、更新する方法がわかります。

推定所要時間: 20～30 分

構築する内容

最初のステートマシンはフロー状態から始まります。フロー状態は、ワークフローを指示および制御するために使用されます。ワークフローの実行方法を学習したら、Amazon Comprehend サービスとタスク状態を統合するアクションを追加します。

次の図は、構築するステートマシン全体の図を示しています。Hello World ステートマシンを初めて作成する場合、追加のリソースを実行する必要はありません。Step Functions コンソールは、ワンクリックですべての状態と IAM ロールを作成します。後でサービス統合を追加するときは、カスタムアクセス許可ポリシーを使用してロールを作成する必要があります。

ステップ 1 - ステートマシンを作成する

Step Functions では、ワークフローはステートマシンと呼ばれます。両方の用語を同じ意味で使用します。ワークフローには、アクションを実行するか、ステートマシンのフローを制御する状態が含まれます。

Workflow Studio の概要

Step Functions 用 Workflow Studio を使用すると、状態をキャンバスに視覚的にdrag-and-dropしてワークフローを構築できます。

状態の追加と編集、ステップの設定、結果の変換、エラー処理の設定を行うことができます。次のスクリーンショットは、ステートマシンの構築に使用するインターフェイスの 4 つの重要な領域を示しています。

モード - Workflow Studio には 3 つのオペレーションモードがあり、デフォルトでビジュアルデザインモードになります。

状態ブラウザには、次の 3 つのタブがあります。

キャンバスグラフとワークフローグラフでは、状態をワークフローグラフにdrag-and-dropし、状態の順序を変更し、状態を選択して設定してテストします。

Inspector パネルは、キャンバスで選択された状態のプロパティを表示および編集する場所です。定義トグルをオンにすると、現在選択されている状態のコードを表示できます。

ステートマシンの概要

Hello World ワークフローは、作業を実行せずに入力を出力に渡す Pass 状態から始まります。パス状態を使用して、データを次の状態に渡す前に静的な JSON 出力を生成したり、JSON 入力を変換したりできます。パス状態は、ステートマシンの構築とデバッグに役立ちます。

次の状態である選択状態は、 のデータIsHelloWorldExampleを使用してワークフローの次のブランチを選択します。最初のルールが一致すると、ワークフローは待機状態で一時停止し、パラレル状態で 2 つのタスクを実行してからチェックポイントに進み、ワークフローを正常に終了します。一致するものがない場合、ワークフローはステートマシンを停止する前にデフォルトで失敗状態になります。

待機状態は、より多くの作業を実行する前に遅延させる場合に便利です。ワークフローは注文入力後 30 秒待機するため、顧客は間違った配送先住所に気づき、修正する時間があります。

並列状態は、データに対して複数のプロセスを実行できます。ワークフローでは、注文チケットの印刷、在庫の更新、日次売上レポートの増加が同時に行われる場合があります。

ワークフローコードを表示する (ASL)

最初のステートマシンは実際には詳細であるため、コードを確認してさらに詳しく調べてください。

ステートマシンは、ステートマシンを宣言的に記述する JSON ベースの言語を記述するオープンソース仕様である Amazon States Language (ASL) を使用して定義されます。

ステートマシン定義全体を表示するには

コードビューで状態の定義がどのように強調表示されているかに気付きましたか？

Inspector でコードを表示するには

他の状態を選択してみてください。選択した各状態の ASL コードがどのようにスクロールされて表示および強調表示されるかを確認してください。

（実際に) ステートマシンを作成する

これまでは、ステートマシンのドラフトを作成してきました。リソースはまだ作成されていません。

ステートマシンの名前を変更して作成するには

ステートマシンと新しい IAM ロールが作成されたという通知が表示されます。

ステートマシンを起動するオプションが自動的に表示されます。これは次のステップで行います。

ステップ 2 - ステートマシンを起動する

ステートマシンを作成したら、ワークフローの実行を開始できます。

ワークフローは、オプションで、 状態で使用でき、統合サービスに送信され、次の状態に渡される入力を受け取ります。

Hello World ステートマシンは自己完結型で、入力は必要ありません。

ステートマシンを起動するには

実行の詳細を確認する

開始直後に、最初の 2 つの状態が成功したはずです。

しばらくすると、残りの状態遷移が実行されてワークフローが完了します。

選択状態 (Hello World の例か?) が X 秒待機状態に分岐することを決めたことに興味がありますか？

State 入力が空白であることがわかりますが、State 出力には の値を に設定する JSON IsHelloWorldExample が含まれていますtrue。

グラフビューからテーブルビューに切り替えて、状態を名前、タイプ、ステータス別に一覧表示します。

この実行の詳細ページには、イベントビューと状態ビューの 2 つのビューがあります。

イベントビューは、状態ごとのフローの詳細な詳細ビューです。

イベントビューテーブルで最初の PassStateEntered イベントと PassStateExited イベントを展開して、状態が入力を受け取らず、CheckpointCount値 0 という変数を割り当て、前に見た出力を生成する方法を確認します。

最後に、テーブルビューに似た状態ビューがあります。状態ビューテーブルでは、状態を選択的に展開して、各状態の入出力のみを表示できます。

ステップ 3 - 外部入力を処理する

の値をワークフロー内のIsHelloWorldExample定数値に設定することは現実的ではありません。ステートマシンがさまざまな入力データに応答することを期待する必要があります。

このステップでは、外部 JSON データをワークフローへの入力として使用する方法を示します。

ハードコードされた入力を削除する

まず、最初のパス状態の出力でハードコードされた値を置き換えます。

更新された状態出力は、JSONata 式を使用して予約された $states 変数から入力データをプルします。これらの値は出力として次の状態に渡され、次の状態の入力になります。

入力データを使用して更新されたワークフローを実行する

次に、ワークフローを実行し、JSON として外部入力データを提供します。

ステートマシンの実行はかなり長く (20 秒) 待機する必要がありますが、最終的には指定した入力を使用して成功します。

グラフビューで、最初のパス状態の入出力を確認します。指定した入力がどのように出力に変換されたかに注目してください。また、実行の詳細ページの上部にある実行の入力と出力を確認します。どちらの場所にも、実行の開始に使用した入力が表示されます。

ワークフロー実行を確認する

ワークフローを数回実行したので、実行の詳細を確認してワークフローの実行を確認します。

実行の詳細を確認するには

実行タブには、次のスクリーンショットのような実行のリストが表示されます。

最後の注意点の 1 つは、ワークフロー実行名は一意でなければならず、再利用することはできません。このチュートリアルでは短縮名 (hello001) を提案しましたが、本番ワークロードでは常に一意な命名規則を使用することをお勧めします。

ステップ 4 - サービスを統合する

Step Functions ステートマシンは、AWS SDK integrations を使用して 220 以上の AWS サービスを呼び出すことができます。 AWS サービスは、ステートマシンに 10,000 を超える潜在的な API アクションを提供します。

このステップでは、Amazon Comprehend タスクを統合して感情分析を行い、ステートマシンの入力を処理します。

サービス統合では、次の 3 つのサービス統合パターンのいずれかを使用します。

最初の統合では、リクエストレスポンス (デフォルト) 統合パターンを使用します。

統合の仕組み

タスク状態は、ステートマシンによって実行される単一の作業単位を表します。ステートマシンのすべての作業は、タスクにより処理されます。

タスクは通常、他の サービスの API アクションに入力を渡して作業を実行し、その後、独自の作業を実行します。、、、 など、さまざまなフィールドを使用してCredentialsRetryCatchTimeoutSeconds、タスクの実行方法を指定できます。タスクの詳細については、「」を参照してくださいTask ワークフロー状態。

AWS SDK 統合を使用するには、呼び出すサービス名と API を指定します。一部の統合にはパラメータも必要です。

Amazon States Language を使用して、タスク状態のリソースフィールドに AWS API アクションを指定できます。オプションで、サービス統合タイプをサービス名に追加できます。

API アクションを指定するには、次のリソース名テンプレートを使用します。

arn:aws:states:::aws-sdk:serviceName:apiAction.[serviceIntegrationPattern]

リソース名の例

Step Functions が Task状態を使用して別のサービスを呼び出す場合、デフォルトのパターンはリクエストレスポンスです。リクエストレスポンス統合パターンでは、Step Functions はサービスを呼び出し、レスポンスを受け取り、すぐに次の状態に進みます。

ステップ 4.1 - 感情分析状態を追加する

ステップ 4.2 - 感情分析の状態を設定する

これらのオートコンプリートオプションを選択したら、状態引数に次の JSON が必要です。

{
    "LanguageCode": "en",
    "Text": "{% $states.context.Execution.Input.feedback_comment %}"
}

ステップ 4.3 - ID ポリシーを設定する

ワークフローを実行する前に、ステートマシンが外部サービスへの API コールを実行できるようにするロールとポリシーを作成する必要があります。

Step Functions の IAM ロールを作成するには

Amazon Comprehend の HelloWorldWorkflowRole にポリシーを追加するには

IAM ロールを Step Functions ステートマシンにアタッチするには

ステップ 4.4 - ステートマシンを実行する

入力用に次の JSON を使用してステートマシンの実行を開始します。

{
    "hello_world": false,
    "wait": 42,
    "feedback_comment" : "This getting started with Step Functions workshop is a challenge!"
}

User: arn:aws:sts::123456789012:assumed-role/StepFunctions-MyStateMachine-role is not authorized
to perform: comprehend:DetectSentiment because no identity-based policy allows the comprehend:DetectSentiment
action (Service: Comprehend, Status Code: 400, Request ID: a1b2c3d4-5678-90ab-cdef-EXAMPLE11111)
        

学習した内容を練習します。

より複雑なワークフローに進む前に、以下のタスクで学習した内容を練習します。

感情分析結果の詳細については、Amazon Comprehend - Sentiment」を参照してください。

リクエストレスポンスの統合について考える 1 つの方法は、レスポンスは通常、リクエストの確認のみを表します。ただし、感情分析などの一部の統合では、確認応答は実際にタスクの完了を表します。

キーラーニングは、 Task状態がリクエストレスポンス統合の基盤となるジョブを待機しないということです。レスポンスを待つには、ジョブの実行 (.sync) サービス統合パターンを調べる必要があります。

リソースをクリーンアップする

作成したリソースをクリーンアップするには、次の手順に従います。

これで、ステートマシンと関連するロールは正常に削除されます。