有奖捉虫:云通信与企业服务文档专题,速来> HOT

实现概要

本示例主要演示:
通过配置 Ckafka 触发器和 Ckafka 对接,实现消息的自定义逻辑处理。
将云函数处理后的消息以文本的形式投递到对象存储 COS。

实现步骤

1. 购买 Ckafka 实例,并创建 Topic。
2. 在云函数控制台中,部署业务处理函数,并配置 Ckafka 触发器,对接已有的 Ckafka Topic。
3. 创建 COS bucket,用于接收处理后的消息文本。

演示流程

在 Ckafka 控制台中的 Consumer Group 查看以 “scf_invoker” 开头的消费组。n当 Ckafka 产生消息后,云函数会被触发执行。同时,在 COS bucket 中也会产生基于时间维度的文件夹、文本文件。