最佳实践

函数部署

最近更新时间:2020-08-03 11:33:34

环境准备

  1. 登录 对象存储控制台,创建一个 Bucket,命名为 ckafka-backup,并选择北京地域,权限选择 “私有读写”。该 bucket 用于存放云函数处理后的 Ckafka 消息。
    注意:

    Bucket 和函数必须位于同一个地域下。本文将以北京区域为例。

  2. 切换到 Ckafka 控制台,购买 Ckafka 实例,并创建 Topic。

创建云函数

  1. 登录云函数控制台,选择左侧导航栏中的【函数服务】。
  2. 在“函数服务”页面上方选择北京地域,并单击【新建】进入新建函数页面。
    设置以下参数信息,并单击【下一步】。如下图所示:
    • 函数名称:命名为 “ckafka-backup”。
    • 运行环境:选择 “Python 2.7”。
    • 创建方式:选择【模板函数】。
    • 模糊搜索:输入 “Ckafka 消息投递 COS”,并进行搜索。
      单击模板中的【查看详情】,即可在弹出的“模板详情”窗口中查看相关信息,支持下载操作。
  3. 保持默认配置,单击【完成】,完成函数的创建。
  4. 在使用本模板函数时,您需要按照提示修改函数代码中的配置信息。
    在【函数代码】页签中的代码框内,设置用户属性。将 appid、secret_id、secret_key、region 和 bucket_upload 替换为您的 APPID、SecretId、SecretKey、region、bucket_upload,并单击【保存】,完成创建。如下图所示:

配置 Ckafka 触发器

  1. 选择左侧的【触发管理】,并单击【创建触发器】,根据页面的参数信息进行填写。如下图所示:

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