日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

自定義事件源消息隊列RocketMQ版

事件總線EventBridge支持接入云消息隊列 RocketMQ 版的消息,進行事件分析、查看事件軌跡、進行數(shù)據(jù)轉(zhuǎn)發(fā)等操作。本文介紹如何在事件總線EventBridge控制臺添加云消息隊列 RocketMQ 版類型的自定義事件源。

前提條件

操作步驟

  1. 登錄事件總線EventBridge控制臺
  2. 在左側(cè)導航欄,單擊事件總線
  3. 在頂部菜單欄,選擇地域。
  4. 事件總線頁面,單擊目標總線名稱。
  5. 在左側(cè)導航欄,單擊事件源
  6. 事件源頁面,單擊添加事件源

  7. 添加自定義事件源面板,輸入名稱描述事件提供方選擇消息隊列 RocketMQ 版,配置以下參數(shù),然后單擊確認

    • 地域:選擇已創(chuàng)建的云消息隊列 RocketMQ 版實例所在的地域。

    • 版本:選擇RocketMQ 4.x或者RocketMQ 5.x

    • RocketMQ 實例:選擇已創(chuàng)建的云消息隊列 RocketMQ 版實例。

    • Topic:選擇已創(chuàng)建的Topic。

    • (可選)Tag:輸入過濾標簽。

    • Group ID:選擇已創(chuàng)建的Group ID。

      說明

      一個Group對應一類業(yè)務消息。請確保不同的事件源使用獨立的Group ID,且不要與已有業(yè)務共用。

    • 消費位點:選擇消費位點,默認為最新位點。

事件示例

{
    "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規(guī)范中定義的參數(shù)解釋,請參見事件概述

data字段包含的參數(shù)解釋如下表所示。

參數(shù)

類型

示例值

描述

topic

String

TopicName

Topic名稱。

systemProperties

Map

系統(tǒng)屬性。

MIN_OFFSET

Int

0

最低位點。

TRACE_ON

Boolean

true

是否有消息軌跡。取值說明如下:

  • true:有消息軌跡。

  • false:無消息軌跡。

MAX_OFFSET

Int

8

最高位點。

MSG_REGION

String

cn-hangzhou

發(fā)送消息的地域。

KEYS

String

systemProperties.KEYS

過濾屬性。

CONSUME_START_TIME

Long

1628577790396

開始消費時間。單位:毫秒。

UNIQ_KEY

String

AC14C305069E1B28CDFA3181CDA2****

消息唯一鍵。

TAGS

String

systemProperties.TAGS

過濾屬性。

INSTANCE_ID

String

MQ_INST_123456789098****_BXhFHryi

實例ID。

userProperties

Map

用戶屬性。

body

String

TEST

消息內(nèi)容。