​Amazon S3 イベント発生時にステートマシンの実行をスタートする - AWS Step Functions

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

​Amazon S3 イベント発生時にステートマシンの実行をスタートする

Amazon AWS Step Functions EventBridge ルールに応じてステートマシンを実行できます。

このチュートリアルでは、ステートマシンを Amazon EventBridge ルールのターゲットとして設定する方法を示します。このルールは、ファイルが Amazon Simple Storage Service (Amazon S3) バケットに追加されたときに、ステートマシンの実行を開始します。

実際のアプリケーションでは、バケットに追加したファイルに対してオペレーションを時刻するステートマシンを起動できます。イメージやビデオファイルに対するサムネイルの作成や Amazon Rekognition 分析の実行などです。

このチュートリアルでは、Amazon S3 Helloworld バケットにファイルをアップロードしてステートマシンの実行を開始します。次に、その実行の入力例を確認して、に配信された Amazon S3 イベント通知からの入力に含まれる情報を確認します EventBridge。

前提条件: ステートマシンを作成する

ステートマシンを Amazon EventBridge ターゲットとして設定する前に、ステートマシンを作成する必要があります。

ステップ 1: Amazon S3 バケットを作成する

Helloworldステートマシンができたので、ファイルを保存する Amazon S3 バケットを作成する必要があります。このチュートリアルのステップ 3 では、 EventBridge このバケットにファイルをアップロードしたときにステートマシンの実行がトリガーされるようにルールを設定します。

  1. Amazon S3 コンソールに移動し、[Create bucket] を選択して、ファイルを保存し、Amazon S3 イベントルールをトリガーするバケットを作成します。

  2. [Bucket name] (バケット名) を入力します (例: username-sfn-tutorial)。

    注記

    バケット名は必ず、Amazon S3 のすべての AWS リージョン内の既存バケット名の中で一意になるようにします。この名前を一意にするには、自分のユーザーネームを使用します。すべてのリソースは同じ AWS リージョン内に作成する必要があります。

  3. ページのすべてのデフォルト選択をそのままにして、[Create bucket] を選択します。

ステップ 2: Amazon S3 イベント通知を有効にする EventBridge

Amazon S3 バケットを作成したら、S3 バケットで特定のイベント (ファイルのアップロードなど) EventBridge が発生するたびにイベントを送信するように設定します。

  1. [Amazon S3 console] (Amazon S3 のコンソール) に移動します。

  2. [Buckets (バケット)] リストで、イベントを有効にするバケットの名前を選択します。

  3. [プロパティ] を選択します。

  4. ページを下にスクロールして「イベント通知」セクションを表示し、「Amazon」 EventBridge サブセクションで「編集」を選択します。

  5. [ EventBridge このバケット内のすべてのイベントについて Amazon に通知を送信] で [オン] を選択します。

  6. [変更を保存] を選択します。

    注記

    有効にすると EventBridge、変更が有効になるまでに約 5 分かかります。

ステップ 3: Amazon EventBridge ルールを作成する

ステートマシンを用意し、Amazon S3 バケットを作成し、イベント通知を送信するように設定したら EventBridge、 EventBridge ルールを作成します。

注記

Amazon S3 EventBridge AWS バケットと同じリージョンでルールを設定する必要があります。

ルールを作成するには

  1. Amazon EventBridge コンソールに移動し、[ルールを作成] を選択します。

    ヒント

    または、 EventBridge コンソールのナビゲーションペインで、「バス」の下の「ルール」を選択し、「ルールを作成」を選択します。

  2. ルールの [名前] (例:S3Step Functions) を入力し、オプションでルールの [説明] を入力します。

  3. イベントバス」と「ルールタイプ」については、デフォルト設定のままにします。

  4. [次へ] をクリックします。これにより、「イベントパターンの作成」ページが開きます。

  5. イベントパターン」セクションまでスクロールし、次の操作を行います。

    1. [イベントソース] では、AWS EventBridge デフォルトのイベントまたはパートナーイベントの選択をそのまま使用します

    2. AWSサービスにはSimple Storage Service (S3) を選択します。

    3. [イベントタイプ] には、[Amazon S3 イベント通知] を選択します。

    4. [特定のイベント] を選択し、[オブジェクトが作成されました] を選択します。

    5. 名前で [Specific bucket (s)] を選択し、ステップ 1 (username-sfn-tutorial) で作成したバケット名を入力してファイルを保存します。

    6. [次へ] をクリックします。[ターゲットの選択] ページが開きます。

ターゲットを作成するには

  1. Target 1 では、AWSデフォルトのサービス選択のままにします

  2. ターゲットの選択」 ドロップダウンリストで、「Step Functions ステートマシン」を選択します。

  3. ステートマシンリストで先ほど作成したステートマシン (例:Helloworld) を選択します。

  4. ページ上のデフォルトの選択をすべてそのままにして、[Next] を選択します。「タグの設定」ページが開きます。

  5. [次へ] をもう一度選択します。「レビューと作成」ページが開きます。

  6. ルールの詳細を確認し、[ルールの作成] を選択します。

    ルールが作成され、すべての Amazon ルールが一覧表示された [ EventBridge ルール] ページが表示されます。

ステップ 4 : ルールをテストする

すべて準備ができたので、Amazon S3 バケットへのファイルの追加をテストして、ステートマシンが実行された結果の入力を確認します。

  1. Amazon S3 バケットにファイルを追加します。

    Amazon S3 コンソールに移動し、ファイルを保存するために作成したバケット (username-sfn-tutorial) を選択し、[アップロード] を選択します。

  2. たとえば、ファイルを追加しtest.png、[Upload] を選択します。

    これによりステートマシンの実行が起動され、AWS CloudTrail​ からの情報が入力として渡されます。

  3. ステートマシンの実行をチェックします。

    Step Functions コンソールに移動し、Amazon EventBridge ルールで使用されているステートマシンを選択します (Helloworld)

  4. そのステートマシンの最新の実行を選択し、「Execution Input」セクションを展開します。

    この入力には、バケット名やオブジェクト名などの情報が含まれています。実際のユースケースでは、この入力を使用してステートマシンがそのオブジェクトに対してアクションを実行できます。

実行入力の例

次の例は、ステートマシン実行の一般的な入力を示しています。

{ "version": "0", "id": "6c540ad4-0671-9974-6511-756fbd7771c3", "detail-type": "Object Created", "source": "aws.s3", "account": "123456789012", "time": "2023-06-23T23:45:48Z", "region": "us-east-2", "resources": [ "arn:aws:s3:::username-sfn-tutorial" ], "detail": { "version": "0", "bucket": { "name": "username-sfn-tutorial" }, "object": { "key": "test.png", "size": 800704, "etag": "f31d8546bb67845b4d3048cde533b937", "sequencer": "00621049BA9A8C712B" }, "request-id": "79104EXAMPLEB723", "requester": "123456789012", "source-ip-address": "200.0.100.11", "reason": "PutObject" } }