AWS Step Functions とは？

Lambdaをつなぐ用途もあるけど、それだけではないよ。AWSサービスなどに処理を依頼し、その順番や分岐をステートマシンとして定義するんだ。状態の中にはサービスを呼ぶTaskだけでなく、条件を判断したり待機したりするものもあるよ。

処理の流れとエラー時の制御を、ワークフロー側で管理できるよ。対象のエラーが起きたらRetryで再試行し、解決しなければCatchで別の状態へ進む、といった定義ができる。ただし再試行回数や対象エラー、移動先は設定が必要で、どんな失敗も自動で直すわけではないんだ。

在庫を確保し、決済して、発送を登録して通知する流れが例になるよ。決済が失敗したら、確保した在庫を戻す補償処理を定義することもできる。ただし在庫戻しの処理自体はアプリ側で実装し、失敗した場合の対応も考える必要がある。自動的に全サービスが巻き戻る仕組みではないよ。

Standardは最長1年の実行を扱い、実行履歴を確認できる。Expressは高頻度のイベント処理などに向き、最長5分で、「1秒以内」という制限ではないよ。Expressの履歴確認にはログ設定が関係するし、ジョブの完了待ちやコールバック待ちの連携方式は使えない。時間だけで選ばないことが大切だね。

Standardの実行モデルでも、定義したRetryでは再実行されるよ。非同期Expressは少なくとも1回、同期Expressは最大1回という実行モデルで、重複の扱いが異なる。外部サービスの処理まで一括して「絶対に1回」と保証すると考えず、注文IDなどを使って同じ要求を重ねても二重処理しない設計を確認しよう。