Step Functions ステートマシンを使用してエラー条件を処理する

このチュートリアルでは、 Fallback 状態フィールドを使用して AWS Step Functions ステートマシンを作成します。Catch フィールドは AWS Lambda 関数を使用して、エラーメッセージのタイプに基づいて条件付きロジックで応答します。これは、関数エラー処理と呼ばれるテクニックです。

詳細については、「AWS Lambda デベロッパーガイド」の「Node.js のAWS Lambda 関数エラー」を参照してください。

注記

また、タイムアウト時に再試行するステートマシンや、エラーやタイムアウトが発生したときに、Catch を使用して特定の状態に移行するステートマシンを作成できます。これらのエラー処理方法の例については、Retry の使用例と Catch の使用例を参照してください。

ステップ 1: 失敗する Lambda 関数を作成する

Lambda 関数を使用してエラー条件をシミュレートします。

重要

Lambda 関数が AWS リージョン ステートマシンと同じ AWS アカウントにあることを確認します。

1. https://console.aws.amazon.com/lambda/ で AWS Lambda コンソールを開きます。

2. [関数の作成] を選択してください。

3. [ブループリントを使う] を選択し、検索ボックスに step-functions を入力してから [カスタムエラーをスローする] ブループリントを選択します。

4. [関数名] に「FailFunction」と入力します。

5. [ロール] は、デフォルトの選択 ([基本的な Lambda アクセス許可で新しいロールを作成する]) のままにします。

6. 次のコードが [Lambda function cod] (関数コード) ペインに表示されます。

   exports.handler = async (event, context) => {
       function CustomError(message) {
           this.name = 'CustomError';
           this.message = message;
       }
       CustomError.prototype = new Error();
   
       throw new CustomError('This is a custom error!');
   };

   context オブジェクトはエラーメッセージ This is a custom error! を返します。

7. [関数の作成] を選択してください。

8. Lambda 関数が作成されたら、ページの右上隅に表示されている関数の Amazon リソースネーム (ARN) をコピーします。ARN の例を次に示します。

   arn:aws:lambda:region:123456789012:function:FailFunction

9. [デプロイ] を選択します。

ステップ 2: Lambda 関数をテストする

Lambda 関数をテストしてオペレーションを確認します。

1. [FailFunction]ページで、[テスト] タブから [テスト] を選択します。テストイベントを作成する必要はありません。

2. テスト結果 (シミュレートしたエラー) を確認するには、[実行結果] で、[詳細] を展開します。

ステップ 3: Catch フィールドを使用するステートマシンを作成する

Step Functions コンソールにより、Task ワークフロー状態 状態で Catch フィールドを使用するステートマシンを作成します。Task 状態に Lambda 関数へのリファレンスを追加します。ステートマシンは Lambda 関数を呼び出しますが、実行中に失敗します。Step Functions は、再試行間のエクスポネンシャルパックオフを使用して、関数を 2 回再試行します。

1. Step Functions コンソールを開き、[Create a state machine] (ステートマシンの作成)] を選択します。

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

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

4. [コード] を選択してコードエディタを開きます。コードエディタで、ワークフローの Amazon States Language (ASL) 定義を記述して編集します。

5. 次のコードを貼り付けます。ただし、Resource フィールドで以前に作成した Lambda 関数の ARN を置き換えます。

   {
      "Comment": "A Catch example of the Amazon States Language using an AWS Lambda function",
      "StartAt": "CreateAccount",
      "States": {
         "CreateAccount": {
            "Type": "Task",
            "Resource": "arn:aws:lambda:region:123456789012:function:FailFunction",
            "Catch": [ {
               "ErrorEquals": ["CustomError"],
               "Next": "CustomErrorFallback"
            }, {
               "ErrorEquals": ["States.TaskFailed"],
               "Next": "ReservedTypeFallback"
            }, {
               "ErrorEquals": ["States.ALL"],
               "Next": "CatchAllFallback"
            } ],
            "End": true
         },
         "CustomErrorFallback": {
            "Type": "Pass",
            "Result": "This is a fallback from a custom Lambda function exception",
            "End": true
         },
         "ReservedTypeFallback": {
            "Type": "Pass",
            "Result": "This is a fallback from a reserved error code",
            "End": true
         },
         "CatchAllFallback": {
            "Type": "Pass",
            "Result": "This is a fallback from any error code",
            "End": true
         }
      }
   }

   これは、Amazon ステートメント言語を使用したステートマシンの説明です。CreateAccount という名前の単一の Task 状態を定義します。詳細については、「State Machine Structure」を参照してください。

   Retry フィールドの構文の詳細については、Retry と Catch を使用するステートマシンの例 を参照してください。

   注記

   Lambda ランタイムの未処理エラーは、履歴的に としてのみ報告されましたLambda.Unknown。新しいランタイムでは、タイムアウトはエラー出力Sandbox.Timedoutで として報告されます。

   Lambda が呼び出しの最大数を超えると、報告されたエラーは になりますLambda.TooManyRequestsException。

   Lambda.Unknown、Sandbox.Timedout、、および で一致States.TaskFailedさせてStates.ALL、考えられるエラーを処理します。Lambda Handled と Unhandled エラーの詳細については、AWS Lambda デベロッパーガイドの FunctionError を参照してください。

6. (オプション) グラフの視覚化 では、ワークフローをリアルタイムでグラフィカルに視覚化して表示します。

7. ステートマシンの名前を指定します。これを行うには、MyStateMachine のデフォルトステートマシン名の横にある編集アイコンを選択します。次に、[ステートマシンの設定] の [ステートマシン名] ボックスに名前を入力します。

   このチュートリアルでは、Catchfailure と入力します。

8. (オプション) [ステートマシンの設定] で、ステートマシンのタイプや実行ロールなど、他のワークフロー設定を指定します。

   このチュートリアルでは、[ステートマシンの設定] のデフォルト設定をすべてそのまま使用します。

9. [ロールの作成を確認] ダイアログボックスで、[確認] を選択して続行します。

   [ロールの設定を表示] を選択して [ステートマシンの設定] に戻ることもできます。

   注記

   Step Functions が作成した IAM ロールを削除すると、Step Functions を後で再作成することはできません。同様に、ロールを変更すると (例えば、IAM ポリシーのプリンシパルから Step Functions を削除するなど)、後で Step Functions でそれを元の設定に復元することはできません。

ステップ 4: ステートマシンを実行する

ステートマシンを作成した後、それを実行できます。

1. [ステートマシン] ページで [Catchfailure] を選択します。

2. [Catchfailure] ページで、[実行を開始] を選択します。[実行を開始] ダイアログが表示されます。

3. [実行を開始] ダイアログボックスで、以下の操作を行います。

   1. (オプション) 生成されたデフォルトを上書きするカスタム実行名を入力します。

      非 ASCII 名とログ記録

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

   2. (オプション) [入力] ボックスに、JSON 形式の入力値を入力してワークフローを実行します。

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

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

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

   例えば、カスタムエラーメッセージを表示するには、[グラフビュー] で [CreateAccount] ステップを選択し、次に [出力] タブを選択します。

   

   注記

   状態入力とエラーを保持するには、ResultPath を使用します。「ResultPath を使用してエラーと入力の両方を に含める Catch」を参照してください。