tencent cloud

文档反馈

配置 TDMQ 连接器

最后更新时间:2024-11-01 20:44:50

    操作场景

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

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持