一、环境准备
注意：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. 在触发器配置中，选择“自定义创建”，根据页面的参数信息进行填写。如下： nn主要参数信息如下：
·触发方式：选择 “Ckafka触发”。
·Ckafka实例：选择需要对接的 Ckafka 实例。
·Topic：选择需要对接的 Topic。
·最大批量消息数：请根据单条消息的大小和实际业务量进行配置，默认消息总数的大小要小于1MB。单次触发云函数运行时最大可处理的消息条数。例如，配置500，则最多会有500条消息会触发一次云函数。Ckafka 生产的消息过多时，消息组将自动触发多个函数实例运行，加速消息速度。
6. 单击完成，即可完成函数和触发器创建。