MQTT-Telegraf-Influxdb2-Grafana bei 2 OpenDTU und 21 Invertern #1036

spueli99 · 2023-06-14T22:37:31Z

spueli99
Jun 14, 2023

Hallo,

wir betreiben hier 21 Balkonkraftwerke mit HM 600.
Diese werden über 2 OpenDTU abgefragt und die Daten an den mqtt-broker weitergeleitet.
Auf dem Debian 10 Server laufen mqtt, telegraf, influxdb 2 und Grafana.
Die 1. OpenDTU sendet die Daten per mqtt unter dem topic solar/
Soweit funktioniert alles wie beabsichtigt.
Aber, wie bekomme ich nun die Daten von der 2. OpenDTU per telegraf in die Influxdb?

Meine telegraf.conf sieht z. Zt. so aus:

[agent]

  interval = "10s"
  round_interval = true
  flush_interval = "10s"
  omit_hostname = true


 [[outputs.influxdb_v2]]

   urls = ["http://127.0.0.1:8086"]
   token = "GEHEIMES TOKEN"
   organization = "MEINE ORGANIZATION"
   bucket = "MEIN BUCKET"
   timeout = "5s"



[[inputs.mqtt_consumer]]
  name_override = "openDTU"
  servers = ["tcp://127.0.0.1:1883"]

  username = "MEIN USERNAME"
  password = "GEHEIMES PASSWORT"
  topics = [
    "solar/+/status/+",
    "solar/+/0/+",
    "solar/+/1/+",
    "solar/+/2/+"
  ]
  data_format = "value"
  data_type = "float"
  tagexclude = ["host","topic"]
  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar/+/+/+"
    tags = "_/serial/channel/field"
  [[processors.pivot]]
  tag_key = "field"
  value_key = "value"


Totals (AC and DC) per DTU

