EventBridge：Buat sumber peristiwa kustom jenis ApsaraMQ for RocketMQ

Prosedur

1. Masuk ke Konsol EventBridge.
2. Di panel navigasi sebelah kiri, klik Event Buses.
3. Di bilah navigasi atas, pilih wilayah.

4. Pada halaman Event Buses, klik nama bus peristiwa yang ingin Anda kelola.

5. Di panel navigasi sebelah kiri, klik Event Sources.

6. Di halaman yang muncul, klik Add Event Source.Event Source

7. Di panel Add Custom Event Source, konfigurasikan parameter Name dan Description. Kemudian, pilih ApsaraMQ for RocketMQ dari daftar drop-down Event Provider, ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya, lalu klik OK. Berikut adalah deskripsi parameter:

   • Region: Pilih wilayah tempat instance ApsaraMQ for RocketMQ yang Anda buat berada.

   • Version: Pilih versi instance ApsaraMQ for RocketMQ. Nilai valid: RocketMQ 4.x dan RocketMQ 5.x.

   • Instance: Pilih instance ApsaraMQ for RocketMQ yang Anda buat.

   • Topic: Pilih topik yang Anda buat pada instance ApsaraMQ for RocketMQ.

   • (Opsional) Tag: Masukkan tag untuk menyaring pesan.

   • Group ID: Pilih ID grup konsumen yang Anda buat pada instance ApsaraMQ for RocketMQ.

     Catatan

     Grup sesuai dengan jenis pesan bisnis. Jangan tentukan grup konsumen yang digunakan dalam bisnis yang ada. Pastikan Anda menggunakan ID grup yang berbeda untuk sumber peristiwa yang berbeda.

   • Consumer Offset: Pilih offset dari mana pesan dikonsumsi. Nilai default: Offset Terbaru.

Contoh peristiwa

{
    "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"
    }
}

Untuk informasi lebih lanjut tentang parameter yang didefinisikan dalam spesifikasi CloudEvents, lihat Ikhtisar.

Tabel berikut menjelaskan parameter yang terkandung dalam data.