操作场景
您可以通过配置 TDMQ 连接器来消费 TDMQ 消息队列的内容。TDMQ 连接器实现方式为 Pull 模型，事件连接器会主动拉取 TDMQ 内容，并将相关事件通过事件规则路由到更多服务。本文为您介绍如何创建 TDMQ 连接器和 TDMQ 连接器生成的事件结构。
注意
目前 TDMQ 连接器只支持消费 TDMQ-Pulsar 版本队列信息。
前提条件
操作步骤
1. 登录 事件总线控制台，选择左侧导航栏中的事件集。
2. 在“事件集”列表，选择期望配置 TDMQ 连接器的事件集。
3. 在“事件集详情”页事件连接器配置项中单击添加，如下图所示：
4. 根据页面提示填写相关信息，其中连接器类型选择消息队列（TDMQ）连接器，其余配置项按照提示填写。如下图所示：
5. 单击确定完成创建。
6. 在“基本信息”页顶部单击管理事件规则，如下图所示：
7. 在“事件规则”顶部选框，选择与之前创建一致的事件集信息，并单击新建，如下图所示：
8. 根据页面提示填写相关信息，其中连接器类型选择消息队列（TDMQ），信息填写完成后点击下一步，如下图所示：
9. 配置触发目标端，配置完成后单击完成即可创建 TDMQ 连接器。
TDMQ 连接器的数据结构说明
{"specversion": "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 消息体。 |
