tencent cloud

事件总线

文档事件总线事件源连接器配置 TDMQ 连接器

配置 TDMQ 连接器

PDF
聚焦模式
字号
最后更新时间： 2024-01-22 20:52:28

操作场景

您可以通过配置 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": "1.0",
    "id": "13a3f42d-7258-4ada-da6d-023a333b4662",
    "type": "connector:tdmq",
    "source": "tdmq.cloud.tencent",
    "subjuect": "qcs::tdmq:$region:$account:topicName/$topicSets.clusterId/$topicSets.environmentId/$topicSets.topicName/$topicSets.subscriptionName",
    "time": "1615430559146",
    "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
订阅名称。
timestamp
时间戳，精确到毫秒。
partitions
TDMQ 队列消费的 partition。
msgId
TDMQ 消息 ID。
msgBody
TDMQ 消息体。

上一篇: 配置 DTS 连接器下一篇: 事件结构

帮助和支持

本页内容是否解决了您的问题？

填写满意度调查问卷，共创更好文档体验。

文档反馈