简介

本文档介绍通过规则引擎服务将MQTT消息转发至百度消息服务（BMS），以及相应的操作示例。

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

场景描述

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

操作步骤

创建实例

1. 点击创建IoT Core。

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

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

添加模板

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

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

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

添加设备

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

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

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

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

配置规则引擎

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

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

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

3. 点击右侧“编辑调试”，进行规则的编辑。

4. 规则的编辑页面如图所示，在数据来源处输入。

$iot/+/events

(接受设备上报的状态消息)

注：可在”topic模板“中查询设置详情。

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

6. 在第一栏选择“百度消息服务BMS”，选择自己的存储主题并点击“确认”，如果其中没有，可以通过“创建Kafka”进行自行创建。

此处输入需要设置的过滤规则，本次暂不设置过滤。

7. 完成后点击保存完成配置。

点击启用运行规则。

测试

我们使用MQTT.fx模拟信息发送。

1. 先进入设备，查看设备信息。

通过此处获取连接信息。

2. 将设备信息填入上方，点击计算，得到连接信息。

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

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

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

6. 进入百度消息服务，进入我们使用的主题。

7. 通过百度消息服务BMS的指定主题的监控，可以看到写入指标有增长，说明消息转发并写入成功。