示例说明

最近更新时间:2019-06-12 14:05:42

实现概要

本示例主要演示:

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

实现步骤

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

演示流程

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