腾讯云云函数实战教程 - SCF + Ckafka 实现消息数据自定义处理并投递至 COS | 函数测试
文档简介：
注意：
如果您还未将实际数据接入消息队列 Ckafka，您可以通过 客户端工具 模拟消息生产。
咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！
微信咨询
免费试用、价格特惠
注意
如果您还未将实际数据接入消息队列 Ckafka，您可以通过 客户端工具 模拟消息生产。
检查 Consumer Group
登录 Ckafka 控制台，并在 “Consumer Group” 中检查消费组是否生成。 如下图所示：
是，表示部署成功。
否，表示部署失败，请 提交工单 反馈。
检查执行状态
触发器生效后，切换至 Serverless 控制台，查看函数的运行日志。如下图所示：
检查 Ckafka 消息
1. 切换至 对象存储 COS 的控制台，查看对应的 bucket 下是否有文件生成。
是，执行下一步。
否，表示部署失败，请 提交工单 反馈。
2. 下载并查看新生成的文件，确认 Ckafka 的消息是否已按照换行写入。如下图所示：
是，表示部署成功。
否，表示部署失败，请 提交工单 反馈。
调整函数代码
本示例根据触发器配置的最大批量消息数触发云函数运行。
说明
如果生产的消息数很多，且不想在 COS bucket 中生成过多的文件，可在云函数中使用 COS 的 SDK，以追加写入的方式减少文件数量。
云函数运行的操作流程如下：
1. 创建一个名称格式为 “时间戳+随机数” 的文本文件，例如2018-11-22-20:43:55-127.txt。
2. 将拉取到的 Ckafka 消息换行写入文本文件中。
3. 将写好的文件上传到 COS bucket，并以小时为单位在 COS bucket 中创建文件夹。
