云函数 TDMQ 触发

通过 EventBridge 事件总线，用户可以编写云函数来处理 TDMQ 消息队列中收取到的消息。云函数后台模块可以作为消费者消费 TDMQ 中的消息，并将消息传递给云函数，本篇文档将为您指导，云函数如何通过 EventBridge 事件总线触发器，接收并消费来自 TDMQ 的产品事件。
创建步骤
步骤1：创建函数
登录 Serverless 控制台，在新建函数页面，完成您的函数代码上传与部署。详情可参见 使用控制台创建一个事件函数。
注意
目前 TDMQ 只支持北京、上海、广州地域。
步骤2：配置触发器
在配置触发器步骤，选择 TDMQ Pulsar消息队列触发后，按照指引，依次选择您的 TDMQ 集群、主题等信息，指定触发事件源，消费位置：
﻿
﻿
步骤3：管理触发器
创建完成后，在“触发器管理”页面可以看到创建的触发器信息，点击进入事件总线控制台，即可完成事件集、事件源等信息管理，详情请参考 事件总线产品文档。
﻿
﻿
给指定 TDMQ 消息队列发送信息，即可看到函数被正常调用：
﻿
﻿
事件结构
{
   {
    "specversion": "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。
subscriptionName
订阅名称。
timestamp
时间戳，精确到毫秒。
tags
TDMQ 标签。
msgId
TDMQ 消息 ID。
msgBody
TDMQ 消息体。
topictype
topic 类型描述：
0：普通消息。
1：全局顺序消息。
2：局部顺序消息。
3：重试队列。
4：死信队列。
﻿

参数	描述
topic	Topic 完整路径 `persistent://appid/namespace/topic-1`。
subscriptionName	订阅名称。
timestamp	时间戳，精确到毫秒。
tags	TDMQ 标签。
msgId	TDMQ 消息 ID。
msgBody	TDMQ 消息体。
topictype	topic 类型描述： 0：普通消息。 1：全局顺序消息。 2：局部顺序消息。 3：重试队列。 4：死信队列。

TDMQ 触发

本页目录：

创建步骤

步骤1：创建函数

步骤2：配置触发器

步骤3：管理触发器

事件结构