通过 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：死信队列。 |
官网1折活动，限时活动，即将结束，速速收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折，更有现金返利。同意关联立享优惠
转转请注明出处：https://www.yunxiaoer.com/149558.html