阿里云物联网平台与数据库
概述
阿里云提供RDS数据库功能 (包含MySQL, MS SQL数据库) ,HMI可以直接连入并存取数据。另外方面,使用阿里云物联网平台,能将HMI所取得的数据,以MQTT方式接入云上,透过规则引擎转发至其他装置,实现数据转发的M2M双向通讯功能。同时也可以直接转发至阿里云RDS数据库,快速且直接将数据导入后台云服务应用。
云数据库RDS版
阿里云关系型数据库(Relational Database Service,简称RDS)是一种稳定可靠、可弹性伸缩的在线数据库服务,并且提供了容灾、备份、恢复、监控、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。威纶通人机支持的MySQL(最受欢迎的开源数据库)、MS SQL Server(大量企业采用的数据库) 都可以在阿里云端上建立运行。
购买实例
数据库为付费服务,需要于阿里云内购买或申请RDS数据库实例。购买方式与套餐费用请参考阿里云的说明文档。购买实例后,便可以在云数据库RDS列表中看到目前可以运作的数据库资源。
若要实现自物联网平台接入数据直接存取到数据库(规则引擎),数据库实例地域设置必须与物联网平台平台相同,目前仅中国国内仅华东二 (上海)服务器同时支持此两个功能。
实例基础设置
地址管理
进入数据库实例管理页面,于基本信息处,可看到内网地址,表示由阿里云服务连入数据库所用的地址。另外如有从外网连入需求(阿里云服务器之外),例如从HMI写入数据库,就必须激活外网地址;以此外网地址,才能允许由外部连入存取数据库。
创造高权限账号
在账号管理中,建立一个账号,这个账号将拥有此数据库的最高权限。利用此账号,再进入数据库管理其他一般连入用账号。
白名单设置
为保障数据库存取安全,需要在数据安全性设置页中,事先输入允许访问的地址,包含其他阿里云服务。设置说明请参考阿里云文档说明。如果要从HMI/计算机访问,则需要将该HMI/计算机的外网IP加入此白名单中。
登录数据库
使用“登录数据库” 按钮,可开启阿里云提供的数据库管理工具(DMS)。第一次先使用以上创建的高权限账号登入。以高权限账号登入后,可以在DMS中创造管理其他账户。尔后便可以使用其他客户端软件程序(Workbench, DBMS)连入数据库,或是使用HMI连入。
HMI连入
如果有远程直接存取的需求。(例如:直接用HMI,或是PC端DBMS系统连入阿里云数据库) 请务必启用外网地址,并且将IP地址加入白名单。
管理数据库
要管理数据库内容数据,数据库用户帐户,需要使用高权限账号登录数据库后设置。点选上方登录数据库,即开启阿里云RDS数据库DMS系统登入页面,输入内网地址:端口和高权限账号登入系统。
登入后可见数据库的内容、状态以及操作数据库的功能列表。
物联网平台
物联网平台可使用HMI的MQTT功能连入传送讯息。本章节说明连入阿里云物联网平台的操作步骤。目前区域仅支持 华东二 (上海)区域服务器。
阿里云设置
首先,需在[物联网平台]>>[产品管理]中创建产品,使用基础版,节点类型=设备,自定义产品名称后,按下确定创建产品。
进入[设备管理]中,由下拉选单中选择上一步创建的产品,并进入添加设备步骤。添加完成后会提示此设备的ProductKey, DeviceName, DeviceSecret,记下这些数据以作为后续MQTT连入的使用参数。回到设备列表中可以观看设备连入的状态。
物联网平台上的设备即表示一台设备数据的接入点,因此在此要为每一台HMI在云上添加一个对应设备,直到所有要上传数据的人机在物联网平台上都有对应设备为止。
查看设备详情的页面,可以取得Topic 列表,表示这个设备使用的Topic。Topic名称会包含了ProduceKey, DeviceName。Update表示发布的Topic,由HMI发布到这个Topic,物联网平台就会接收到。
EBPro 设置
EBPro端,将利用MQTT功能连上阿里云,发送数据上阿里云物联网平台。
- MQTT中的Server设置
云端服务 | 一般 |
---|---|
通讯协议 | MQTT v3.1.1 |
域名 | 勾选使用域名。华东二 节点为 [ProductKey].iot-as-mqtt.cn-shanghai.aliyuncs.com |
端口号 | 1883 |
Client ID | [ConnectID]|securemode=3,signmethod=hmacsha1,timestamp=123| [ConnectID]可以是自定义的值。 |
验证 | 要勾选 |
用户名称 | [DeviceName]&[ProductKey] |
密码 | 以sha1算法用以下数据计算出之HMAC 消息: clientId[clientId]deviceName[deviceName] productKey[productKey]timestamp123 密钥:[DeviceSecret] 可提供此计算的一个网站 https://1024tools.com/hmac |
备注:[XXXX] 请连同[]以实际的数值取代,例如: deviceName值是mydevice就是代表 [deviceName]要用mydevice进行取代。
- MQTT Topic设置
原则上,从HMI上传数据是属于发布,即update。因此,在MQTT中设置Topic发布并用完整的topic名为: /[ProductKey]/[deviceName]/update。QoS设置不支援QoS 2。格式建议保持使用JSON,方便后续解析运用。Topic所内含的数据为希望自HMI上传的地址。
建立检查
设计工程文件完成后,使用模拟或是下载到HMI上。正常联机状况下,MQTT状态会显示已连接。
规则引擎
利用规则引擎,可以将消息发送到其他的阿里云服务。例如:
- 发送到另一个Topic。(实现设备到设备间通讯)
- 发送到MQ。MQ是如同MQTT 服务器(MQTT Server)的服务。可以支持标准的一对多Pub/Sub方式发布MQTT消息。关于如何设置MQ可以参考其他说明文檔。
- 发送到RDS。RDS是阿里云上的关系型数据库,支持MySQL, MS SQL等数据库系统。
队列服务
物联网平台只是一个接口工具,实际数据应该转送到云端其他服务,才产生价值。
物联网平台内设备,可以送到阿里云对列服务中。在产品列表 (对创建的产品进行查看),选择服务端订阅,将物联网平台的消息推送到队列中,然后服务端能基于SDK从队列中获取消息实现通信。
MQTT发送到数据库(透过物联网平台)
利用物联网平台的规则引擎发送到阿里云RDS,轻易实现MQTT转存入数据库,大大方便后续分析应用。
数据库设置
数据库的架构必须事先定义,并且数据格式与上送的数据能对应正确。在此使用阿里云的DMS 网页系统操作为范例图。需要建置的设置有:
建立数据库
在DMS中创建数据库即可。确认数据库名,其他一般使用默认的设置。
在数据库中建立表。
“列名”是传送数据进入此数据表的依据。 “类型”设置的数据格式与将来存入的数据也需要正确对应。通常除了传入的数据列外,会另外保留一列,作为唯一索引,设置AUTO INCREMENT (自动增长)以及PRIMAY KEY (主键)。
规则引擎设置
物联网平台中是透过规则引擎将收到的数据根据规则转发。规则引擎设置只要区分两个阶段步骤:处理数据和转发数据。。
处理数据
物联网平台收到数据后,使用数据处理引擎进行比对过滤,决定是否转发此数据以及转 的内容。数据处理引擎使用SQL SELECT语法查询。
使用接口会协助完成SQL语句,仅需依序填入字段,Topic,和条件。
- 字段: 表示希望由消息中取出的数据。支持JSON语法。HMI的MQTT传送消息的JSON格式是如以下的例子,上层为d, ts,实际数据列于d的下一层级。
{
"d" : {
"value1" : [ true ],
"value2" : [ 0 ]
},
"ts" : "2018-07-06T17:58:25.493665"
}
因此字段应输入d.value1, 其中value1为该数据的名称。
- Topic: 表示希望处理的Topic消息。
- 条件: 如有特定条件,于此输入。例如: 希望 value1>10 时,才将处理消息,则输入 d.value>10。
填妥信息后,SQL SELECT语句会自动于上方生成。
转发数据
自上一步处理数据取出需要的数据后,此步骤决定如何转发。在转发数据区块,添加操作,选择存储到云数据库(RDS)中。各项目依照以下填入:
(控制可能需要AliyunIOTAccessingRDSRole授权,请依照阿里云指示提供物联网平台连入RDS的授权)
- RDS实例: 选择开通的RDS实例
- MySQL数据库: 选择在[数据库设置]中建立的数据库。
- 账号/密码:从下拉选单选择账号,并输入该账号的密码。
- 表名: 选择在[数据库设置]中建立的表。
- 键 (key): 表中的列名。
- 值 (value): 要填入的数据的来源。可以填入常数,或是填入上一步骤处理而来的数据。以${value1}表示,表示传入value1的值。可输入多组键值组合。
MQTT发送至数据库检查列表
- 阿里云数据库RDS建置
- 物联网平台的产品与旗下设备建置。使用MQTT上报消息至设备应使用的Topic。
- 启用物联网平台中的规则引擎,确认处理数据的SQL会选择到正确的Topic,转发的数据对应到RDS数据库上正确的栏位。
关于此篇所提及功能之使用限制,请参考官方帮助文檔。