一、实现概要
本示例主要演示:
·通过配置 Ckafka 触发器和 Ckafka 对接,实现消息的自定义逻辑处理。
·将云函数处理后的消息以文本的形式投递到对象存储 COS。
二、实现步骤
3. 创建 COS bucket,用于接收处理后的消息文本。
三、演示流程
在 Ckafka 控制台中的 Consumer Group 查看以 “scf_invoker” 开头的消费组。n当 Ckafka 产生消息后,云函数会被触发执行。同时,在 COS bucket 中也会产生基于时间维度的文件夹、文这篇件。