AWS Step Functionsチュートリアル実践：リトライを使ったエラーハンドリングの作成と実行 #reinvent

AWS re:Invent 2016

#AWS Step Functions

#AWS

quiver

2016.12.26

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

AWS re:Invent 2016で発表された『AWS Step Functions』、Getting Startedの他にもドキュメントではチュートリアルが幾つか用意されています。当エントリではそのうちの1つ、Retryフィールドを使ってステートマシンのエラー状態を処理したものについて実践してみた結果をご紹介してみたいと思います。

AWS Step Functionsに関するエントリ一覧は下記関連シリーズをご参照ください。

Step Functions ｜特集カテゴリー｜ Developers.IO

{
  "Comment": "A Retry example of the Amazon States Language using an AWS Lambda Function",
  "StartAt": "HelloWorld",
  "States": {
    "HelloWorld": {
      "Type": "Task",
      "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:FUNCTION_NAME",
      "Retry": [
        {
          "ErrorEquals": [
            "HandledError"
          ],
          "IntervalSeconds": 1,
          "MaxAttempts": 2,
          "BackoffRate": 2
        },
        {
          "ErrorEquals": [
            "UnhandledError"
          ],
          "IntervalSeconds": 1,
          "MaxAttempts": 3,
          "BackoffRate": 2
        },
        {
          "ErrorEquals": [
            "States.TaskFailed"
          ],
          "IntervalSeconds": 30,
          "MaxAttempts": 2,
          "BackoffRate": 2
        },
        {
          "ErrorEquals": [
            "States.ALL"
          ],
          "IntervalSeconds": 5,
          "MaxAttempts": 5,
          "BackoffRate": 2
        }
      ],
      "End": true
    }
  }
}

aws-step-functions-retry-state-machine

Step 4:ステートマシンの実行

ステートマシン実行。実行の際に用いるパラメータとして、以下文字列を設定します。この内容がLambda関数に渡され、処理が実行される形となります。

{
  "Comment": "Insert your JSON here"
}

ステートマシン実行。程なくして結果が表示されました。

retry-state-machine-result

HelloWorld が赤くなっているため、失敗しているとわかります。

Output にはトレースバックが表示されいます。

aws-step-functions-retry-execution-log

Output の error: UnhandledError からわかるように、今回は UnhandledError が発生しました。ステートマシーンの

{
    "ErrorEquals": ["UnhandledError"],
    "IntervalSeconds": 1,
    "MaxAttempts": 3,
    "BackoffRate": 2.0
},

の条件にマッチするため、エラーが発生後、3回ほどリトライを行い、その後、終了しています。

例外の種類について

例外に関するドキュメントでは

"X": {
  "Type": "Task",
  "Resource": "arn:aws:states:us-east-1:123456789012:task:X",
  "Next": "Y",
  "Retry": [
    {
      "ErrorEquals": [ "ErrorA", "ErrorB" ],
      "IntervalSeconds": 1,
      "BackoffRate": 2,
      "MaxRetries": 2
    },
    {
      "ErrorEquals": [ "ErrorC" ],
      "IntervalSeconds": 5
    }
  ],
  "Catch": [
    {
      "ErrorEquals": [ "States.ALL" ],
      "Next": "Z"
    }
  ]
}

というように、細かい粒度で例外処理ができそうに読み取れます。

Step Functions Forums での 2016/12/19 時点での中の人の回答によると、実際には