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

环境准备

1. 登录 对象存储控制台,创建一个 Bucket,命名为 ckafka-backup,并选择北京地域,权限选择 “私有读写”。该 bucket 用于存放云函数处理后的 Ckafka 消息。
注意
Bucket 和函数必须位于同一个地域下。本文将以北京区域为例。
2. 切换到 Ckafka 控制台,购买 Ckafka 实例,并创建 Topic。

创建云函数及 Ckafka 触发器

1. 登录 Serverless 控制台,进入函数服务页面。
2. 在“函数服务”页面上方选择北京地域,并单击新建进入新建函数页面。n设置以下参数信息,并单击下一步。如下图所示:
创建方式:选择模板创建
模糊搜索:输入 “Ckafka 消息转储至 COS”,并进行搜索,本文以运行环境 Python 2.7 为例。单击模板中的查看详情,即可在弹出的“模板详情”窗口中查看相关信息,支持下载操作。n


3. 单击下一步,函数名称默认填充,可根据需要自行修改。按照引导配置运行角色:
运行角色:勾选“启用”,选择“配置并使用SCF模板运行角色”,将会自动创建并选择关联了 COS、Ckafka 全读写权限的 SCF 模板运行角色,或选择“使用已有角色”,在下拉列表中选择包含上述权限的已有角色。本文以“配置并使用SCF模板运行角色”为例。如下图所示:
说明
云函数在运行时,会使用运行角色换取临时密钥,操作相关云产品资源。



4. 在使用本模板函数时,您需要按照提示修改函数代码中的配置信息。n点击展开函数代码,将 appid、secret_id、secret_key、region 和 bucket_upload 替换为您的 APPID、SecretId、SecretKey、region、bucket_upload,并单击保存,完成创建。如下图所示: n


5. 触发器配置中,选择“自定义创建”,根据页面的参数信息进行填写。如下图所示: n

n主要参数信息如下:
触发方式:选择 “Ckafka触发”。
Ckafka实例:选择需要对接的 Ckafka 实例。
Topic:选择需要对接的 Topic。
最大批量消息数:请根据单条消息的大小和实际业务量进行配置,默认消息总数的大小要小于1MB。单次触发云函数运行时最大可处理的消息条数。例如,配置500,则最多会有500条消息会触发一次云函数。Ckafka 生产的消息过多时,消息组将自动触发多个函数实例运行,加速消息速度。
6. 单击完成,即可完成函数和触发器创建。