如何将两个表的_value合并到一个表中？

发布于 2025-01-14 20:58:46 字数 641 浏览 2 评论 0原文

我正在尝试创建一个仪表板，可以在其中按加油站位置和燃料类型过滤数据。这是我的查询表：

from(bucket: "homeassistant")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["entity_id"] == "tankerkoenig_aral_tankstelle_bat_waldmohr_e5")
  |> filter(fn: (r) => r["_field"] == "city_str" or r["_field"] == "value")
  |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
  |> yield(name: "last")

flux 数据库

我怎样才能获得 _field "city_str 的 _value " 和 _field "value" 的 _value 放入一张表中，以便我可以在 grafana 中同时查询位置和价格？

原文

I'm trying to create a dashboard where i can filter data by gas station location and fuel type.
This is my Table from this query:

from(bucket: "homeassistant")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["entity_id"] == "tankerkoenig_aral_tankstelle_bat_waldmohr_e5")
  |> filter(fn: (r) => r["_field"] == "city_str" or r["_field"] == "value")
  |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
  |> yield(name: "last")

flux database

How can i get the _value of _field "city_str" and the _value of the _field "value" into one table so i can query the location and the price at the same time within grafana?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

維他命╮ 2025-01-21 20:58:46

使用 schema.fieldsAsCols 函数。您将得到一张包含 city_str 和 value 列的表。

import "influxdata/influxdb/schema"

from(bucket: "homeassistant")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["entity_id"] == "tankerkoenig_aral_tankstelle_bat_waldmohr_e5")
  |> filter(fn: (r) => r["_field"] == "city_str" or r["_field"] == "value")
  |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
  |> schema.fieldsAsCols()
  |> yield(name: "last")

Use schema.fieldsAsCols function. You will get one table with city_str and value columns.

import "influxdata/influxdb/schema"

from(bucket: "homeassistant")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["entity_id"] == "tankerkoenig_aral_tankstelle_bat_waldmohr_e5")
  |> filter(fn: (r) => r["_field"] == "city_str" or r["_field"] == "value")
  |> aggregateWindow(every: v.windowPeriod, fn: last, createEmpty: false)
  |> schema.fieldsAsCols()
  |> yield(name: "last")

回复收藏 0 原文

~没有更多了~