12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576 |
- 创建数据库:
- create database lanpengdb duration 10 buffer 16 wal_level 1 PRECISION 'ns';
- 设备类型:CCD、温度、风压、...
- 超级表创建分类依据:CCD、Temperature、Pressure
- 采集到的数据根据设备类型将数据存储到对应类型的表中。
- 超级表下按照对每个设备单独建子表
- 对每个子表建发布主题
- ccd表
- 创建ccd的沿值表,初始8个沿值
- create stable data_ccd(ts timestamp,frame_no int, edge1 int,edge2 int,edge3 int,edge4 int,edge5 int, edge6 int,edge7 int ,edge8 int) tags(server_id int,node_d int);
- 子表名:data_ccd_{server_id)_{node_id}
- node_id为设备的id
- 添加设备后创建子表:
- //insert into data_ccd_1_1 using data_ccd tags(1,1) (ts, frame_no,edge1) values(now,1234,1000);
- 温度表
- 创建温度表
- create stable data_temperature (ts timestamp, temperature float) tags(server_id int,node_id int);
- //create table data_temperature (ts timestamp, server_id int,node_id int,temperature float);
- //insert into data_temperature_1_1 using data_temperature tags(1,1) values(now,100);
- create table data_temperature_{1}_{1} using data_temperature tags({1},{1});
- 风压表
- 创建风压表
- create stable data_pressure (ts timestamp, pressure float) tags(server_id int,node_id int);
- create table data_pressure (ts timestamp, server_id int,node_id int,pressure float);
- insert into data_pressure_1_1 using data_pressure tags(1,1) values(now,100);
- 净化
- 订阅指定设备的指定数据相关的主题
- 为已生效方案,建立净化超级表,子表
- 表结构与
- 临时方案(含已生效方案):
- 不存储,为每个方案建立发布主题,供页面对比使用
- 算法:
- 告警:
- 建立MySql告警表,并推送到mqtt,主题是AlarmData
- 码流:
- 前端
- 采集数据表
- 每个设备建立一个表。
- 表名规则:data_{device_id}_{ver}
- 列名:ts timestamp 必须有且必须名为ts
- frame_no int 如果有则名为frame_no
- 其他列:各属性的code
- 如果添加、删除、修改过属性,则升版本号新建表
- 建发布主题
- 净化、算法数据表
- 每个方案或节点建立一个表。
- 表名规则:data_{node_id}_{ver}
- 列名:ts timestamp 必须有且必须名为ts
- frame_no int 如果有则名为frame_no
- 其他列:各属性的code
- 如果添加、删除、修改过属性,则升版本号新建表
- 建发布主题
|