Grafana - aggregierte Werte addieren und subtrahieren

Marc Berg

habe ich mich noch nicht mit beschäftigen müssen. Ist auch eher ein Grafana Thema, da benutze ich nur das Nötigste.

bitwicht

Ich habe noch einiges erweitert und möchte zwei monatswerte subtrahieren.

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

Z1=
from(bucket: "iobroker")
  |> range(start: -15d)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Haus")
  |> filter(fn: (r) => r["_field"] == "value")
  |> difference()
  |> aggregateWindow(every: 1d, fn: sum, createEmpty: false)
  |> keep(columns: ["_value", "_time"])
 
  Z2=
from(bucket: "iobroker")
  |> range(start: -15d)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Garten")
  |> filter(fn: (r) => r["_field"] == "value")
  |> difference()
  |> aggregateWindow(every: 1d, fn: sum, createEmpty: false)
  |> keep(columns: ["_value", "_time"])

 join(tables: {Z1 : Z1, Z2 : Z2}, on: ["_time"])
// |> map(fn: (r) => ({_time: r._time, _Erg:r._value_Z1 - r._value_Z2}))
  |>map(fn: (r) => ({_time: r._time, Z1: r._value_Z1, Z2: r._value_Z2, Summe: r._value_Z1-r._value_Z2}))

Was ich nicht verstehe, der Wert Wasserzaehler-CAM-Haus müsste doch gleich dem Wert Z1 sein und Wasserzaehler-CAM-Garten müsste doch gleich wer Z2 sein.

In der Grafik sind die Werte aber unterschiedlich:

Beispiel 12.07
Wasserzaehler-CAM-Haus 1,73
Z1 1,46

Warum ist das so ?!

Marc Berg

@bitwicht
Schwer zu sagen, ohne die Daten zu haben. Was mich nur wundert: in deiner Query stehen 3 Spalten, im Diagramm aber 5!?

bitwicht

@Marc-Berg

Die 5 ist einfach zu erklären.
Ich habe 3 Querys:

Query 1 und 2 sind die einzelnen Werte - die sollten passen:

Query1:

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

from(bucket: "iobroker")
  |> range(start: -15d)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Haus" and r["_field"] == "value" )
  |> difference()
  |> aggregateWindow(every: 1d, fn: sum, timeSrc: "_start")

Query2:

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

from(bucket: "iobroker")
  |> range(start: -15d)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Garten" and r["_field"] == "value" )
  |> difference()
  |> aggregateWindow(every: 1d, fn: sum, timeSrc: "_start")

Im Query 3 habe ich dann die Berechnung versucht und bin über die unterschiedlichen Werte gestolpert.

Ich glaube ich habe was gefunden:
Wasserzaehler-CAM-Haus müsste doch gleich dem Wert Z1 aber es ist Wasserzaehler-CAM-Haus müsste doch gleich dem Wert Z1 + 1 Tag

Also Z1 ist anscheinend um +1 Tag versetzt.

Warum das so ist verstehe ich nicht. Ich dachte durch Timezone haben alle den gleichen Stand.

bitwicht

Ich habe dazu noch mal eine Fragen.

In Board 1 lasse ich mir einfach die Monate von zwei Datenpunkten ausgeben, in zwei Querrys. Die Monate passen auch.

in Board2 möchte die Monate von den zwei Datenpunkten Subtrahieren. Hier sind die Monate um einen Monat verschoeben.

Warum ist das so?

Board1:

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

from(bucket: "iobroker")
  |> range(start: -1y)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Haus" and r["_field"] == "value" )
  |> difference()
  |> aggregateWindow(every: 1mo, fn: sum, timeSrc: "_start")

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

from(bucket: "iobroker")
  |> range(start: -1y)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Garten" and r["_field"] == "value" )
  |> difference()
  |> aggregateWindow(every: 1mo, fn: sum, timeSrc: "_start")

Board2:

import "timezone"
option location = timezone.location(name: "Europe/Berlin")

Z1=
from(bucket: "iobroker")
  |> range(start: -1y)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Haus")
  |> filter(fn: (r) => r["_field"] == "value")
  |> difference()
  |> aggregateWindow(every: 1mo, fn: sum, createEmpty: false)
  |> keep(columns: ["_value", "_time"])
 
  Z2=
from(bucket: "iobroker")
  |> range(start: -1y)
  |> filter(fn: (r) => r["_measurement"] == "Wasserzaehler-CAM-Garten")
  |> filter(fn: (r) => r["_field"] == "value")
  |> difference()
  |> aggregateWindow(every: 1mo, fn: sum, createEmpty: false)

  join(tables: {Z1: Z1, Z2: Z2}, on: ["_time"])
  |>map(fn: (r) => ({_time: r._time, Wasser_Haus: r._value_Z1-r._value_Z2, Wasser_Garten: r._value_Z2}))

bitwicht

@Marc-Berg

Siehst du hier auch meinen Fehler, bzw. brauchst du vom Influx Explorer die Raw Daten?

Marc Berg

@bitwicht sagte in Grafana - aggregierte Werte addieren und subtrahieren:

Siehst du hier auch meinen Fehler, bzw. brauchst du vom Influx Explorer die Raw Daten?

Kipp mal alles hier rein, was du so hast. Schaue ich mir morgen an.

Marc Berg

@bitwicht

Mit der aggregateWindow Funktion werden bestimmte Zeiträume zusammengefasst und die Einzelwerte in diesem Zeitraum mit der Funktion fn: xyz bearbeitet. Ein aggregierter Monat bildet dann ein Zeitfenster von beispielsweise

01.12.2023 00:00 Uhr bis 01.01.2024 00:00 Uhr (lokale Zeit)

