云函数 函数测试(SCF + Ckafka 实现消息数据自定义处理并投递至 COS)

登录 Ckafka 控制台,并在 “Consumer Group” 中检查消费组是否生成。 如下图所示: n。

相关产品
云函数 产品页,含版本规格、价格与购买入口。

注意:如果你还未将实际数据接入消息队列 Ckafka,你可以通过 客户端工具 模拟消息生产。

一、检查 Consumer Group

·是,表示部署成功。

·否,表示部署失败,请 提交工单 反馈。

二、检查执行状态

触发器生效后,切换至 Serverless 控制台,查看函数的运行日志。如下: n

三、检查 Ckafka 消息

1. 切换至 对象存储 COS 的控制台,查看对应的 bucket 下是否有文件生成。

·是,执行下一步。

·否,表示部署失败,请 提交工单 反馈。

2. 下载并查看新生成的文件,确认 Ckafka 的消息是否已按照换行写入。如下: n

·是,表示部署成功。

·否,表示部署失败,请 提交工单 反馈。

四、调整函数代码

本示例根据触发器配置的最大批量消息数触发云函数运行。

注意:如果生产的消息数很多,且不想在 COS bucket 中生成过多的文件,可在云函数中使用 COS 的 SDK,以追加写入的方式减少文件数量。

云函数运行的操作流程如下:

1. 创建一个名称格式为 “时间戳+随机数” 的文这篇件,例如2018-11-22-20:43:55-127.txt。

2. 将拉取到的 Ckafka 消息换行写入文这篇件中。

3. 将写好的文件上传到 COS bucket,并以小时为单位在 COS bucket 中创建文件夹。

赞 (0)
上一篇 4天前
下一篇 4天前