云函数 示例说明(SCF + Ckafka 实现消息数据自定义处理并投递至 COS)

1. 购买 Ckafka 实例,并创建 Topic。2. 在云函数控制台中,部署业务处理函数,并配置 Ckafka 触发器,对接已有的 Ckafka Topic。

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

一、实现概要

本示例主要演示:

·通过配置 Ckafka 触发器和 Ckafka 对接,实现消息的自定义逻辑处理。

·将云函数处理后的消息以文本的形式投递到对象存储 COS。

二、实现步骤

3. 创建 COS bucket,用于接收处理后的消息文本。

三、演示流程

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

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