凡客诚品商城,企业网站快速优化排名,海口网站建设公司哪家好,网站建设 重庆Influxdb将表格数据多个字段_field从垂直列布局聚合成水平布局行字段。
问题
1、Influxdb 是一种时间序列数据库#xff0c;在我的项目中主要用来存储换热站的测点数据的。换热站有非常多的测点#xff0c;我们用Flux 语法去查询测点数据#xff0c;返回的数据结构是每个测…Influxdb将表格数据多个字段_field从垂直列布局聚合成水平布局行字段。
问题
1、Influxdb 是一种时间序列数据库在我的项目中主要用来存储换热站的测点数据的。换热站有非常多的测点我们用Flux 语法去查询测点数据返回的数据结构是每个测点字段对应的所有时间数据。 from(bucket: autodata)| range(start:2023-04-11T06:34:16.000Z, stop:2023-04-12T06:35:20.000Z)| filter(fn: (r) r._measurement HeatStationData)| filter(fn: (r) r[_field] HuiYuanZhan.1500.TT_17_PV or r[_field] HuiYuanZhan.1500.Level_1_PV or r[_field] HuiYuanZhan.1500.Modbus_FLMeter_5_LLLL) | sort(columns:[ _time], desc: true) | limit(n:10, offset: 1)
2、而我想要的数据格式则是这几个field字段的值作为行字段水平展示并根据时间聚合在一起形成一条根据时间的完整数据。也就是我想查询多个字段同一时间的值组成一条数据。
解决方法
Flux 查询提供了两种方式来解决这个问题
1、 pivot(rowKey:[_time], columnKey: [_field], valueColumn: _value)
使用pivot将_field的_value值,作为一个行字段。这样就可以查询同一时间这三个字段的值了
from(bucket: autodata)| range(start:2023-04-11T06:34:16.000Z, stop:2023-04-12T06:35:20.000Z)| filter(fn: (r) r._measurement HeatStationData)| filter(fn: (r) r[_field] HuiYuanZhan.1500.TT_17_PV or r[_field] HuiYuanZhan.1500.Level_1_PV or r[_field] HuiYuanZhan.1500.Modbus_FLMeter_5_LLLL) | pivot(rowKey:[_time], columnKey: [_field], valueColumn: _value)| sort(columns:[ _time], desc: true) | limit(n:10, offset: 1) 2、v1.fieldsAsCols()
这是一个Flux 查询提供的函数使用时需要先引入他的功能跟上边的pivot效果是一样的。 import influxdata/influxdb/v1from(bucket: autodata)| range(start:2023-04-11T06:34:16.000Z, stop:2023-04-12T06:35:20.000Z)| filter(fn: (r) r._measurement HeatStationData)| filter(fn: (r) r[_field] HuiYuanZhan.1500.Modbus_FLMeter_5_LLLL or r[_field] HuiYuanZhan.1500.Level_1_PV or r[_field] HuiYuanZhan.1500.TT_17_PV) | sort(columns:[ _time], desc: true) | v1.fieldsAsCols()
