EventBridge:Create a custom event source of the ApsaraMQ for RocketMQ type

Sınırlamalar

• Her olay kaynağı için ayrılmış bir tüketici grubu gereklidir. Mevcut üretim iş yüklerini sunan bir tüketici grubunu yeniden kullanmayın. Her olay kaynağı için benzersiz bir grup kimliği atayın.

• Hem RocketMQ 4.x hem de RocketMQ 5.x örnekleri desteklenir. Örneğinizle eşleşen sürümü seçin.

Ön koşullar

Başlamadan önce aşağıdakilere sahip olduğunuzdan emin olun:

• ApsaraMQ for RocketMQ

  • Gerekli izinlerin bir Resource Access Management (RAM) kullanıcısına verildiği, etkinleştirilmiş bir ApsaraMQ for RocketMQ hizmeti. Daha fazla bilgi için bkz. ApsaraMQ for RocketMQ'yu etkinleştirme ve izin verme

  • En az bir konu ve bir tüketici grubuna sahip bir ApsaraMQ for RocketMQ örneği. Daha fazla bilgi için bkz. Kaynak oluşturma

• EventBridge

  • Gerekli izinlerin bir RAM kullanıcısına verildiği, etkinleştirilmiş bir EventBridge hizmeti. Daha fazla bilgi için bkz. EventBridge'i etkinleştirme ve bir RAM kullanıcısına izin verme

  • Özel bir olay veri yolu. Daha fazla bilgi için bkz. Özel olay veri yolu oluşturma

RocketMQ olay kaynağı ekleyin

1. EventBridge konsolu üzerinde oturum açın.

2. Sol gezinme bölmesinde Event Buses öğesine tıklayın.

3. Üst gezinme çubuğunda bir bölge seçin.

4. Event Buses sayfasında hedef olay veri yolunun adına tıklayın.

5. Sol gezinme bölmesinde Event Sources öğesine tıklayın.

6. Add Event Source seçeneğine tıklayın.

7. Add Custom Event Source panelinde aşağıdaki parametreleri yapılandırın ve OK seçeneğine tıklayın.

   Parametre	Zorunlu	Açıklama
   Name	Evet	Olay kaynağı için bir ad girin.
   Description	Evet	Bir açıklama girin.
   Event Provider	Evet	ApsaraMQ for RocketMQ seçeneğini belirleyin.
   Region	Evet	ApsaraMQ for RocketMQ örneğinizin bulunduğu bölgeyi seçin.
   Version	Evet	Örnek sürümünü seçin: RocketMQ 4.x veya RocketMQ 5.x.
   Instance	Evet	ApsaraMQ for RocketMQ örneğini seçin.
   Topic	Evet	Örnekteki konuyu seçin.
   Tag	Hayır	Mesajları filtrelemek için bir etiket girin.
   Group ID	Evet	Tüketici grubu kimliğini seçin. Bir grup, belirli bir türdeki iş mesajına karşılık gelir. Diğer uygulamalar veya olay kaynaklarıyla paylaşılmayan, ayrılmış bir grup kullanın.
   Consumer Offset	Evet	Mesajların tüketilmeye başlanacağı ofseti seçin. Varsayılan: Latest Offset.

Entegrasyonu doğrulayın

Olay kaynağını oluşturduktan sonra RocketMQ konusuna bir test mesajı yayınlayın ve EventBridge konsolundaki olay izlemesini kontrol edin. Yapılandırma doğruysa mesaj, CloudEvents biçiminde bir olay olarak olay veri yolunda görünür.

Örnek olay

Olay kaynağı oluşturulduktan sonra RocketMQ konusuna yayınlanan mesajlar, aşağıdaki biçimde CloudEvents olarak olay veri yoluna iletilir:

{
    "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 zarf alanları (id, source, specversion, type, datacontenttype, subject, time) hakkında daha fazla bilgi için bkz. Olaylara genel bakış.