[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  username = "MEIN USERNAME"
  password = "GEHEIMES PASSWORT"
  persistent_session = false

  tagexclude = ["host","topic"]

 Topics that will be subscribed to.

  topics = [
    "solar/ac/+",
    "solar/dc/+"
  ]
  data_format = "value"
  data_type = "float"

  Measurement name
  name_override = "dtu_totals"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar/+/+"
    tags  = "_/channel/field"

smainz · 2023-06-15T20:07:47Z

smainz
Jun 15, 2023

In der 2.DTU muss ein anderes Basis Topic gesetzt werden, damit man die unterscheiden kann:

Und dann einen zweiten telegraf Prozess starten, der auf dieses Topic hört.

Bei der Konstellation hätte ich gerne eine Test hiervon: https://github.com/smainz/OpenDTU-MQTT-Telegraf-influxdb-integration, ob das mit mehreren DTUs wirklich funktioniert.

8 replies

smainz Jun 17, 2023

Was möchtest Du denn genau erreichen?

Mir war wichtig, auch die DTU-Daten selbst zu haben, aber die liest du ja nicht. Zudem weiß ich genau, was meine zwei DTUs tun und möchte die Werte je DTU genau kennen, d.h. ich muss die unterscheiden können. Wenn es nur um die Summe der Leistung geht, kann man das so lassen, wie du es hast und in Grafana einfach aufsummieren.

Mit den topics:

topics = [
"solar/ac/+",
"solar/dc/+"
]

und gleichem base topic werden die Werte der DTUs gemischt. Wenn Du die Werte je DTU haben möchtest, musst Du zwingend die Werte unterscheiden, d.h. ein unterschiedliches base topic nehmen..

Die Konfiguration könnte dann so aussehen:

[[inputs.mqtt_consumer]]
name_override = "openDTU"
servers = ["tcp://127.0.0.1:1883"]

username = "MEIN USERNAME"
password = "GEHEIMES PASSWORT"
topics = [
"solar/+/status/+",
"solar/+/0/+",
"solar/+/1/+",
"solar/+/2/+",
"solar2/+/status/+",
"solar2/+/0/+",
"solar2/+/1/+",
"solar2/+/2/+"
]
data_format = "value"
data_type = "float"
tagexclude = ["host","topic"]

# So sollen die Topics mit base topic solar geparsed werden:
[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar/+/+/+"
tags = "dtu/serial/channel/field"
[[processors.pivot]]
tag_key = "field"
value_key = "value"

# So sollen die Topics mit base topic solar2 geparsed werden:
[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar2/+/+/+"
tags = "dtu/serial/channel/field"
[[processors.pivot]]
tag_key = "field"
value_key = "value"

# Totals (AC and DC) per DTU

[[inputs.mqtt_consumer]]
servers = ["tcp://127.0.0.1:1883"]
username = "MEIN USERNAME"
password = "GEHEIMES PASSWORT"
persistent_session = false

tagexclude = ["host","topic"]

# Topics that will be subscribed to.

topics = [
"solar/ac/+",
"solar/dc/+"
"solar2/ac/+",
"solar2/dc/+"
]
data_format = "value"
data_type = "float"

Measurement name
name_override = "dtu_totals"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar/+/+"
tags = "dtu/channel/field"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "sola2r/+/+"
tags = "dtu/channel/field"

Ich habe einfach die Anzahl der Topics, auf die gehört wird verdoppelt (solar und solar2) und das base topic als tag dtu mit in das measurement aufgenommen. Für ein paar DTUs funktioniert das ganz gut.

Wenn das die ganze telegraf Konfiguration ist, könnte man das noch vereinfachen zu:

[[inputs.mqtt_consumer]]
name_override = "openDTU"
servers = ["tcp://127.0.0.1:1883"]

username = "MEIN USERNAME"
password = "GEHEIMES PASSWORT"
topics = [
"solar/+/status/+",
"solar/+/0/+",
"solar/+/1/+",
"solar/+/2/+",
"solar2/+/status/+",
"solar2/+/0/+",
"solar2/+/1/+",
"solar2/+/2/+"
]
data_format = "value"
data_type = "float"
tagexclude = ["host","topic"]

# Alle Topics mit 4 Elementen werden so interpretiert
[[inputs.mqtt_consumer.topic_parsing]]
topic = "+/+/+/+"
tags = "dtu/serial/channel/field"
[[processors.pivot]]
tag_key = "field"
value_key = "value"

# Totals (AC and DC) per DTU

[[inputs.mqtt_consumer]]
servers = ["tcp://127.0.0.1:1883"]
username = "MEIN USERNAME"
password = "GEHEIMES PASSWORT"
persistent_session = false

tagexclude = ["host","topic"]

Topics that will be subscribed to.

topics = [
"solar/ac/+",
"solar/dc/+"
"solar2/ac/+",
"solar2/dc/+"
]
data_format = "value"
data_type = "float"

Measurement name
name_override = "dtu_totals"

# Alle Topics mit 3 Elementen werden so interpretiert
[[inputs.mqtt_consumer.topic_parsing]]
topic = "+/+/+"
tags = "dtu/channel/field"

Edit: Die Konfigurationen habe ich nicht getestet, d.h. es sollte funktionieren

spueli99 Jun 17, 2023
Author

Zunächst herzlichen Dank für die Unterstützung.
Meine Ziele sind:

möglichst alle Daten (der DTU`s und der einzelnen Wechselrichter) zu erfassen
dies möglichst mit den "zukünftigen" mqtt-topics umzusetzen

Ich benutze nun die "lange" Version - da blick ich etwas besser durch.
Da ich ja bei 21 Wechselrichtern nicht mit 2 DTU auskomme (max. 10WR je OpenDTU), werde ich die Wechselrichter bald einfach auf 3 DTU aufteilen.
Somit müssten die Intervalle der einzelnen Abfragen ja dann auch etwas kürzer sein.
Vermutlich durch die Änderung des basic topics bei den beiden DTU stimmen die Angaben in den Dashboards nicht.
Ich habe nun eine DTU auf solar1/ und die andere auf solar2/ - vorher standen beide auf solar/.
Zumindest "leben" die Werte und morgen wird ja nichts mehr unter solar/ gefunden und ausgewertet.

DANKE, ich bin schon ein ganzes Stück weiter.

smainz Jun 17, 2023

Die wesentliche Änderung bei den neuen Topics ist ja, dass die Seriennummer der dtu mitgeliefert wird und zusätzlich ein paar Werte dazukommen bzw." tags" umbenannt werden.
Was mir gerade eingefallen ist: statt solr1 und solar2 könntest Du die Seriennummer der DTU verwenden, dann hast Duden richtigen Wert schon drin.

Die alten Werte mit Key solar kann man ja in influxdb per Task migrieren. Nur wenn da schon viele Werte liegen, braucht das einiges an RAM.

spueli99 Jun 19, 2023
Author

Da einige Nachbarn bereits ein Dashboard mit IOT MQTT Panel unter Android nutzen, wäre eine große Änderung des topics mit zusätzlichen Aufwand verbunden. Eine Änderung von solar/ auf solar1/ oder solar2... ist einfacher zu erklären.

Ich hoffe ich habe nun alles "richtig" gemacht...
Fehlt etwas? Könnte ich noch etwas verbessern?

@smainz
Dein Dashboard läuft nun mit der nachfolgenden config.
Dort wird allerdings unter Übersicht-Aktuelle Leistung AC mit "input_per_dtu" gerechnet?
Ist das beabsichtigt? Ich habe das dort auf "output_per_dtu" geändert.
Vielleicht könntest du in einer evtl. überarbeiteten Version die Datenbank als Variable einbauen, dies würde es Neulingen deutlich vereinfachen.
Das Dashboard ist dir sehr gut gelungen - TOP.
Habe ich die Möglichkeit statt der Inverter Serial# dort den in OpenDTU vergebenen Namen anzeigen zulassen?

Mein nächstes Ziel wäre nun daraus für jeden Nachbarn ein eigenes Dashboard nur mit dementsprechenden Wechselrichter zu erstellen.


######################################################################################
# OpenDTU data (string values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false

  tagexclude = ["host","topic"]

  ## Topics that will be subscribed to.
  topics = [
    "solar1/dtu/status",
    "solar1/dtu/ip",
    "solar1/dtu/hostname",
    "solar2/dtu/status",
    "solar2/dtu/ip",
    "solar2/dtu/hostname",
    "solar3/dtu/status",
    "solar3/dtu/ip",
    "solar3/dtu/hostname"
  ]
  data_format = "value"
  data_type = "string"

  # Measurement name
  name_override = "dtu"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar1/dtu/+"
    tags  = "_/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar2/dtu/+"
    tags  = "_/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar3/dtu/+"
    tags  = "_/_/field"


######################################################################################
# OpenDTU data (float values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false

  tagexclude = ["host","topic"]

  ## Topics that will be subscribed to.
  topics = [
    "solar1/dtu/rssi",
    "solar1/dtu/uptime",
    "solar2/dtu/rssi",
    "solar2/dtu/uptime",
    "solar3/dtu/rssi",
    "solar3/dtu/uptime"
  ]
  data_format = "value"
  data_type = "float"

  # Measurement name
  name_override = "dtu"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar1/dtu/+"
    tags  = "_/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar2/dtu/+"
    tags  = "_/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
    topic = "solar3/dtu/+"
    tags  = "_/_/field"


######################################################################################
## Output (AC) per DTU (float values)
######################################################################################
[[inputs.mqtt_consumer]]
servers = [ "$MQTT_URL" ]
username = "$MQTT_USER"
password = "$MQTT_PASSWORD"
persistent_session = false

tagexclude = ["host","topic"]

# Topics that will be subscribed to.

topics = [
"solar1/ac/+",
"solar2/ac/+",
"solar3/ac/+"
]
data_format = "value"
data_type = "float"

# Measurement name
name_override = "output_per_dtu"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar1/+/+"
tags = "dtu/channel/field"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar2/+/+"
tags = "dtu/channel/field"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar3/+/+"
tags = "dtu/channel/field"


######################################################################################
## Input (DC) per DTU (float values)
######################################################################################
[[inputs.mqtt_consumer]]
servers = [ "$MQTT_URL" ]
username = "$MQTT_USER"
password = "$MQTT_PASSWORD"
persistent_session = false

tagexclude = ["host","topic"]

# Topics that will be subscribed to.

topics = [
"solar1/dc/+",
"solar2/dc/+",
"solar3/dc/+"
]
data_format = "value"
data_type = "float"

# Measurement name
name_override = "input_per_dtu"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar1/+/+"
tags = "dtu/channel/field"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar2/+/+"
tags = "dtu/channel/field"

[[inputs.mqtt_consumer.topic_parsing]]
topic = "solar3/+/+"
tags = "dtu/channel/field"


######################################################################################
## Inverter specific topics (string values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false

  topics = [
    "solar1/+/device/+",
    "solar1/+/name",
    "solar2/+/device/+",
    "solar2/+/name",
    "solar3/+/device/+",
    "solar3/+/name"
  ]
  data_format = "value"
  data_type = "string"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "inverter"

  # Set a long interval for this. It does not change often
  interval = "10m"

[[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar1/+/+/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar1/+/name"
  tags  = "_/inverter/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar2/+/+/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar2/+/name"
  tags  = "_/inverter/field"  

[[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar3/+/+/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic = "solar3/+/name"
  tags  = "_/inverter/field"


######################################################################################
## Inverter specific topics (float values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false  

  topics = [
    "solar1/+/status/+",
    "solar1/+/0/temperature",
    "solar2/+/status/+",
    "solar2/+/0/temperature",
    "solar3/+/status/+",
    "solar3/+/0/temperature"
  ]
  data_format = "value"
  data_type = "float"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "inverter"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/status/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/0/+"
  tags  = "_/inverter/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/status/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/0/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/status/+"
  tags  = "_/inverter/_/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/0/+"
  tags  = "_/inverter/_/field"

######################################################################################
## Output (AC) per inverter (float values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false

  topics = [
    "solar1/+/0/current",    
    "solar1/+/0/power",
    "solar1/+/0/yieldday",
    "solar1/+/0/yieldtotal",
    "solar1/+/0/frequency",
    "solar2/+/0/current",    
    "solar2/+/0/power",
    "solar2/+/0/yieldday",
    "solar2/+/0/yieldtotal",
    "solar2/+/0/frequency",
    "solar3/+/0/current",    
    "solar3/+/0/power",
    "solar3/+/0/yieldday",
    "solar3/+/0/yieldtotal",
    "solar3/+/0/frequency"
  ]
  data_format = "value"
  data_type = "float"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "output_per_inverter"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/0/+"
  tags  = "_/inverter/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/0/+"
  tags  = "_/inverter/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/0/+"
  tags  = "_/inverter/_/field"


######################################################################################
## Input (DC) per inverter (float values)
######################################################################################
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false

  topics = [
    "solar1/+/0/powerdc",
    "solar2/+/0/powerdc",
    "solar3/+/0/powerdc"
  ]
  data_format = "value"
  data_type = "float"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "input_per_inverter"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/0/+"
  tags  = "_/inverter/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/0/+"
  tags  = "_/inverter/_/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/0/+"
  tags  = "_/inverter/_/field"


######################################################################################
## Output (AC) values per phase (float values)
######################################################################################    
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false  

  topics = [
    "solar1/+/0/current",
    "solar1/+/0/power",
    "solar1/+/0/powerfactor",
    "solar1/+/0/reactivepower",
    "solar1/+/0/voltage",
    "solar1/+/0/yieldday",
    "solar1/+/0/yieldtotal",
    "solar2/+/0/current",
    "solar2/+/0/power",
    "solar2/+/0/powerfactor",
    "solar2/+/0/reactivepower",
    "solar2/+/0/voltage",
    "solar2/+/0/yieldday",
    "solar2/+/0/yieldtotal",
    "solar3/+/0/current",
    "solar3/+/0/power",
    "solar3/+/0/powerfactor",
    "solar3/+/0/reactivepower",
    "solar3/+/0/voltage",
    "solar3/+/0/yieldday",
    "solar3/+/0/yieldtotal"
  ]
  data_format = "value"
  data_type = "float"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "output"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/0/+"
  tags  = "_/inverter/phase/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/0/+"
  tags  = "_/inverter/phase/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/0/+"
  tags  = "_/inverter/phase/field" 


######################################################################################
## Input (DC) values per string (float values)
######################################################################################    
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false  

  topics = [
    "solar1/+/1/current",
    "solar1/+/1/voltage",    
    "solar1/+/1/power",
    "solar1/+/1/irradiation",
    "solar1/+/1/yieldday",
    "solar1/+/1/yieldtotal",
    "solar1/+/2/current",
    "solar1/+/2/voltage",       
    "solar1/+/2/power",
    "solar1/+/2/irradiation",
    "solar1/+/2/yieldday",
    "solar1/+/2/yieldtotal",
    "solar1/+/3/current",
    "solar1/+/3/voltage",       
    "solar1/+/3/power",
    "solar1/+/3/irradiation",  
    "solar1/+/3/yieldday",
    "solar1/+/3/yieldtotal",  
    "solar1/+/4/current",
    "solar1/+/4/voltage",       
    "solar1/+/4/power",
    "solar1/+/4/irradiation",
    "solar1/+/4/yieldday",
    "solar1/+/4/yieldtotal",
    "solar2/+/1/current",
    "solar2/+/1/voltage",    
    "solar2/+/1/power",
    "solar2/+/1/irradiation",
    "solar2/+/1/yieldday",
    "solar2/+/1/yieldtotal",
    "solar2/+/2/current",
    "solar2/+/2/voltage",       
    "solar2/+/2/power",
    "solar2/+/2/irradiation",
    "solar2/+/2/yieldday",
    "solar2/+/2/yieldtotal",
    "solar2/+/3/current",
    "solar2/+/3/voltage",       
    "solar2/+/3/power",
    "solar2/+/3/irradiation",  
    "solar2/+/3/yieldday",
    "solar2/+/3/yieldtotal",  
    "solar2/+/4/current",
    "solar2/+/4/voltage",       
    "solar2/+/4/power",
    "solar2/+/4/irradiation",
    "solar2/+/4/yieldday",
    "solar2/+/4/yieldtotal",
    "solar3/+/1/current",
    "solar3/+/1/voltage",    
    "solar3/+/1/power",
    "solar3/+/1/irradiation",
    "solar3/+/1/yieldday",
    "solar3/+/1/yieldtotal",
    "solar3/+/2/current",
    "solar3/+/2/voltage",       
    "solar3/+/2/power",
    "solar3/+/2/irradiation",
    "solar3/+/2/yieldday",
    "solar3/+/2/yieldtotal",
    "solar3/+/3/current",
    "solar3/+/3/voltage",       
    "solar3/+/3/power",
    "solar3/+/3/irradiation",  
    "solar3/+/3/yieldday",
    "solar3/+/3/yieldtotal",  
    "solar3/+/4/current",
    "solar3/+/4/voltage",       
    "solar3/+/4/power",
    "solar3/+/4/irradiation",
    "solar3/+/4/yieldday",
    "solar3/+/4/yieldtotal"
  ]
  data_format = "value"
  data_type = "float"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "input"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/+/+"
  tags  = "_/inverter/string/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/+/+"
  tags  = "_/inverter/string/field"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/+/+"
  tags  = "_/inverter/string/field"


######################################################################################
## Input (DC) values per string (string values)
######################################################################################    
[[inputs.mqtt_consumer]]
  servers = [ "$MQTT_URL" ]
  username = "$MQTT_USER"
  password = "$MQTT_PASSWORD"
  persistent_session = false  

 # The AC output does not have a name in the current OpenDTU, so wie can subscribe to all "channels"
  topics = [
    "solar1/+/+/name",
    "solar2/+/+/name",
    "solar3/+/+/name"   
  ]
  data_format = "value"
  data_type = "string"

  tagexclude = ["host","topic"]

  # Measurement name
  name_override = "input"

[[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar1/+/+/+"
  tags  = "_/inverter/string/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/+/+"
  tags  = "_/inverter/string/field"

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar3/+/+/+"
  tags  = "_/inverter/string/field"


######################################################################################
## Processors to convert current topics to future topic structure
###################################################################################### 

[[processors.regex]]
  namepass = ["input_per_inverter"]

    # Replace tag "field" with value 'power' for field "powerdc"
    [[processors.regex.tags]]
      ## Tag to change, "*" will change every tag
      key = "field"
      pattern = "^powerdc$"
      replacement = "power"       

[[processors.regex]]
  namepass = ["output"]    

    # Change tag 'phase' to value '1' if 'phase' is 0
    [[processors.regex.tags]]
      key = "phase"
      pattern = "^0$"
      replacement = "1"   

[[processors.pivot]]
  order = 99
  tag_key = "field"
  value_key = "value"

smainz Jun 21, 2023

Ich würde auch bei den Inverter-spezifischen Topics die dtu (solar1, solar2, ...) mit auslesen. Dazu müssen die Zeilen der Art

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/+/+"
  tags  = "_/inverter/string/field"

so geändert werden:

  [[inputs.mqtt_consumer.topic_parsing]]
  topic =  "solar2/+/+/+"
  tags  = "dtu/inverter/string/field"

Also einfach bei tags den ersten Unterstrich durch dtu ersetzen.

Das mit den input_per_dtu für AC Leistung ist Quatsch und müsste output_per_dtu heißen. Ich mache da heute im Laufe des Tages eine Korrektur.
Mit "die Datenbank als Variable einbauen" meinst Du den Bucket, aus dem die Daten gelesen werden z.B. solar/actual oder weather? Das sollte möglich sein.

Namen Anzeigen wünsche ich mir auch, aber bisher ist es an mangelnden Influxdb flux Kenntnissen gescheitert. Wenn ich die Zeit finde, mich da tiefer einzuarbeiten kommt das.

Bevor das hier komplett off-topic wird, mach lieber eine Issue im Repo auf.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

MQTT-Telegraf-Influxdb2-Grafana bei 2 OpenDTU und 21 Invertern #1036

{{title}}

{{editor}}'s edit

{{editor}}'s edit

Replies: 1 comment 8 replies

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{title}}

Select a reply

MQTT-Telegraf-Influxdb2-Grafana bei 2 OpenDTU und 21 Invertern #1036

spueli99 Jun 14, 2023

Replies: 1 comment · 8 replies

smainz Jun 15, 2023

smainz Jun 17, 2023

spueli99 Jun 17, 2023 Author

smainz Jun 17, 2023

spueli99 Jun 19, 2023 Author

smainz Jun 21, 2023

spueli99
Jun 14, 2023

Replies: 1 comment 8 replies

smainz
Jun 15, 2023

spueli99 Jun 17, 2023
Author

spueli99 Jun 19, 2023
Author