本文介绍如何在事件总线EventBridge控制台添加消息队列RocketMQ版类型的自定义事件源。
前提条件
- 消息队列RocketMQ版
- 事件总线EventBridge
操作步骤
事件示例
{
"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字段包含的参数解释如下表所示。
参数 | 类型 | 示例值 | 描述 |
---|---|---|---|
topic | String | TopicName | Topic名称。 |
systemProperties | Map | 系统属性。 | |
MIN_OFFSET | Int | 0 | 最低位点。 |
TRACE_ON | Boolean | true | 是否有消息轨迹。取值说明如下:
|
MAX_OFFSET | Int | 8 | 最高位点。 |
MSG_REGION | String | cn-hangzhou | 发送消息的地域。 |
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 | 消息内容。 |