数据转发至MongoDB存储

场景说明

对于平台的流转数据可以选择让平台将设备上报数据转发给文档数据库服务（DDS），由DDS进行存储（华为云DDS完全兼容MongoDB协议），用户无需做额外的数据存储代码开发即可使用设备数据进行业务处理。本示例为将流转数据转发至文档数据库服务存储。

购买MongoDB实例

1. 登录华为云官方网站，访问文档数据库服务DDS。
2. 单击“进入控制台”进入文档数据库服务管理控制台。
3. 单击右上角“购买数据库实例”，根据需求选择实例规格与配置安全组后，单击“立即购买”。
   图1 购买MongoDB实例

   

配置设备接入服务

在设备接入服务中创建产品模型、注册设备并设置数据转发规则，实现当设备上报数据时将数据转发至MongoDB。

1. 访问设备接入服务，单击“管理控制台”进入设备接入控制台。
2. 选择左侧导航栏的“产品”，单击创建产品，选择新建产品所属的资源空间。
   

   本文中使用的产品模型和设备仅为示例，您可以使用自己的产品模型和设备进行操作。

3. 单击“创建产品”，创建一个基于MQTT协议的产品，填写参数后，单击“确认”。

   基本信息
   所属资源空间	选择资源空间
   产品名称	自定义，如MQTT_Device
   协议类型	选择“MQTT”
   数据格式	选择“JSON”
   所属行业	根据实际情况进行填写。
   设备类型
   所属子行业

4. 下载文件，获取产品模型文件样例。
5. 在模型定义页面，单击“上传模型文件”，在弹出的页面中加载产品模型文件，然后单击“确认”。
   图2 上传模型文件
   

6. 选择左侧导航栏的“设备 > 所有设备”，单击“注册设备”，填写设备注册参数，完成后单击“确定”，请注意保存注册成功返回的“设备ID”和“设备密钥”。
   图3 创建设备

   

   参数名称	说明
   所属资源空间	选择3中创建的产品所在的资源空间
   所属产品	选择3中创建的产品。
   设备标识码	即node_id，填写为设备的IMEI、MAC地址或Serial No；若没有真实设备，填写自定义字符串，由英文字母和数字组成。
   设备名称	自定义。
   设备ID	自定义，可不填，平台会自动生成一个设备ID
   设备认证类型	选择“密钥”。
   密钥	设备密钥，可自定义，不填写物联网平台会自动生成。

7. 选择左侧导航栏的“规则>数据转发”，单击左上角的“创建规则”。
   

   您也可以基于已经创建的规则，在规则详情页面，添加新的转发目标MongoDB。

8. 参考下表参数说明，填写规则内容。以下参数取值仅为示例，您可参考数据转发简介填写具体的流转规则参数，填写完成后单击“创建规则”。

   参数名	参数说明
   规则名称	自定义，如iotda-mongodb。
   规则描述	自定义，如数据转发至MongoDB存储。
   数据来源	选择“设备属性”。
   触发事件	自动匹配“设备属性上报”。
   资源空间	选择转发的数据来源所属的资源空间，或者所有资源空间。

9. 单击“设置转发目标”页签，单击“添加”，设置转发目标。

   参数名	参数说明
   转发目标	选择“MongoDB数据库”
   数据库实例地址	填写数据库实例的连接IP（或域名）和端口。
   数据库名称	填写数据库实例中转发目标数据库名称。
   访问账户	填写数据库实例的账户。
   访问密码	填写数据库实例的密码。
   SSL	选择是否通过SSL加密方式连接数据库。推荐使用SSL方式连接，不开启SSL方式连接可能存在数据传输安全风险。选择通过SSL方式连接时，需要先在数据库实例中设置SSL数据加密。

10. 单击“下一步：转发数据配置”，此过程会连接数据库。
11. 填写转存集合，配置流转数据和数据库集合的映射关系，若集合不存在则会自动创建。
    • 转发字段：流转数据的json key。
    • 目标存储字段：数据库集合的字段，选择目标存储字段后自动匹配字段类型。
    图4 创建数据转发目标
    

12. 单击“启动规则”，激活配置好的数据转发规则。

验证操作

触发规则数据来源的事件，比如设备属性上报。

• 您可以使用配置设备接入服务时注册的真实设备接入平台，上报任意数据。
• 您也可以使用模拟器模拟设备上报数据，操作方法请参考在线开发MQTT协议的智慧路灯。

期望结果：

登录MongoDB管理控制台，打开目标表格，可以查看到表格目标字段转存的数据。

图5 查询数据上报信息