チュートリアル 3: ワークフローに if-else 条件を実装する

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 コンソールを開き、callback-human-approval というタイトルの Node.js 16.x Lambda 関数を作成します。コンソールを使用した Lambda 関数の作成については、「AWS Lambda デベロッパーガイド」の「コンソールで Lambda の関数の作成」を参照してください。

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

   // Sample Lambda function that will automatically approve any task whenever a message is published to an Amazon SNS topic by Step Functions.
   
   console.log('Loading function');
   const AWS = require('aws-sdk');
   const resultMessage = "Successful";
   
   exports.handler = async (event, context) => {
       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. [Add] (追加) を選択します。

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. チュートリアル 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. 以降のアクションに進むには、このウィンドウを開いたままで次のチュートリアルに進みます。