标签:02 Union ThdA PM5350P 语法 Flux tag 2022 id
- drop 、set、rename应该放最语句后端
- join 只能连接两个表
- union 可以并多个表
- pivot 可以做行专列
- filter用or比contains 快N倍
- range显示起止时间可以加快查询速度
t_max = from(bucket: "po")
|> range(start: 2022-02-01T00:00:00Z, stop: 2022-03-01T00:00:00Z)
|> filter(fn: (r) => r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsA" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsB" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsC")
|> set(key: "tag", value: "max")
|> group(columns: ["tag_id_2022-02"])
|> window(every: 1mo)
|> max()
//|> rename(columns: { _value: "max"})
|> drop(columns: ["_time", "_start","_stop","_field","_measurement","table"])
t_min = from(bucket: "po")
|> range(start: 2022-02-01T00:00:00Z, stop: 2022-03-01T00:00:00Z)
|> filter(fn: (r) => r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsA" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsB" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsC")
|> set(key: "tag", value: "min")
|> group(columns: ["tag_id_2022-02"])
|> window(every: 1mo)
|> min()
//|> rename(columns: { _value: "min"})
|> drop(columns: ["_time", "_start","_stop","_field","_measurement","table"])
t_mean = from(bucket: "po")
|> range(start: 2022-02-01T00:00:00Z, stop: 2022-03-01T00:00:00Z)
|> filter(fn: (r) => r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsA" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsB" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsC")
//|> filter(fn: (r) =>contains(value: r["tag_id_2022-01"], set: ["c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsA"]))
|> group(columns: ["tag_id_2022-02"])
|> window(every: 1mo)
|> mean()
|> drop(columns: [ "_start","_stop","_field","_measurement"])
|> set(key: "tag", value: "mean")
t_last = from(bucket: "po")
|> range(start: 2022-02-01T00:00:00Z, stop: 2022-03-01T00:00:00Z)
|> filter(fn: (r) => r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsA" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsB" or r["tag_id_2022-02"] == "c1.H_1AH1_PM5350P_1\\MHAI1\\ThdA\\phsC")
|> set(key: "tag", value: "last")
|> group(columns: ["tag_id_2022-02"])
|> window(every: 1mo)
|> last()
|> drop(columns: ["_time", "_start","_stop","_field","_measurement","table"])
union(tables: [t_max,t_min,t_last,t_mean])
|>pivot(rowKey: ["tag_id_2022-02"], columnKey: ["tag"], valueColumn: "_value")
标签:02,Union,ThdA,PM5350P,语法,Flux,tag,2022,id 来源: https://www.cnblogs.com/wuhailong/p/16624268.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。