百度消息服务触发器使用示例

更新时间：2026-09-24

概述

本文档介绍如何在云函数计算 CFC 中为函数配置百度消息服务触发器，包括编写处理函数、配置触发器，以及通过模拟测试和真实测试验证函数执行结果。

前提条件

已登录百度智能云管理控制台，并具备云函数计算 CFC 与百度消息服务的操作权限。
已创建用于绑定触发器的目标函数。
已准备可供监听的百度消息服务 Topic。## 百度消息服务触发器说明

百度消息服务是全兼容 Apache Kafka 的分布式、高可扩展、高通量的消息托管服务。

如果在百度消息服务的 Topic 上检测到记录，您可以使用 CFC 函数从此 Topic 读取成批的数据来处理，并且 CFC 会定期轮询（每秒一次）Topic 中的新纪录。

百度消息服务触发器创建

用户可以为新建的函数或已有函数配置百度消息服务触发器，创建函数的流程可以具体参考从头创建函数，这里不再赘述。

这里假设您已经创建了一个目标函数，以下内容将引导您在 CFC 控制台的函数管理页面中为函数配置百度消息服务触发器。

编写处理函数

导航路径：产品服务->云函数计算 CFC->函数列表->目标函数->函数代码

步骤 1：进入目标函数详情页

在 【函数列表】 页面，点击目标函数名称，进入函数详情页。

步骤 2：编写并保存处理函数

点击 【函数代码】，保持 编辑类型 为 在线编辑，将编辑器中的示例代码替换为以下内容，并确认 处理程序 为 index.handler。完成后，点击 【保存】。

                Python
                
            

                # -*- coding: utf-8 -*-
import base64

def handler(event, context):
    for record in event['Records']:
        payload = base64.b64decode(record['Kafka']['Value'])
        print("Decoded payload: " + payload.decode('utf-8'))
    return 'Successfully processed {} records.'.format(len(event['Records']))
            

处理程序使用 index.handler，表示事件触发时会调用 index.py 中的 handler 方法。该处理函数会遍历 event['Records']，对每条 Kafka 消息的 Value 进行 Base64 解码，并返回本次处理的记录数。

百度消息服务触发器的 event 消息体结构如下：

                JSON
                
            

                {
  "Records": [
    {
      "EventId": "<事件唯一标识>",
      "Kafka": {
        "Key": "<Base64 编码后的消息键>",
        "Value": "<Base64 编码后的消息值>",
        "Topic": "<Topic 名称>",
        "Partition": 0,
        "Offset": 0,
        "Timestamp": 0
      },
      "EventName": "bce:kafka:record",
      "EventSourceBrn": "<事件源标识>",
      "EventSource": "bce:kafka"
    }
  ]
}
            

配置百度消息服务触发器

导航路径：产品服务->云函数计算 CFC->函数列表->目标函数->触发器

步骤 1：进入触发器配置页

Plain Text

1![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_01.png)
2
3![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_02.png)

在 【函数列表】 页面，点击目标函数名称进入函数详情页，再点击 【触发器】。

步骤 2：新增百度消息服务触发器

在触发器页面点击 【新增触发器】，在弹出框的 触发器 下拉框中选择 百度消息服务（kafka）触发器。

Plain Text

1![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_04.png)

步骤 3：配置触发器参数并完成创建

Plain Text

1![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_05.png)

测试触发器

模拟测试

导航路径：产品服务->云函数计算 CFC->函数列表->目标函数

步骤 1：打开测试事件窗口

在函数详情页，点击 【测试】，打开测试事件窗口。

步骤 2：输入测试事件并执行

在 【测试事件】 页签中，将编辑器中的默认内容替换为以下测试事件，然后点击 【执行】。

                JSON
                
            

                {
  "Records": [
    {
      "EventId": "<事件唯一标识-1>",
      "Kafka": {
        "Key": "",
        "Value": "<Base64 编码后的消息值-1>",
        "Topic": "<Topic 名称>",
        "Partition": 0,
        "Offset": 0,
        "Timestamp": 0
      },
      "EventName": "bce:kafka:record",
      "EventSourceBrn": "<事件源标识>",
      "EventSource": "bce:kafka"
    },
    {
      "EventId": "<事件唯一标识-2>",
      "Kafka": {
        "Key": "",
        "Value": "<Base64 编码后的消息值-2>",
        "Topic": "<Topic 名称>",
        "Partition": 0,
        "Offset": 1,
        "Timestamp": 0
      },
      "EventName": "bce:kafka:record",
![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_07.png)
      "EventSourceBrn": "<事件源标识>",
![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_08.png)

### 真实测试

导航路径：**产品服务->云函数计算 CFC->函数列表->目标函数**

![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_09.png)

在添加好触发器之后，您可以按以下步骤进行真实测试。

![图片](https://doc.bce.baidu.com/bce-documentation/CFC/CFC_Kafka_10.png)
            

评价此篇文章

有帮助没帮助

DuEdge触发器

CDN触发器使用示例