实现概要
本示例主要演示:通过配置 Ckafka 触发器和 Ckafka 对接,实现消息的自定义逻辑处理。将云函数处理后的消息以文本的形式投递到对象存储 COS。
实现步骤
1. 购买 Ckafka 实例,并创建 Topic。2. 在云函数控制台中,部署业务处理函数,并配置 Ckafka 触发器,对接已有的 Ckafka Topic。3. 创建 COS bucket,用于接收处理后的消息文本。
演示流程
在 Ckafka 控制台中的 Consumer Group 查看以 “scf_invoker” 开头的消费组。n当 Ckafka 产生消息后,云函数会被触发执行。同时,在 COS bucket 中也会产生基于时间维度的文件夹、文本文件。
官网1折活动,限时活动,即将结束,速速收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折,更有现金返利。同意关联立享优惠
转转请注明出处:https://www.yunxiaoer.com/149996.html