云函数 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:死信队列。
赞 (0)
上一篇 4天前
下一篇 4天前