一、操作场景
注意:目前 TDMQ 连接器只支持消费 TDMQ-Pulsar 版本队列信息。
二、前提条件
已 创建事件集。
三、操作步骤
1. 登录 事件总线控制台,选择左侧导航栏中的事件集。
2. 在“事件集”列表,选择期望配置 TDMQ 连接器的事件集。
3. 在“事件集详情”页事件连接器配置项中单击添加:
4. 根据页面提示填写相关信息,其中连接器类型选择消息队列(TDMQ)连接器,其余配置项按照提示填写。如下:
5. 单击确定。
6. 在“基本信息”页顶部单击管理事件规则:
7. 在“事件规则”顶部选框,选择与之前创建一致的事件集信息,并单击新建:
8. 根据页面提示填写相关信息,其中连接器类型选择消息队列(TDMQ),信息填写完成后单击下一步:
9. 配置触发目标端,配置完成后单击完成即可创建 TDMQ 连接器。
四、TDMQ 连接器的数据结构说明
{ "specversion": "1.0", "id": "74cd1a32-cfc9-439e-940a-71c172aac6c2", "source": "tdmq.cloud.tencent", "type": "connector:tdmq", "subject": "qcs::tdmq:$region:$account:topicName/$topicSets.clusterId/$topicSets.environmentId/$topicSets.topicName/$topicSets.subscriptionName", "time": 1678193776105, "region": "ap-guangzhou", "datacontenttype": "application/json;charset=utf-8", "data": { "topic": "persistent://appid/namespace/topic-1", "tags": "testtopic", "TopicType": "0", "subscriptionName": "xxxxxx", "toTimestamp": "1603352765001", "partitions": "0", "msgId": "123345346", "msgBody": "Hello from TDMQ!" }}
参数说明如下:
| 参数 | 描述 |
| topic | Topic 完整路径 persistent://appid/namespace/topic-1。 |
| tags | TDMQ 标签。 |
| TopicType | topic 类型描述:0:普通消息。1:全局顺序消息。2:局部顺序消息。3:重试队列。4:死信队列。 |
| subscriptionName | 订阅名称。 |
| toTimestamp | 时间戳,精确到毫秒。 |
| partitions | TDMQ 队列消费的 partition。 |
| msgId | TDMQ 消息 ID。 |
| msgBody | TDMQ 消息体。 |