注意如果您还未将实际数据接入消息队列 Ckafka，您可以通过 客户端工具 模拟消息生产。
检查 Consumer Group
登录 Ckafka 控制台，并在 “Consumer Group” 中检查消费组是否生成。 如下图所示： n
是，表示部署成功。否，表示部署失败，请 提交工单 反馈。
检查执行状态
触发器生效后，切换至 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 中创建文件夹。
官网1折活动，限时活动，即将结束，速速收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折，更有现金返利。同意关联立享优惠
转转请注明出处：http://www.yunxiaoer.com/150005.html