开发者学堂课程【阿里云 AIoT 物联网开发实战:AloT 物联网开发实战02】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/328/detail/3695
AloT 物联网开发实战02 (四)
6、表格存储
通过规则引擎的方式,把设备上报的温度和湿度流转到阿里云上的表格存储数据库,表格存储是一个 Kv 型的数据库,类似 mango tb。
配置的过程首先要到物联网平台控制台的规则引擎创建一条云产品的流转,会先做数据处理,抽取出 device name 一个时间戳以及一个 location 的标签,还有当前的温度值和湿度值。最终存放的目的地是表格存储的实例。
表格存储实例,表格存储数据库
只需要创建主键就可以,主键为 devicename 和时间戳,剩下的列自动扩展。
当前数据库没有数据。
来到物联网平台规则引擎创建一条规则。
Sql 的编写是需要抽取的一些字段,通过提供的 sql 函数来取得的数据。
数据上报物模型里面的时间戳,物模型上报的温湿度值。
Topic 类型选择物模型的数据上报,针对产品下面的全部数据做数据流转,流转的 topic 选择属性上报,条件没有添加全量设备的属性上报进行流转。
目的地的处理,很多目的地选择,选择表格存储是在华东一,意味着数据会从华东二的上海流转到华东一的杭州,是跨 region 的数据流转。做了一个字段的映射,把前面缩口处理的结果里边的 key device name 里 key 映射到主键 device name 上,时间戳映射到 time上,同时做 LT ,数据流转到表格存储需要授权,LT 访问表格存储的权限。
创建编辑完之后,规则处于运行中设备上报的数据就会实时的流转到表格存储中。设备为离线,没有上报数据。
物联网平台的控制台有运维监控,下面有设备模拟器,可以模拟设备,在没有真实设备的情况下,可以模拟设备来进行联调工作。
启动设备模拟器,设备已经上线,发送 connect 的请求,云端返回 connedk 是成功的。定义物模型有温度和湿度值,设置26.5的温度,68的湿度。
上报发送指令,设备端会向云平台发送一条指令。
设备当前的状态,设备模拟器启动之后设备在线,设备的数据68、26.5。
再调整一下,27.2、71,再模拟上报一次,打开实时刷新。
来到日志服务看数据流转,进入日志服务
以 trace ID 做追踪。
trace ID 做一下追踪,就是设备云端发了一条消息,模型的属性,同样云端也给设备回复了一个 reply,说说明云端已经收到这条模型的属性上。在云端会对数据做物模型校验,校验成功之后会做存储。还触发了一条规则引擎的操作,把数据流转到对应的表格存储里,存储到实例下面的表格里,这是一个完整的从设备端到云平台再到数据库的流转过程。
来数据库里查看一下有没有数据,看到设备有两条数据上报。有上报的温度值、湿度,设备所在的位置是客厅,客厅是通过设备本身的标签来抽取出来的,有上报的一个时。
可以再模拟数据
又模拟设备的上报,数据库里会有实时的更新。
完整的演示设备数据的流转最终落到数据库里,后续的业务系统可以直接从数据库里来读取数据,或者做一些业务的处理。