Flux Union语法

2022-08-25 15:02:36 阅读：265 来源： 互联网

标签：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. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Flux Union语法