简介

本文档介绍如何通过规则引擎服务将 MQTT 消息转发至百度消息服务 for Kafka，并给出共享版 Kafka 目的地的配置和测试示例。

百度消息服务 for Kafka 支持共享版和专享版。本文以共享版 Kafka 为例：在配置规则目的地时，可直接选择当前账号下的共享版 Kafka 主题。若需要写入专享版 Kafka，请先在百度消息服务 for Kafka 控制台开启产品间转储，并在 IoT Core 的“数据目的地管理”中添加专享版 Kafka 目的地，详细步骤请参考数据目的地管理。

阅读本示例前，建议先熟悉快速入门文档。

场景描述

该场景演示在物联网应用中，将设备上报的 MQTT 消息通过规则引擎转发至百度消息服务 for Kafka 的完整过程，包括创建 IoT Core 实例、添加模板、添加设备、配置规则引擎和测试消息转发结果。

操作步骤

创建实例

1. 点击创建 IoT Core。

2. 在名称中输入想要创建的实例名字后点击提交。

此时在实例列表中可以看见刚刚创建的实例，点击该实例进行配置。

添加模板

1. 在配置页面点击左侧的“模板”栏进行模板创建。

2. 输入想要创建的模板名称，点击确认。

3. 创建完成后可以在模板栏看见该模板，里面已有两个预设 Topic，其中“deviceName”为占位符，实际设备中使用设备的名称进行替换。

添加设备

1. 进入左侧“设备列表”栏，点击新增设备。

2. 在名称栏输入创建的设备名，认证方式选择“密钥认证”，模板栏选择上一步创建的模板，点击“提交”。

3. 此时会显示该设备的密钥，点击“下载”保存密钥记录文本。

4. 在设备列表中可以看见刚刚创建的设备。

配置规则引擎

1. 进入左侧的“规则引擎” > “规则列表”，点击“创建规则”进行创建。

2. 在“名称”输入想要创建的规则名称后点击确认。

此时规则列表中已有刚刚创建的规则，初始状态为“已禁用”。

3. 点击右侧“编辑调试”，进入规则编辑页面。

4. 在“数据来源”处输入需要订阅的设备消息 Topic。

1$iot/+/events

该 Topic 用于接收设备上报的状态消息。也可以通过“Topic 模板”查询和选择设备消息来源。

5. 数据来源配置完毕后，配置数据目的地，点击“添加目的地”。

6. 在目的地类型中选择“百度消息服务 for Kafka”，选择区域和需要写入的 Kafka 主题后点击“确认”。

如果下拉列表中没有可选主题，请检查对应区域下是否已创建百度消息服务 for Kafka 共享版实例和主题；如未创建，可点击“创建 Kafka”跳转到百度消息服务 for Kafka 控制台进行创建。

说明：

• 本示例使用共享版 Kafka 主题作为规则目的地。
• 若需要写入专享版 Kafka，请先在“数据目的地管理”中添加专享版 Kafka 目的地，再在规则目的地中选择“用户 Kafka”类型下的对应目的地。
• 专享版 Kafka 使用前需要在百度消息服务 for Kafka 控制台开启产品间转储，否则连接测试和规则写入可能失败。

7. 配置过滤规则。本示例暂不设置过滤规则，消息会继续进入后续转发流程。

8. 完成后点击保存，完成规则配置。

点击启用运行规则。

测试

本示例使用 MQTT.fx 模拟设备消息发送。

1. 进入设备详情页，查看设备信息。

通过连接信息计算工具获取连接信息。

2. 将设备信息填入连接信息计算工具，点击计算，得到 MQTT 连接信息。

3. 在 MQTT.fx 配置页面输入上一步获取的信息。

4. 保存后点击 Connect 进行连接。

5. 通过 MQTT.fx 客户端的 Publish 功能发送测试消息。为了便于观察测试效果，可以发送多次。

6. 进入百度消息服务 for Kafka 控制台，打开本示例中使用的 Kafka 主题。

7. 通过百度消息服务 for Kafka 主题的监控信息，可以看到写入指标增长，说明设备消息已通过规则引擎成功转发并写入 Kafka 主题。