最佳实践

函数部署

最近更新时间:2021-01-06 16:52:57

环境准备

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

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

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

创建云函数及 Ckafka 触发器

  1. 登录云函数控制台,选择左侧导航栏中的【函数服务】。

  2. 在“函数服务”页面上方选择北京地域,并单击【新建】进入新建函数页面。
    设置以下参数信息,并单击【下一步】。如下图所示:

    • 创建方式:选择【模板创建】。
    • 模糊搜索:输入 “Ckafka 消息转储至 COS”,并进行搜索,本文以运行环境 Python 2.7 为例。
      单击模板中的【查看详情】,即可在弹出的“模板详情”窗口中查看相关信息,支持下载操作。
  3. 单击【下一步】,函数名称默认填充,可根据需要自行修改。按照引导配置运行角色:

    • 运行角色:勾选“启用”,选择“配置并使用SCF模版运行角色”,将会自动创建并选择关联了 COS、Ckafka 全读写权限的 SCF 模版运行角色,或选择“使用已有角色”,在下拉列表中选择包含上述权限的已有角色。本文以“配置并使用SCF模版运行角色”为例。如下图所示:
      说明

      云函数在运行时,会使用运行角色换取临时密钥,操作相关云产品资源。

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

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

    主要参数信息如下:

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

目录