Step Functions ワークフローに条件付きロジックを追加する

1. Amazon SNSコンソールを開き、標準トピックタイプを作成します。トピックの作成の詳細については、「Amazon Simple Notification Service デベロッパーガイド」の「Amazon SNSトピックの作成」を参照してください。

2. トピック名に TaskTokenTopic を指定します。

3. トピックをコピーARNしてテキストファイルに保存してください。人間による承認待ち状態のサービス統合を指定するARNときは、 トピックが必要です。トピック の例を次に示しますARN。

   arn:aws:sns:us-east-2:123456789012:TaskTokenTopic

4. トピックの E メールベースのサブスクリプションを作成し、次にサブスクリプションを確定します。トピックへのサブスクリプションの詳細については、「Amazon Simple Notification Service デベロッパーガイド」の「トピックに対するサブスクリプションを作成する」を参照してください。

1. 新しいタブまたはウィンドウで Lambda コンソールを開き、 というタイトルの Node.js Lambda 関数を作成しますcallback-human-approval。コンソールを使用して Lambda 関数を作成する方法については、「」の「コンソールで Lambda 関数を作成する」を参照してください。 AWS Lambda デベロッパーガイド。

2. callback-human-approval ページで、コードソースエリアの既存のコードを次のコードに置き換えます。

   // Lambda function that will automatically approve any task 
   // in a message published to an Amazon SNS topic
   
   console.log('Loading function');
   const AWS = require('aws-sdk');
   const resultMessage = "Successful";
   
   export const handler = async (event) => {
       const stepfunctions = new AWS.StepFunctions();
       
       let message = JSON.parse(event.Records[0].Sns.Message);
       let taskToken = message.TaskToken;
       
       console.log('Message received from SNS:', message); 
       console.log('Task token: ', taskToken);
       
       // Return task token to Step Functions
       
       let params = {
           output: JSON.stringify(resultMessage),
           taskToken: taskToken
       };
       
       console.log('JSON Returned to Step Functions: ', params);
       let myResult = await stepfunctions.sendTaskSuccess(params).promise();
       console.log('State machine - callback completed..');
       
       return myResult;
       
   };

3. 以降のアクションに進むには、このウィンドウを開いたまま次のステップに進みます。

1. callback-human-approval Lambda 関数の [関数の概要] セクションで、[トリガーを追加] を選択します。

2. トリガーのドロップダウンリストから、トリガーSNSとして を選択します。

3. SNS トピック については、このチュートリアル のステップ 1 で作成した Amazon SNSトピックの名前を入力し始め、表示されるドロップダウンリストから選択します。

4. [追加] を選択します。

5. 以降のアクションに進むには、このウィンドウを開いたまま次のステップに進みます。

1. callback-human-approval ページで、設定 タブを選択し、アクセス許可 を選択します。

2. 実行ロール で、ロール名を選択して に移動します。 AWS Identity and Access Management コンソールのロールページ。

3. 必要なアクセス許可を追加するには、[アクセス許可の追加] を選択し、次に [ポリシーをアタッチ] を選択します。

4. [検索] ボックスに、AWSStepFunctions と入力して Enter を押します。

5. AWSStepFunctionsFullAccess を選択し、下にスクロールしてポリシーのアタッチ を選択します。これにより、callback-human-approval Lambda 関数ロールに必要なアクセス許可を含むポリシーが追加されます。

Choice 状態を使用して if-else 条件ロジックを追加するには

1. ステートマシンを作成する で作成したワークフロープロトタイプを含む、Step Functions コンソールウィンドウを開きます。

2. [適用したクレジット > = 5000?] 状態を選択します。[設定] タブで、次のように条件付きロジックを指定します。

   1. [選択ルール] で、[ルール #1] タイルの [編集] アイコンを選択し、最初の選択ルールを定義します。

   2. [条件を追加] を選択します。

   3. [ルール #1 の条件] ダイアログボックスで、[変数] に $ を入力します。

   4. [演算子] には [未満] を選択します。

   5. [値] で [定数] を選択し、[値] ドロップダウンリストの横にあるフィールドに 5000 を入力します。

   6. [条件を保存する] を選択します。

   7. [次の状態:] ドロップダウンリストで、[自動承認の上限] を選択します。

   8. [新しい選択ルールを追加] を選択し、サブステップ 2.b から 2.f を繰り返して、クレジット金額が 5000 以上になったら 2 つ目の選択ルールを定義します。[演算子] で、[以上] を選択します。

   9. [次の状態:] ドロップダウンリストには、[人による承認待ち] を選択します。

   10. [デフォルトのルール] ボックスで、[編集] アイコンを選択してデフォルトの選択ルールを定義し、[デフォルトの状態]ドロップダウンリストから [人による承認待ち] を選択します。デフォルトのルールは、[選択] 状態の条件がどれも「true」または「false」と評価されなかった場合に、遷移する次の状態を指定するために定義します。

3. 次のように、[人による承認待ち] 状態を設定します。

   1. 設定タブのトピック で、Amazon SNSトピックの名前 を入力し始め、ドロップダウンリストに表示される名前TaskTokenTopicを選択します。

   2. [メッセージ] には、ドロップダウンリストから [メッセージを入力] を選択します。メッセージ フィールドで、Amazon SNSトピックに発行するメッセージを指定します。このチュートリアルでは、タスクトークンをメッセージとして公開します。

      タスクトークンを使用すると、外部プロセスが完了してタスクトークンが返されるまで、[Standard] タイプの Step Functions ワークフローを一時停止できます。.waitForTaskToken サービス統合パターンを指定して、タスク状態をコールバックタスクとして指定すると、タスクの開始時にタスクトークンが生成され、コンテキストオブジェクトに配置されます。コンテキストオブジェクトは、実行中に使用できる内部JSON構造であり、ステートマシンとその実行に関する情報が含まれています。コンテキストオブジェクトの詳細については、「コンテキストオブジェクト」を参照してください。

   3. 表示されたボックスで、メッセージとして次のように入力します。

      {
        "TaskToken.$": "$$.Task.Token"
      }

   4. [コールバックを待つ] チェックボックスをオンにします。

   5. 表示されたダイアログボックスで [完了] を選択します。

4. このウィンドウを開いたままにして、次のトピックに進みます。