このトピックでは、EventBridge が提供するイベントストリーム機能を使用して、Simple Message Queue (旧 MNS) (SMQ) キュー間でメッセージをルーティングする方法について説明します。
前提条件
EventBridge がアクティブ化されており、必要な権限がResource Access Management (RAM) ユーザーに付与されていること。 詳細については、「EventBridge をアクティブ化し、RAM ユーザーに権限を付与する」をご参照ください。
SMQ キューが作成されていること。 詳細については、「SMQ をアクティブ化し、RAM ユーザーに SMQ へのアクセスを承認する」をご参照ください。
背景情報
エンドツーエンドのストリーミングデータをリアルタイムで処理するための軽量チャネルの一種として、イベントストリームを使用すると、軽量ストリーミングデータのフィルタリングと変換、およびデータウェアハウス間、データ処理プログラム間、データ分析システムとデータ処理システム間でのデータの同期が可能になります。 イベントストリームを使用すると、ソース SMQ キューから宛先 SMQ キューにメッセージをルーティングできます。イベントバスを定義する必要はありません。 詳細については、「概要」をご参照ください。
手順 1:イベントストリームを作成する
EventBridge では、同じリージョンにデプロイされている SMQ キュー間でのみメッセージをルーティングするイベントストリームを作成できます。
EventBridge コンソール にログオンします。
上部のナビゲーションバーで、イベントストリームを作成するリージョンを選択します。
左側のナビゲーションペインで、[イベントストリーム] をクリックします。
[イベントストリーム] ページで、[イベントストリームの作成] をクリックします。
[イベントストリームの作成] ページで、タスク名 パラメーターと 説明 パラメーターを設定し、画面の指示に従って他のパラメーターを設定します。 次に、[保存] をクリックします。 次のセクションでは、パラメーターについて説明します。
タスクの作成
[ソース] 手順で、[データプロバイダー] パラメーターを [SMQ] に設定し、画面の指示に従って他のパラメーターを設定して、[次の手順] をクリックします。 次の表にパラメーターを示します。
パラメーター
説明
例
キュー名
作成したソース SMQ キュー。
test-queue
Base64 デコード
Base64 デコードを有効にするかどうかを指定します。 Base64 デコードを有効にすると、SMQ 内のデータは、宛先サービスに配信される前に Base64 形式でデコードされます。
test
一括プッシュの件数
関数呼び出しごとに送信できるメッセージの最大数。 要求は、バックログ内のメッセージ数が指定された値に達した場合にのみ送信されます。 有効な値:1 ~ 10000。
100
バッチプッシュ間隔 (単位:秒)
関数が呼び出される時間間隔。 システムは、指定された時間間隔で集約されたメッセージを Function Compute に送信します。 有効な値:0 ~ 15。 単位:秒。 値 0 は、集約後すぐにメッセージが送信されることを指定します。
3
Filtering (フィルタリング) と Transform (変換) 手順で、イベントフィルタリング方法とイベント変換ルールを設定します。 次に、[次の手順] をクリックします。 イベント変換設定については、「Function Compute を使用してメッセージクレンジングを実行する」をご参照ください。
Sink (ターゲット) 手順で、サービスタイプ パラメーターを [SMQ] に設定し、画面の指示に従って他のパラメーターを設定します。 次に、[保存] をクリックします。 次の表にパラメーターを示します。
パラメーター
説明
例
キュー名
作成した宛先 SMQ キュー。
test
Base64 エンコードを有効にする
Base64 エンコードを有効にするかどうかを指定します。 この機能を無効にすると、受信するメッセージに文字化けが含まれます。
はい
メッセージ本文
イベントの変換に使用するメソッド。 詳細については、「イベント変換」をご参照ください。
完全なイベント
タスクのプロパティ
イベントストリームの再試行ポリシーと配信不能キューを指定します。 詳細については、「再試行ポリシーと配信不能キュー」をご参照ください。
[イベントストリーム] ページに戻り、作成したイベントストリームを見つけ、有効にする[アクション] 列の をクリックします。
イベントストリームが有効になるまで 30 ~ 60 秒かかります。 [イベントストリーム] ページの [ステータス] 列で進捗状況を確認できます。
手順 2:イベントストリームをテストする
SMQ コンソール にログオンします。
上部のナビゲーションバーで、手順 1:イベントストリームを作成する で作成したイベントストリームが存在するリージョンを選択します。
左側のナビゲーションペインで、[キューモデル] > キュー を選択します。
[キュー] ページで、手順 1:イベントストリームを作成する で指定したソースキューを見つけ、詳細[アクション] 列の をクリックします。
[キューの詳細] ページの右上隅にある [メッセージの送信] をクリックします。
[クイックエクスペリエンス] ページで、[メッセージの内容] パラメーターと [スケジュール期間] パラメーターを設定し、[メッセージの送信] をクリックします。
メッセージが送信されると、送信されたメッセージの ID がこのページに表示されます。
ソースキューからメッセージを送信した後、[キュー] ページに戻ります。
[キュー] ページで、手順 1:イベントストリームを作成する で指定した宛先キューを見つけ、詳細[アクション] 列の をクリックします。
[キューの詳細] ページの右上隅にある [メッセージの送信] をクリックします。
[クイックエクスペリエンス] ページで、[メッセージの受信] をクリックします。
返されたメッセージの ID と内容が、送信されたメッセージの ID と内容と同じであることを確認します。