文档简介：
一、简介
在本教程中，您将学习到如何将 IoT Core 的设备消息通过『规则引擎』转发至不同账户下的百度消息服务 BMS 实例，可以实现跨账 户消息转发等需求。本文主要包括简介、场景描述、注意事项、操作步骤 4 部分内容，通过具体示例展示了相关使用流程。
其他关于规则引擎转发到百度消息服务 BMS 的功能，也可以查看另外一个教程：数据转发到百度消息服务BMS。
阅读本示例前建议先熟悉『快速入门』文档。
二、场景描述
此功能应用场景不仅可以用于『百度消息服务 BMS，即消息服务 for Kafka』与『IoT Core 产品』不在同一账户的情况，更主要的是出于安全性的考量。
例子：当需要将设备的实时数据共享给其他用户时，如果直接提供『IoT Core』的账户给用户显然是不安全的，正确的做法是用户向数据接收方（即『IoT Core』账户所有者）提供自己百度智能云账户下的 Kafka 主题，让其在规则引擎中进行『添加目的地』操作，进而实现设备消息可以跨用户进行流转。
三、注意事项
⚠️ 『用户 Kafka』当前仅支持任意百度云账号下广州区的『百度消息服务 for Kafka』作为『用户 Kafka』被添加为『数据目的地』。
四、操作步骤
4.1 创建 IoT Core 实例
进入物联网核心套件 IoT Core 平台后，进行如下操作：
- 在『实例列表』中点击『创建 IoT Core』。
- 填写名称、描述（可选），点击『提交』。
当看见创建的 IoT Core 实例处于『运行中』即为创建成功，如下图所示。
4.2 添加模版
基于 4.1，点击所创建的『IoT Core 实例』名字，进入后找到『模版』并点击『添加模版』。
填写『模板名称』，点击『确认』完成添加模版操作，成功之后会在『模版』页显示。
默认创建的模版会有两个主题，详细用途可以点击所创建的『模版名称』进行查看，在里面也可以进行『添加主题』的操作。
注意这个 {deviceName} 是占位符，在后续订阅主题时需自行替换相应的设备名。
4.3 新增设备
基于 4.1，点击所创建的『IoT Core 实例』名字，进入后找到『设备列表』并点击『新增设备』。
依次填写『名称』、『认证方式』、『描述』（可选）、『模版』后，点击『提交』。
- 『认证方式』选择『证书认证』，参考教程：使用证书鉴权建立MQTT连接。
- 『认证方式』选择『密钥认证』，参考教程：通过MQTT连接及收发消息。
- 再次提醒这个『名称』就是待会要替换 {deviceName} 。
4.4 添加目的地
⚠️ 前提你的百度云账号下开启了『百度消息服务 BMS，即消息服务 for Kafka』，以及创建了『主题』（ 仅支持广州区）。
在进入『百度消息服务 BMS，即消息服务 for Kafka』平台后，点击『证书』，如果还未创建，先进行『创建证书』（权限根据自己情况自行选择），创建后点击『密钥』那一栏的内容进行下载密钥文件（用于后续的『添加目的地』操作）。
回到 IoT Core 实例，依次点击『数据目的地』、『添加目的地』进行添加用户 kafka 操作。
把下载好的密钥文件进行『解压』操作，如下图填写好对应的信息，点击『提交』即可完成『添加目的地』操作。
『提交』后可以点击『连通测试』看看是否配置成功。
4.5 创建规则
点击『规则引擎』下的『规则列表』，若还未创建规则，请先点击『创建规则』进行创建。
创建完成后点击『编辑调试』去配置让 IoT Core 平台通过规则引擎把设备数据流转到用户下的 kafka 中去。
下面的『查询语句』填写 $ 即可，表示规则引擎这边不进行格式转换，直接把原格式数据流转到用户下的 kafka 中。
『保存』好之后，点击『启用』规则。
4.6 测试
至此我们已经完成所有的配置操作，我们来测试以下数据流向是否为：物理设备 --> IoT Core --> 规则引擎 --> 用户 Kafka。
这里我们还是通过 MQTT 模拟器 MQTT.fx 来进行演示，使用教程参考：使用 MQTT 模拟器连接及收发消息。
点击 kafka 主题，看到监控确实有数据写入，配置成功！
