配置 TDMQ 连接器

最近更新时间:2024-07-10 17:56:21

我的收藏

操作场景

您可以通过配置 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 消息体。