EventBridge:SMQ へのイベントのルーティング

イベントストリームの作成

1. EventBridge コンソール にログインします。 左側のナビゲーションペインで、[イベントストリーム] をクリックします。

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

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

   • タスクの作成

     1. Source (ソース)、Filtering (フィルタリング) 、Transform (変換) ステップで、イベントソース、フィルタリング方法、変換ルールを指定します。 次に、[次のステップ] をクリックします。 イベント変換の構成については、「Function Compute を使用したメッセージクレンジングの実行」をご参照ください。

     2. Sink (ターゲット) ステップで、サービスタイプ パラメーターを SMQ に設定し、画面の指示に従って他のパラメーターを構成します。 次の表では、パラメーターについて説明します。

        パラメーター	説明	例
        キュー名	作成した SMQ キュー。	test
        [base64 エンコーディングの有効化]	Base64 エンコーディングを有効にするかどうかを指定します。 この機能を無効にすると、受信するメッセージに文字化けが含まれます。	はい
        メッセージ本文	イベントの変換に使用するメソッド。 詳細については、「イベント変換」をご参照ください。	イベント全体

   • タスクのプロパティ

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

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

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

結果の確認

SMQ コンソールでイベントが受信されているかどうかを確認できます。

1. SMQ コンソール にログインします。 左側のナビゲーションペインで、[キューモデル] > キュー を選択します。

2. 上部のナビゲーションバーで、リージョンを選択します。

3. [キュー] ページで、イベントをルーティングしたキューを見つけ、その他 > メッセージの送信[アクション] 列で を選択します。

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

   次のサンプルコードは、受信したイベントの例を示しています。

   {
       "data":{
          "props":{
               "firstTopic":"topci12****",
               "secondTopic":"",
               "clientId":"GID_MQTT_CONSOLE@@@lmqhb1share01vpc165759566****"
          },
          "body":"Hello World"  // Hello World
       },
       "id":"AC11C08E76C67E7740853B0F604D****",
       "source":"acs:mqtt",
       "specversion":"1.0",
       "type":"mqtt:Topic:SendMessage",
       "datacontenttype":"application/json; charset\u003dutf-8",
       "time":"2022-07-12T03:14:23.447Z",
       "subject":"acs:mq:cn-qingdao:182572506381****:topic/mqtt-cn-2r42rdr****/topci12****",
       "aliyunaccountid":"182572506381****"
   }