创建数据库： 
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
如果添加、删除、修改过属性，则升版本号新建表
建发布主题