上云无忧 > 文档中心 > 腾讯云云函数使用教程 - 事件总线触发器 TDMQ 触发
云函数 SCF
腾讯云云函数使用教程 - 事件总线触发器 TDMQ 触发

文档简介:
通过 EventBridge 事件总线,用户可以编写云函数来处理 TDMQ 消息队列中收取到的消息。云函数后台模块可以作为消费者消费 TDMQ 中的消息,并将消息传递给云函数,本篇文档将为您指导,云函数如何通过 EventBridge 事件总线触发器,接收并消费来自 TDMQ 的产品事件。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠
通过 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:死信队列。
相似文档
  • 当您调用触发器接口 设置函数触发方式(CreateTrigger)时,对应的 TriggerDesc 参数为触发器描述,您可参考本文进行使用。
  • 云函数(Serverless Cloud Function,SCF)提供代码部署、镜像部署两种部署方式,支持事件函数和 Web 函数两种函数类型。不同的部署方式以及函数类型在代码开发时需要采用不同的规范。本文主要介绍代码部署的事件函数的编写规范及相关概念,镜像部署 和 Web 函数 详情请参考对应文档。
  • 在创建并编写完云函数之后,您可以通过以下方式测试云函数,了解函数运行情况,并检查代码执行流程。 SCF VS Code 插件:云端调试。 SCF 控制台:云端测试。
  • 在创建或编辑云函数时,您可以通过修改配置中的环境变量,为云函数的运行环境增加、删除或修改环境变量。 在配置环境变量后,环境变量将在函数运行时配置到所在的操作系统环境中。函数代码可以使用读取系统环境变量的方式来获取到设置的具体值并在代码中使用。
  • 内置依赖 云函数 SCF 各个运行时已内置部分常用依赖库,您可前往各运行时代码开发中查询: Node.js、 Python、 PHP、 Golang。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部