函数部署

最近更新时间:2019-06-12 14:04:57

环境准备

  1. 登录 对象存储控制台,创建一个 Bucket,命名为 ckafka-backup,并选择广州地域,权限选择 “私有读写”。该 bucket 用于存放云函数处理后的 Ckafca 消息。
  2. 切换到 Ckafka 控制台,购买 Ckafca 实例,并创建 Topic。

创建云函数

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

配置 Ckafca 触发器

  1. 在 “触发方式” 页签中,单击【添加触发方式】,并根据页面的参数信息进行填写。如下图所示:

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