すべてのプロダクト
Search
ドキュメントセンター

EventBridge:SMQ キュー間でメッセージをルーティングするためのイベントストリームの使用

最終更新日:Jan 11, 2025

このトピックでは、EventBridge が提供するイベントストリーム機能を使用して、Simple Message Queue (旧 MNS) (SMQ) キュー間でメッセージをルーティングする方法について説明します。

前提条件

背景情報

エンドツーエンドのストリーミングデータをリアルタイムで処理するための軽量チャネルの一種として、イベントストリームを使用すると、軽量ストリーミングデータのフィルタリングと変換、およびデータウェアハウス間、データ処理プログラム間、データ分析システムとデータ処理システム間でのデータの同期が可能になります。 イベントストリームを使用すると、ソース SMQ キューから宛先 SMQ キューにメッセージをルーティングできます。イベントバスを定義する必要はありません。 詳細については、「概要」をご参照ください。

手順 1:イベントストリームを作成する

説明

EventBridge では、同じリージョンにデプロイされている SMQ キュー間でのみメッセージをルーティングするイベントストリームを作成できます。

  1. EventBridge コンソール にログオンします。

  2. 上部のナビゲーションバーで、イベントストリームを作成するリージョンを選択します。

  3. 左側のナビゲーションペインで、[イベントストリーム] をクリックします。

  4. [イベントストリーム] ページで、[イベントストリームの作成] をクリックします。

  5. [イベントストリームの作成] ページで、タスク名 パラメーターと 説明 パラメーターを設定し、画面の指示に従って他のパラメーターを設定します。 次に、[保存] をクリックします。 次のセクションでは、パラメーターについて説明します。

    • タスクの作成

      1. [ソース] 手順で、[データプロバイダー] パラメーターを [SMQ] に設定し、画面の指示に従って他のパラメーターを設定して、[次の手順] をクリックします。 次の表にパラメーターを示します。

        パラメーター

        説明

        キュー名

        作成したソース SMQ キュー。

        test-queue

        Base64 デコード

        Base64 デコードを有効にするかどうかを指定します。 Base64 デコードを有効にすると、SMQ 内のデータは、宛先サービスに配信される前に Base64 形式でデコードされます。

        test

        一括プッシュの件数

        関数呼び出しごとに送信できるメッセージの最大数。 要求は、バックログ内のメッセージ数が指定された値に達した場合にのみ送信されます。 有効な値:1 ~ 10000。

        100

        バッチプッシュ間隔 (単位:秒)

        関数が呼び出される時間間隔。 システムは、指定された時間間隔で集約されたメッセージを Function Compute に送信します。 有効な値:0 ~ 15。 単位:秒。 値 0 は、集約後すぐにメッセージが送信されることを指定します。

        3

      2. Filtering (フィルタリング) Transform (変換) 手順で、イベントフィルタリング方法とイベント変換ルールを設定します。 次に、[次の手順] をクリックします。 イベント変換設定については、「Function Compute を使用してメッセージクレンジングを実行する」をご参照ください。

      3. Sink (ターゲット) 手順で、サービスタイプ パラメーターを [SMQ] に設定し、画面の指示に従って他のパラメーターを設定します。 次に、[保存] をクリックします。 次の表にパラメーターを示します。

        パラメーター

        説明

        キュー名

        作成した宛先 SMQ キュー。

        test

        Base64 エンコードを有効にする

        Base64 エンコードを有効にするかどうかを指定します。 この機能を無効にすると、受信するメッセージに文字化けが含まれます。

        はい

        メッセージ本文

        イベントの変換に使用するメソッド。 詳細については、「イベント変換」をご参照ください。

        完全なイベント

    • タスクのプロパティ

      イベントストリームの再試行ポリシーと配信不能キューを指定します。 詳細については、「再試行ポリシーと配信不能キュー」をご参照ください。

  6. [イベントストリーム] ページに戻り、作成したイベントストリームを見つけ、有効にする[アクション] 列の をクリックします。

    イベントストリームが有効になるまで 30 ~ 60 秒かかります。 [イベントストリーム] ページの [ステータス] 列で進捗状況を確認できます。

手順 2:イベントストリームをテストする

  1. SMQ コンソール にログオンします。

  2. 上部のナビゲーションバーで、手順 1:イベントストリームを作成する で作成したイベントストリームが存在するリージョンを選択します。

  3. 左側のナビゲーションペインで、[キューモデル] > キュー を選択します。

  4. [キュー] ページで、手順 1:イベントストリームを作成する で指定したソースキューを見つけ、詳細[アクション] 列の をクリックします。

  5. [キューの詳細] ページの右上隅にある [メッセージの送信] をクリックします。

  6. [クイックエクスペリエンス] ページで、[メッセージの内容] パラメーターと [スケジュール期間] パラメーターを設定し、[メッセージの送信] をクリックします。

    メッセージが送信されると、送信されたメッセージの ID がこのページに表示されます。

  7. ソースキューからメッセージを送信した後、[キュー] ページに戻ります。

  8. [キュー] ページで、手順 1:イベントストリームを作成する で指定した宛先キューを見つけ、詳細[アクション] 列の をクリックします。

  9. [キューの詳細] ページの右上隅にある [メッセージの送信] をクリックします。

  10. [クイックエクスペリエンス] ページで、[メッセージの受信] をクリックします。

  11. 返されたメッセージの ID と内容が、送信されたメッセージの ID と内容と同じであることを確認します。