EventBridge:SMQ

手順

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

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

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

   • タスクの作成

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

        パラメーター	説明	例
        キュー名	作成した SMQ キュー。	test-queue
        Base64 デコード	Base64 デコードを有効にするかどうかを指定します。 Base64 デコードを有効にすると、SMQ 内のデータは、デスティネーションサービスに配信される前に Base64 形式でデコードされます。	test
        一括プッシュの件数	関数呼び出しごとに送信できるメッセージの最大数。 要求は、バックログ内のメッセージ数が指定された値に達した場合にのみ送信されます。 有効な値: 1 ～ 10000。	100
        バッチプッシュ間隔 (単位：秒)	関数を呼び出す時間間隔。 システムは、指定された間隔に達すると、集約されたメッセージを Function Compute に送信します。 有効な値: 0 ～ 15。 単位: 秒。 値 0 は、集約後すぐにメッセージが送信されることを指定します。	3

     2. [フィルタリング]、[変換]、[シンク] の各ステップで、イベントフィルタリング方法、イベント変換ルール、イベントターゲットを設定します。 イベント変換設定については、「Function Compute を使用してメッセージクレンジングを実行する」をご参照ください。

   • タスクのプロパティ

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

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

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

サンプルイベント

{
    "specversion":"1.0",
    "id":"bffb9722-9c48-407b-9895-b038f78f****",
    "source":"acs:mns",
    "type":"mns:Queue:SendMessage",
    "subject":"acs:mns:cn-hangzhou:123456789098****:queues/zeus",
    "datacontenttype":"application/json; charset=utf-8",
    "time":"2021-04-08T06:28:17.093Z",
    "aliyunpublishtime":"2021-04-08T06:30:31.367Z",
    "aliyuneventbusname":"mybus",
    "data":{
        "requestId":"606EA3074344430D4C81****",
        "messageId":"C6DB60D1574661357FA227277445****",
        "messageBody":"TEST"
    }
}

CloudEvents 仕様で定義されているパラメーターについては、「概要」をご参照ください。

次の表に、data に含まれるパラメーターを示します。