EventBridge:RocketMQ タイプの ApsaraMQ のカスタムイベントソースを作成する

手順

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

4. [イベントバス] ページで、管理するイベントバスの名前をクリックします。

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

6. 表示されるページで、イベントソースの追加 をクリックします。Event Source

7. カスタムイベントソースの追加 パネルで、名前 パラメーターと 説明 パラメーターを設定します。 次に、Message Queue for Apache RocketMQイベントプロバイダー ドロップダウンリストから OK を選択し、画面の指示に従って他のパラメーターを設定し、 をクリックします。 以下の項目では、パラメーターについて説明します。

   • リージョン: 作成した RocketMQ 用 ApsaraMQ インスタンスが存在するリージョンを選択します。

   • バージョン: RocketMQ 用 ApsaraMQ インスタンスのバージョンを選択します。有効な値：[rocketmq 4.x] および [rocketmq 5.x]。

   • RocketMQ インスタンス: 作成した RocketMQ 用 ApsaraMQ インスタンスを選択します。

   • Topic: RocketMQ 用 ApsaraMQ インスタンスで作成したトピックを選択します。

   • (オプション) Tag: メッセージをフィルタリングするためのタグを入力します。

   • Group ID: ApsaraMQ for RocketMQ インスタンスで作成したコンシューマーグループの ID を選択します。

     説明

     グループはビジネスメッセージの種類に対応します。既存のビジネスで使用されているコンシューマーグループを指定しないでください。異なるイベントソースには異なるグループ ID を使用してください。

   • コンシューマーオフセット: メッセージが消費されるオフセットを選択します。 デフォルト値：[最新のオフセット]。

サンプルイベント

{
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "UNIQ_KEY":"AC14C305069E1B28CDFA3181CDA2****",
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_123456789098****_BXhFHryi"
        },
        "userProperties":{
        },
        "body":"TEST"
    }
}

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

data に含まれるパラメーターについては、次の表で説明します。