概述

天工平台将设备上报的数据流转至百度kafka中，之后，业务应用服务器可以消费kafka中的数据进行业务处理。

应用场景

场景说明：

• 通过百度消息服务kafka削峰填谷，缓冲消息，减轻服务器同时接收大量设备消息的压力。
• 持久化设备上报的业务数据，防止业务处理应用故障导致消息丢失造成损失。

前提条件

已开通百度消息服务。如未开通，请登录百度消息服务BMS产品页，开通服务。

注意： 规则引擎作为IoT Core的组成部分，不单独计费。

操作步骤

本文介绍如何使用控制台快速IoT Core下创建一条规则，学习编辑调试规则、删除规则，用时大约五分钟。

成功创建 IoT Core 实例后，点击实例名称，进入详情页面，点击 规则引擎 即可创建和管理规则，基本操作流程如下：

1.创建规则：在IoT Core下创建一条规则。
2.编辑调试：编辑规则数据来源、数据目的地，配置规则。
3.规则验证：查看数据目的地产品是否有数据写入，验证规则。

1.创建规则

1.在IoT Core实例详情点击左侧规则引擎菜单，进入规则列表页。
2.点击「创建规则」按钮，填写规则名称、描述，点击「确定」即可完成规则创建。

2.编辑调试

点击上一步创建规则最后的「编辑调试」按钮，进入规则编辑调试页。

1.在「数据来源」输入框中输入设备上报消息的主题，示例中我们使用$iot/+/events，代表规则引擎接收当前IoT Core下所有设备通过$iot/{deviceName}/events上报的消息。

2. 点击「添加目的地」按钮，在弹窗中「数据目的地」下拉选项中选择「百度消息服务BMS」,选择kafka所在的「区域」，选择「存储主题」，最后点击「确定」保存目的地。如当前账号没有百度消息服务BMS主题，可点击「创建Kafka」进行创建。

3. 设置「过滤条件为」空，表示不对数据进行过滤处理;同时设置「查询语句」为 $ ,表示将不对消息进行格式转换直接将原始消息转发到数据目的地；

4. 点击页面最下方的「保存」按钮，返回规则列表，点击规则最右侧的「启用」按钮。

3.验证规则

经过上边步骤，规则已开始运行并将数据来源topic订阅到的消息转发到百度kafka中，打开百度消息服务控制台，找到对应的topic，进入监控页面，可以查看到设备消息已写入。

至此，你已经可以使用规则引擎进行消息转发了，可以进一步尝试将设备消息转发到MQTT主题、存储到TSDB。