In der Standardeinstellung bekommt das aggregierte Ergebnis den Zeitstempel, der das Ende des Zeitraums repräsentiert. Hier also der 01.01. 0 Uhr. Um das zu verändern, musst du ein , timeSrc: "_start" an die Funktion in Z1 und Z2 anhängen:

|> aggregateWindow(every: 1mo, fn: sum, createEmpty: false, timeSrc: "_start")

bitwicht

@Marc Berg

Danke, passt. Habe schon alles angepasst.

alex303

Hallo zusammen,

nachdem ich nun ein Dashboard über meinen Wechselrichter erstellt habe, möchte ich den Leistungsbedarf ermitteln.

Mit der Hilfe von chatGPT habe ich folgendes Skript bekommen:

SELECT 
  SUM("AC_Leistung" + "PV_Einspeisewirkleistung") - 
  SUM("Wirkleistung_P+_tot(W)") - 
  SUM("Wirkleistung_P-_tot(W)") AS "Leistungsbedarf"
FROM 
   ( 
    SELECT "AC_Gesamtstrom" FROM "Wechselrichter_Fronius" 
    UNION ALL 
    SELECT "PV_Einspeisewirkleistung" FROM "Wechselrichter" 
    UNION ALL 
    SELECT "Wirkleistung_P+_tot(W)" FROM "Strom" 
    UNION ALL 
    SELECT "Wirkleistung_P-_tot(W)" FROM "Strom" 
  )
WHERE 
  $timeFilter
GROUP BY 
  time($__interval)

Das funktionier nur nicht.
In Grafana kommt folgende Fehlermeldung:

Status: 500. Message: InfluxDB returned error:

Wo könnte hier der Fehler liegen?

alex303

@alex303
Dieses Skript habe ich von Influx kopiert und in Grafana eingefügt.

 |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "Strom")
  |> filter(fn: (r) => r["_field"] == "Wirkleistung_P+_tot(W)")
  |> aggregateWindow(every: v.windowPeriod, fn: mean, createEmpty: false)
  |> yield(name: "mean")

Funktioniert auch nicht.

Hat keiner eine Idee was hier falsch ist?

mickemup

@alex303
Du musst Grafana schon noch mittteilen von welchem Bucket die Daten geholt werden sollen, sonst wird es schwierig...

Als erste Zeile müsste sowas hin:

from(bucket: "DEINBUCKETNAME")

Hast du in Grafana übehaupt Influx schon hinzugefügt?
https://docs.influxdata.com/influxdb/v2/tools/grafana/

alex303

@mickemup said in Grafana - aggregierte Werte addieren und subtrahieren:

Hast du in Grafana übehaupt Influx schon hinzugefügt?
https://docs.influxdata.com/influxdb/v2/tools/grafana/

In den Einstellungen von Grafana hatte ich Query language auf InfluxQL stehen.
Nachdem ich auf Flux umgestellt habe funktioniert auch das einfügen von Influx.
Jetzt sind die Dashboards umgeschrieben die ich hatte.

Nun zu meinem ursprünglichen Problem:
Anzeigen möchte ich die verbrauchte Leistung P-Verbrauch

P-Verbrauch = P-Fronius + P-SMA + P-Bezug - P-Lieferung

P-Fronius = measurement Wechselrichter_Fronius
P-SMA = measurement Wechselrichter_SMA
P-Bezug = measurement Strom
P-Lieferung = measurement Strom

Wie soll hierfür das Script aussehen?

mickemup

@alex303
Zeig mal einer deinen einzelnen Queries:

P-Verbrauch kannst du ganz einfach mit einer Expression erhalten.

Dort einfach deine Gleichung eintragen mit den passenden Buchstaben: $A + $B +$C -$D

Falls diese so sind:
A P-Fronius = measurement Wechselrichter_Fronius
B P-SMA = measurement Wechselrichter_SMA
C P-Bezug = measurement Strom
D P-Lieferung = measurement Strom

alex303

@mickemup said in Grafana - aggregierte Werte addieren und subtrahieren:

@alex303
Zeig mal einer deinen einzelnen Queries:

mickemup

@alex303 und klappts?
Eventuell muss man noch was an aggregate window schrauben...

alex303

@mickemup said in Grafana - aggregierte Werte addieren und subtrahieren:

@alex303
Zeig mal einer deinen einzelnen Queries:

P-Verbrauch kannst du ganz einfach mit einer Expression erhalten.

Dort einfach deine Gleichung eintragen mit den passenden Buchstaben: $A + $B +$C -$D

Falls diese so sind:
A P-Fronius = measurement Wechselrichter_Fronius
B P-SMA = measurement Wechselrichter_SMA
C P-Bezug = measurement Strom
D P-Lieferung = measurement Strom

Ich weis nicht wo ich das einstellen kann.

mickemup

@alex303
direkt unter den Queries

+Expression

alex303

@mickemup
Hallo,
ich wieder mal an meinen Grafen am arbeiten, und bin auf ein Problem gestoßen.
Sobald ich die Formel unter Expression einfüge ändern sich die Namen der einzelnen Werte.
Normalerweise setzt sich der Name aus "field" und "Tag value" zusammen.
Mit der Formel setzt sich der Name aus "measurement", "measurement" und "Tag value" zusammen.

Nun kann ich z.B. den Namen mit Override nicht mehr ändern da es in meinem Fall "Strom Strom 1" zweimal gibt.

Was kann man hier tun?

mickemup

@alex303
Hm bei mir gehen Overrides problemlos auch bei Expression.

Wie sieht den dein Dropdown aus bei:

Overrides : Field with name

Community Forum

NEWS

Grafana - aggregierte Werte addieren und subtrahieren

Support us

618

32.7k

82.5k

1.3m