こんにちは。ma2k8です。

今回のre:Inventで発表された新サービスの中で、個人的に一番テンションがあがったAWS Step Functionsについて紹介させていただきます。なお、本記事内のスライド画像は以下セッションものです。

CMP319 – NEW LAUNCH! Building Distributed Applications with AWS Step Functions

AWS Step Functionsとは？

ビジュアルワークフローを使用して分散アプリケーションを構築するツールです。TaskにLambda関数を定義できる点がすごく良いと思いました。

AWS Step functionsの利点

指定できるStep

条件分岐、並列処理もサポートしているようです。また、TaskではRetryとCatchも定義できました。Serverlessを組む際に悩みがちな制御をStep Functionsへ委譲できそうです。

• Amazon States Language

Activity

TaskではLambda関数以外にActivityと呼ばれるものが指定可能でした。Step Functions用の長時間実行用のWorkerを用意して実行するというものです。

セッションではTaskは Poll(Activity) or Push(Lambda) という紹介がされていました。ActivityはAWSへ接続できればどこでも良いので、オンプレにおけるのも大きな利点になりそうです。

Worker上で実行するコードは以下の流れを無限ループで常駐させていました。

1. ActivityのARNを指定してgetActivityTaskでStep Functions上のActivityを捕捉
2. 行いたい処理を実行
3. sendTaskSuccess|sendTaskFailureで処理結果をActivityへ送信

基本的にStep Functions側からActivityを実行する方法は用意されていないようなので、Wokerは常時実行が想定されているようです。LambdaでECSのコンテナを立ち上げるようなコードを書いてActivityの前のTaskとして定義してあげれば都度実行も可能でしょう。

例えば、Lambdaには実行時間が短いという制限があることからSQSのポーリングなどには不向きでしたが、Activityであれば行うことができます。

Activityの作成手順はチュートリアルが公式ドキュメントにあったのでそちらをご参照ください。

• Tutorial: An Activity State Machine

制限

アカウント制限

実行制限

Taskの実行制限

スロットリング制限

前述のサービス制限に加え、Step Functionの特定のAPIコールはトークンバケット方式を使用してサービス帯域幅を維持するために抑制されます。なお、スロットリング制限はアカウント/地域ごととなります。

• Step Functionの制限

料金

• 毎月4,000回の状態遷移まで無料
• その後は1,000回の状態遷移ごとに$0.025

• Pricing

利用可能リージョン

東京が対応しているのはうれしいですね。

試してみた

Lambda関数作成からStep Functions実行までの手順はAWSブログをご参照ください。

• AWS Step Functions – ビジュアルワークフローを使ったアプリケーションのビルドと配布

まとめ

Serverlessでサクッとやれることの幅がかなり広がりそうですね！このサービスは以下の点において最高だと思いました²⁾他にもまだまだあると思いますが。

• 単純なwait時に発生する実行時間の問題をWaitStepで解決
• ポーリング系処理をはさむ際の実行時間の問題をServerありきなActivityで解決
• フロー制御をInput/Outputをつなぐ処理をjsonで定義できるようにして解決
• 並列処理制御をParallelStepで解決
• それぞれのMicroServiceが接続先を意識しないといけない問題をChoiceStepで解決

Serverless Architectureを加速させてくれる存在になってくれそうで楽しみです！

• 公式ドキュメント