アプリのワークフローを視覚的に構成。 AWS Step Functions をグラレコで解説

Amazon States Language (ASL) は、JSON ベースの 構造化言語で、JSON オブジェクトに各種 API アクションやパラメータを定義します。

ASL は、リアルタイムで更新されるビジュアル画面で視覚的にワークフローを確認しながら設計できます。

2021 年 6 月より、ローコードビジュアルツール Step Functions Workflow Studio の提供を開始 しました。

Step Functions Workflow Studio を使うと、ドラッグ & ドロップでステートマシンを設計でき、JSON を使った設計よりもさらに直感的な操作が可能になります。

AWS Lambda は、サーバーのプロビジョニング無しで、クラウド上で任意のコードを実行できるサーバーレスコンピューティングサービスです。

ステートマシンに Lambda 関数実行のステートを加えることで、AWS サービスが提供する API アクションに依存しない自由な処理をワークフローに組み込むことができます。

Step Functions でサポートしている AWS Lambda API と構文について詳しくは、「Step Functions で Lambda を呼び出す」をご覧ください。

なお、Task ステートに、Retry フィールドや Catch フィールドを加えることで、エラー発生時に、自動リトライを試行したり、特定のステートに遷移するなどのエラー処理を組み込むことができます。詳しくは、「Step Functions のエラー処理」をご覧ください。

Amazon DynamoDB は、あらゆる規模のワークロードにも対応できるハイパフォーマンスなキーバリュー型の NoSQL データベースサービスです。

Step Functions は、Amazon DynamoDB と統合されており、データベース上のアイテムの読み込み (GET)・書き込み (PUT)・削除 (DELETE)・更新 (UPDATE) をステートマシンから直接行うことができます。

Step Functions でサポートしている Amazon DynamoDB API と構文について詳しくは、「Step Functions を使用した DynamoDB API の呼び出し」をご覧ください。

なお、ステートマシンに、Choice ステートや Map ステートなどを指定することで、条件分岐やループなどステート遷移のフローを制御することができます。ステートの種類と構文について詳しくは、「状態」をご覧ください。

Amazon SNS は、pub/sub メッセージング、SMS、電子メール、モバイルプッシュ通知などのメッセージをサーバーレスで送信できるメッセージングサービスです。

Step Functions は、Amazon SNS をサポートしており、ステートマシンから直接SNSトピックにイベントを送信できます。Amazon SNS へのメッセージ発行用のステートを組み込むことで、たとえば特定のステートでエラーが発生した場合に、エラー通知をメール送信するなどの処理をワークフローに組み込めます。

Step Functions でサポートしている Amazon SNS API と構文について詳しくは、「Step Functions で Amazon SNS を呼び出す」をご覧ください。

Amazon EMR は、ビッグデータフレームワーク (Apache Hadoop や Apache Spark など) の実行を簡素化して、ビッグデータを処理および分析するマネージドクラスタープラットフォームです。

ステートマシンから、EMR クラスタの作成、終了、削除や、EMR ジョブの実行などが可能です。Step Functions に Amazon EMR ジョブを組み込むことで、EMR ジョブが成功した場合に限り次のステートに遷移したり、失敗した場合にリトライするなど同期的な処理フローを実装できます。

Step Functions でサポートしている Amazon EMR API と構文について詳しくは、「Step Functions を使用して Amazon EMR を呼び出す」をご覧ください。

Amazon ECS は、Docker コンテナを AWS クラウド上で簡単に実行、停止、管理できるスケーラブルで高速なコンテナ管理サービスです。

ステートマシンから直接、コンテナクラスタの作成やタスクの起動などが可能です。EMR ジョブと同様、ECS タスクの実行に成功した際のステート遷移や、失敗した際のリトライなど、同期的な処理フローを設計できます。また、ECS タスクと同様、AWS Fargate タスクも実行できます。

Step Functions でサポートしている Amazon ECS / AWS Fargate API と構文について詳しくは、「Step Functions で Amazon ECS または Fargate タスクを管理する」をご覧ください。

AWS Glue は、データ分析のために、データソースからデータを抽出 (Extract) し、分析しやすい形式に変換 (Transform) し、任意のデータウェアハウスに格納 (Load) できる、サーバーレス ETL サービスです。

ステートマシンから直接 AWS Glue ジョブを実行し、例えば S3 からデータをクロールして、Redshift などに変換し格納するといった Task ステートを設定できます。

Step Functions でサポートしている AWS Glue API と構文について詳しくは、「Step Functions を使った AWS Glue ジョブの管理」をご覧ください。

AWS Batch は、任意のバッチ処理を含むコンテナイメージを、AWS Fargate または Amazon EC2 上で実行するフルマネージド型のバッチサービスです。

ステートマシンから直接 AWS Batch ジョブを送信し、任意のバッチ処理を実行できます。サーバーレスで、任意の処理を実行するという点では、AWS Lambda と類似してますが、AWS Batch はキューイングの機構を備えており、優先順位の高い処理から確実に実行するため、Lambda 関数で処理するよりも大量で複雑なデータの処理に向いています。

Step Functions でサポートしている AWS Batch API と構文について詳しくは、「Step Functions で AWS Batch を管理する」をご覧ください。

Task ステートから StartExecution API アクションを呼び出し、必要なパラメータを渡すだけで、実行中のステートマシンから別のステートマシンを開始することができます。

これにより複雑なステートマシンをよりシンプルな個別のステートマシンに分割したり、再利用可能なステートマシンをライブラリとしてワークフローに組み込むなどが可能です。

別のステートマシンを実行する構文について詳しくは、「タスク状態からワークフロー実行を開始する」をご覧ください。

Amazon SQS は、複数のサービスを連携するメッセージとキューを管理するフルマネージド型のメッセージキューイングサービスです。

Step Functions では、ステートマシンから直接 Amazon SQS キューへメッセージを書き込めます。最大限のスループットでメッセージを送信する標準キュー、およびメッセージの配信順序を保証する SQS FIFO キューのいずれも Step Functions から操作できます。

Step Functions でサポートしている Amazon SQS API と構文について詳しくは、「Step Functions で Amazon SQS を呼び出す」をご覧ください。

Amazon SageMaker は機械学習モデルを簡単かつ迅速に、構築・トレーニング・デプロイできる、フルマネージド型のサービスです。

Step Functions では、Amazon SageMaker を使った機械学習モデルの前処理、トレーニング、評価、デプロイにいたる機械学習パイプラインをワークフローに組み込めます。

Step Functions でサポートしている Amazon SageMaker API と構文について詳しくは、「Step Functions で SageMaker を管理する」をご覧ください。

なお、Amazon SageMaker を用いた機械学習パイプラインを、Python や Jupyter Notebook から簡単にステートマシンに組み込むことができるオープンソースライブラリ「AWS Step Functions Data Science SDK」も全リージョンで利用できます。