EventBridge を使用して、S3 イベント発生時にStep Functionsを実行してみた。

Amazon EventBridge とは?

EventBridge はサーバーレスのイベントバスサービスです。EventBridgeを使用して、アプリケーションをさまざまなソースからのデータに接続できます。EventBridge は、以前は Amazon CloudWatch Events と呼ばれていました。CloudWatch Events で作成したデフォルトのイベントバスとルールも EventBridge コンソールで見ることができます。

EventBridge ルール　:  ルールは、受信したイベントを処理のターゲットに送信します。イベントは複数のターゲットに送信できます。

この記事では、EventBridge を使用して、S3 イベント発生時にStep Functionsを実行してみました。ファイルがS3バケットに追加されると、EventBridgeルールがStep Functionsの実行を開始します。

やってみた

Step Functionsの作成

• Step Functions コンソールで、Create state machineをクリックしておきます。
• Write your workflow in codeを選択して、TypeでStandardを選択しておきます。

• 必要に応じてコードを変更して、ステートマシン名を入力して、[Create new role]を選択して、State Machineを作成しておきます。

S3バケットの作成

• S3コンソールで、Create bucketをクリックします。
• バケット名を入力して、バケットを作成しておきます。

AWS CloudTrailの作成

S3 の API イベントが Amazon EventBridge ルールを満たすために、CloudTrail でTrailを設定する必要があります。

• CloudTrailコンソールで、Create trailを選択しておきます。
• トレイル名を入力して、Storage locationでCreate new S3 bucketを選択しておきます。
• 暗号化を無効にした、Trailを作成しておきます。

EventBridgeルールの作成

• EventBridgeコンソールで、Create Ruleを選択しておきます。
• 次の設定でDefine patternを構成しておきます。
  • Event patternを選択しておきます。
  • Event matching pattern : Pre-defined pattern by service
  • Service provider : AWS
  • サービス名 : S3
  • タイプ : Object-Level API Call via CloudTrail
  • Operation : Specific - PutObject
  • Bucket : 前の手順で作成したバケットの名前を入力します。

• ターゲットでStep Functions state machineを選択して、以前に作成したState Machineの名前を選択して、Create a new roleを選択しておきます。

• Choose log eventsでData eventsを選択しておきます。

• データイベントタイプでS3を選択して、[Log all events]を選択して、EventBridge Ruleを作成しておきます。

S3バケットにファイルを追加する

• 作成したS3バケットにファイルを追加しておきます。
• ファイルがS3バケットに追加されると、ルールがStep Functions の実行を呼び出します。Step FunctionsコンソールでState Machineの実行をみることができます。

まとめ

EventBridge Ruleを使用して、S3 イベント発生時にStep Functionsを実行してみました。この記事では、ファイルのアップロードイベント(PutObject)をしてみました。他のS3イベントでEventBridgeルールを作成することもできます。

CloudTrailを使わない方法もあります : CloudTrailを使わないで、S3イベント通知をEventBridgeと統合することもできます。