Step Functions ステートマシンでのエラー条件の処理

AWS Lambda コンソールの https://console.aws.amazon.com/lambda/ を開いてください。

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

[ブループリントを使う] を選択し、Step Functions を検索して、[カスタムエラーをスローする] を選択します。

[関数名] に「ThrowErrorFunction」と入力します。

[Role] で、[Create a new role with basic Lambda permissions] を選択します。

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

次のコードが [コード] ペインに表示されます。

export const handler = async () => {
    function CustomError(message) {
        this.name = 'CustomError';
        this.message = message;
    }
    CustomError.prototype = new Error();

    throw new CustomError('This is a custom error!');
};

[テスト] タブを選択します。

[新しいイベントを作成] を選択し、デフォルトの [Event JSON] をそのままにします。

[テスト] を選択して、テストイベントで関数を呼び出します。

[関数の実行] を展開して、スローされたエラーの詳細を確認します。

Step Functions コンソールを開き、メニューから [ステートマシン] を選択したら、[ステートマシンの作成] を選択します。

[空白から作成] を選択し、[ステートマシン名] に「CatchErrorStateMachine 」と入力します。

デフォルトのタイプ (Standard) を受け入れ、[続行] を選択して、Workflow Studio でステートマシンを編集します。

[コード] を選択して ASL エディタに切り替え、コードを次のステートマシン定義に置き換えます。

{
  "Comment": "Example state machine that can catch a custom error thrown by a function integration.",
  "StartAt": "CreateAccount",
  "States": {
    "CreateAccount": {
      "Type": "Task",
      "Resource": "arn:aws:states:::lambda:invoke",
      "Output": "{% $states.result.Payload %}",
      "Arguments": {
        "FunctionName": "arn:aws:lambda:region:account-id:function:ThrowErrorFunction:$LATEST",
        "Payload": "{% $states.input %}"
      },
      "Catch": [
        {
          "ErrorEquals": [
            "CustomError"
          ],
          "Next": "CustomErrorFallback"
        },
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "Next": "CatchAllFallback"
        }
      ],
      "End": true,
      "Retry": [
        {
          "ErrorEquals": [
            "CustomError",
            "Lambda.ServiceException",
            "Lambda.AWSLambdaException",
            "Lambda.SdkClientException",
            "Lambda.TooManyRequestsException"
          ],
          "IntervalSeconds": 1,
          "MaxAttempts": 3,
          "BackoffRate": 2,
          "JitterStrategy": "FULL"
        }
      ]
    },
    "CustomErrorFallback": {
      "Type": "Pass",
      "End": true,
      "Output": {
        "Result": "Fallback from a custom error function."
      }
    },
    "CatchAllFallback": {
      "Type": "Pass",
      "End": true,
      "Output": {
        "Result": "Fallback from all other error codes."
      }
    }
  },
  "QueryLanguage": "JSONata"
}

[デザイン] モードに戻り、CreateAccount という名前の [Lambda : Invoke] タスクステートを選択します。

[設定] タブで、[API の引数] を探します。 [関数名] で、先ほど作成した Lambda 関数を選択します。

[作成] を選択し、ロールを確認してから、[確認] を選択すると、ステートマシンが作成されます。

エディタで [実行] を選択します。

あるいは、[ステートマシン] リストから [実行を開始] を選択します。

[実行を開始] ダイアログボックスで、生成された ID を受け入れ、[入力] に次の JSON を入力します。

{ "Cause" : "Custom Function Error" }

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