sql.txt 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. 创建数据库:
  2. create database lanpengdb duration 10 buffer 16 wal_level 1 PRECISION 'ns';
  3. 设备类型:CCD、温度、风压、...
  4. 超级表创建分类依据:CCD、Temperature、Pressure
  5. 采集到的数据根据设备类型将数据存储到对应类型的表中。
  6. 超级表下按照对每个设备单独建子表
  7. 对每个子表建发布主题
  8. ccd表
  9. 创建ccd的沿值表,初始8个沿值
  10. 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);
  11. 子表名:data_ccd_{server_id)_{node_id}
  12. node_id为设备的id
  13. 添加设备后创建子表:
  14. //insert into data_ccd_1_1 using data_ccd tags(1,1) (ts, frame_no,edge1) values(now,1234,1000);
  15. 温度表
  16. 创建温度表
  17. create stable data_temperature (ts timestamp, temperature float) tags(server_id int,node_id int);
  18. //create table data_temperature (ts timestamp, server_id int,node_id int,temperature float);
  19. //insert into data_temperature_1_1 using data_temperature tags(1,1) values(now,100);
  20. create table data_temperature_{1}_{1} using data_temperature tags({1},{1});
  21. 风压表
  22. 创建风压表
  23. create stable data_pressure (ts timestamp, pressure float) tags(server_id int,node_id int);
  24. create table data_pressure (ts timestamp, server_id int,node_id int,pressure float);
  25. insert into data_pressure_1_1 using data_pressure tags(1,1) values(now,100);
  26. 净化
  27. 订阅指定设备的指定数据相关的主题
  28. 为已生效方案,建立净化超级表,子表
  29. 表结构与
  30. 临时方案(含已生效方案):
  31. 不存储,为每个方案建立发布主题,供页面对比使用
  32. 算法:
  33. 告警:
  34. 建立MySql告警表,并推送到mqtt,主题是AlarmData
  35. 码流:
  36. 前端
  37. 采集数据表
  38. 每个设备建立一个表。
  39. 表名规则:data_{device_id}_{ver}
  40. 列名:ts timestamp 必须有且必须名为ts
  41. frame_no int 如果有则名为frame_no
  42. 其他列:各属性的code
  43. 如果添加、删除、修改过属性,则升版本号新建表
  44. 建发布主题
  45. 净化、算法数据表
  46. 每个方案或节点建立一个表。
  47. 表名规则:data_{node_id}_{ver}
  48. 列名:ts timestamp 必须有且必须名为ts
  49. frame_no int 如果有则名为frame_no
  50. 其他列:各属性的code
  51. 如果添加、删除、修改过属性,则升版本号新建表
  52. 建发布主题