Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨

[roland1000]

Hallo ioBroker -Gemeinde

Bin seit ca 2 Wochen dabei einen MQTT wert zu Splitten in 4 einzelne Datenpunkte . Die Datenpunkte sind schon angelegt.
Habe das orginal script ein wening umgeschrieben um zugeordnete werte besser (oder schlechter) zu trennen. Ich habe es
mit Blockly und Node-Red versucht mit teil erfolg . Diese wurde zwar zugeordnet aber mit falschen Zahlen und Sonderzeichen. Diese werte sollen dann grafisch in Vis dargestellt werden .
Die Mqtt Mitteilung lautet :
mqtt.0.SmartZähler_4_1.Status None,A:32766,B:32766,C:32766,D:32766,Counter:66,

Danke im voraus bei euch .
Roland1000

[smartnoob]

@roland1000 Jo, würde mich auch interessieren. Versuch gerade genau dasselbe, allerdings mit einem JSON Object, welches ich aus einer WebAPI geholt habe. Ich würde die einzelnen JSON-'topics' nun gerne einzelnen Datenpunkten zuordnen. Vllt. weiß jemand weiter? Ansonsten könnte man, das Object natürlich auch als STRING behandeln und manuell zerlegen, finde ich aber irgendwie unschön. Ob jemand ne Idee hat? Grüße!

[mickym]

@roland1000 Du musst das ganze halt in ein Objekt daraus zu machen.

In meinen Augen wenn Du daran selbst rumgefuhrwerkt hast - hast Du es schlimmer gemacht, als es vorher war.

Ich habe ausserdem mal meinen neuen Flow mit eingebaut:

In meinen Augen ist es Schwachsinn das alles wieder wegzuschreiben. Ich gehe mal davon aus, dass mqtt einen JSON String geliefert hat und nicht so einen verstümmelten String. Wenn das ein JSON String ist dann poste den lieber mal .

Umd dann zum Beispiel den Counter zu extrahieren ist das viele Einfacher:

Mit meiner neuen Node - wird das automatisch in einzelne Datenpunkte aufgedröselt.

Ich weigere mich aber den Flow zu posten - wenn ihr JSON-Strings kaputt macht. :(

[mickym]

@smartnoob Dann probiere meine neue Node - und Du hast was Du willst

[roland1000]

Hallo mickym

Wau. Dachte das Programm ist kleiner . Bin gerade dabei mich mit Java auseinander zusetzten. Werde gleich das programm im orignal zustand flashen

MFG
roland1000

[mickym]

@roland1000 Das ist nur so lange - weil Du den JSON String kaputt machst - poste den JSON String und nutz entweder die Node - oder wandel es selbst in ein Objekt um und extrahiere einzelne Werte- Das Ganze ist nur so lang - weil DU den JSON String kaputt gemacht hast. Mit dem orginären JSON String einer JSON Node - hast Du alles in einem Objekt - kannst dann meine Node nutzen oder selbst extrahieren.

MIt der Manipulieren von JSON Strings macht man diese hervorragende Konzept nur kaputt. :(

Und wer partout kein NodeRed nutzen will, der soll halt dann im Javascript den parse Befehl. Der wandelt es in ein Objekt um - und auf dessen Eigenschaften greift man einfach mit einem Punkt zu - also obj.eigenschaft.

var obj = JSON.parse(text);

siehe hier: https://www.w3schools.com/js/js_json.asp

[roland1000]

@mickym

So sieht die Originale Mqtt nachricht aus

mqtt.0.SmartZähler_4_1.Status None, 32766, 32766, 32766, 32766, C82B961DCB31, FRITZBOX, -64dB, 192.168.178.99, 5

LG roland1000

[mickym]

@roland1000 OK das ist kein JSON sondern Array.

Das kannst Du über split in JS in ein Array über führen.

Ansonsten mach ich Dir für dafür einen kleinen Flow,

Wenn Du es in ein Array umwandels (erste Change Node)

Auf diese einzelnen Werte greifst Du dann einfach über payload.0 oder payload.1 zu - also IP ist payload.8

Mit meinem Subflow bekommst Du dies Ergebnis:

Wenn Du den Flow implementierst - hast Du den Subflow mit implementiert - musst halt wieder löschen, wenn Du ihn nicht willst.

Spoiler

[
   {
       "id": "c3403a60.92fbb8",
       "type": "subflow",
       "name": "JSON or Obj to IOBroker",
       "info": "# Creates an IOBroker tree\n\nThis node creates an IOBroker tree out of an Java-Object or JSON String.\n\nThe object tree will be created under 0_userdata.0\nIn addition to the JSON-String or Java Object as `msg.payload` it is necessary to specify a `msg.top` properity in addition to the msg-Object.\n\nThe object tree will be created under 0_userdata.0\n\nExisting `msg.topic` entries will be deleted.\nAn iobroker-out node has to be appended to this subflow node. It is not part of the subflow itself. No topic should be specified in the iobroker out node.\n\nIs no `msg.top` property is defined, then you will get an error in the following iobroker-out node (key or topic does not exist) - if you append a debug node to the subflow node you will get the message: \n> Please define msg.top as root for the object structure \n\n# Erstellt einen Objektbaum im ioBroker\n\nDiese Node erstellt einen Objektbaum im ioBroker aus einem JAVA Objekt bzw. einem JSON String. \n\nDer Baum wird in jedem Fall unter 0_userdata.0 erstellt und zwar unter dem Topic der in` msg.top` mitgegeben wurde. In der `msg.payload` befindet sich dann der JSON String oder das entsprechende Objekt.\n\nExistierende `msg.topic `Einträge werden gelöscht.\nEin entsprechende iobroker-out Node muss an den Flow angehängt werden. Sie ist nicht Bestandteil des Subflows. In dieser iobroker-out Node darf kein Topic angegeben werden. \n\nFalls in keine Angabe in msg.top definiert wurde, wird man in der darauffolgenden iobroker-out node den Fehler erhalten, dass kein key oder topic definiert ist. Falls eine debug Node an den Subflow angehängt wirde erhält man folgende Ausgabe:\n> Please define msg.top as root for the object structure ",
       "category": "",
       "in": [
           {
               "x": 60,
               "y": 160,
               "wires": [
                   {
                       "id": "94876630.f71748"
                   }
               ]
           }
       ],
       "out": [
           {
               "x": 2280,
               "y": 260,
               "wires": [
                   {
                       "id": "74b0b536.02371c",
                       "port": 0
                   },
                   {
                       "id": "ab9b1e85.eea2a",
                       "port": 0
                   }
               ]
           }
       ],
       "env": [],
       "color": "#E2D96E",
       "icon": "node-red/batch.svg"
   },
   {
       "id": "eea737e7.7e8fb8",
       "type": "split",
       "z": "c3403a60.92fbb8",
       "name": "split object",
       "splt": "\\n",
       "spltType": "str",
       "arraySplt": 1,
       "arraySpltType": "len",
       "stream": false,
       "addname": "key",
       "x": 1170,
       "y": 160,
       "wires": [
           [
               "dc473616.c2b508"
           ]
       ]
   },
   {
       "id": "dc473616.c2b508",
       "type": "change",
       "z": "c3403a60.92fbb8",
       "name": "add key to topic",
       "rules": [
           {
               "t": "set",
               "p": "stateName",
               "pt": "msg",
               "to": "key",
               "tot": "msg"
           },
           {
               "t": "set",
               "p": "topic",
               "pt": "msg",
               "to": "topic  & '.' & key",
               "tot": "jsonata"
           },
           {
               "t": "change",
               "p": "topic",
               "pt": "msg",
               "from": " ",
               "fromt": "str",
               "to": "_",
               "tot": "str"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1360,
       "y": 160,
       "wires": [
           [
               "78697695.9a72c8"
           ]
       ]
   },
   {
       "id": "78697695.9a72c8",
       "type": "switch",
       "z": "c3403a60.92fbb8",
       "name": "is type?",
       "property": "payload",
       "propertyType": "msg",
       "rules": [
           {
               "t": "istype",
               "v": "array",
               "vt": "array"
           },
           {
               "t": "istype",
               "v": "object",
               "vt": "object"
           },
           {
               "t": "else"
           }
       ],
       "checkall": "true",
       "repair": false,
       "outputs": 3,
       "x": 1540,
       "y": 160,
       "wires": [
           [
               "d839cef8.577f1"
           ],
           [
               "eea737e7.7e8fb8"
           ],
           [
               "bdfdae99.f4d9d"
           ]
       ]
   },
   {
       "id": "d839cef8.577f1",
       "type": "split",
       "z": "c3403a60.92fbb8",
       "name": "split array",
       "splt": "\\n",
       "spltType": "str",
       "arraySplt": 1,
       "arraySpltType": "len",
       "stream": false,
       "addname": "",
       "x": 580,
       "y": 280,
       "wires": [
           [
               "36327f2d.8efc3"
           ]
       ]
   },
   {
       "id": "36327f2d.8efc3",
       "type": "change",
       "z": "c3403a60.92fbb8",
       "name": "add index to topic",
       "rules": [
           {
               "t": "set",
               "p": "topic",
               "pt": "msg",
               "to": "topic  & '.' & parts.index",
               "tot": "jsonata"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 770,
       "y": 280,
       "wires": [
           [
               "d8f58d9b.b6a1"
           ]
       ]
   },
   {
       "id": "74b0b536.02371c",
       "type": "change",
       "z": "c3403a60.92fbb8",
       "name": "finalize msg.topic",
       "rules": [
           {
               "t": "set",
               "p": "top",
               "pt": "msg",
               "to": "'0_userdata.0.' & top",
               "tot": "jsonata"
           },
           {
               "t": "set",
               "p": "topic",
               "pt": "msg",
               "to": "top & topic",
               "tot": "jsonata"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1970,
       "y": 240,
       "wires": [
           []
       ]
   },
   {
       "id": "4cdee7cb.910c38",
       "type": "switch",
       "z": "c3403a60.92fbb8",
       "name": "is type?",
       "property": "payload",
       "propertyType": "msg",
       "rules": [
           {
               "t": "istype",
               "v": "json",
               "vt": "json"
           },
           {
               "t": "istype",
               "v": "object",
               "vt": "object"
           },
           {
               "t": "istype",
               "v": "array",
               "vt": "array"
           },
           {
               "t": "else"
           }
       ],
       "checkall": "true",
       "repair": false,
       "outputs": 4,
       "x": 400,
       "y": 160,
       "wires": [
           [
               "c1c41535.17d3b8"
           ],
           [
               "eea737e7.7e8fb8"
           ],
           [
               "d839cef8.577f1"
           ],
           [
               "d8f58d9b.b6a1"
           ]
       ]
   },
   {
       "id": "c1c41535.17d3b8",
       "type": "json",
       "z": "c3403a60.92fbb8",
       "name": "",
       "property": "payload",
       "action": "",
       "pretty": false,
       "x": 570,
       "y": 120,
       "wires": [
           [
               "3ccd67db.375058"
           ]
       ]
   },
   {
       "id": "bdfdae99.f4d9d",
       "type": "switch",
       "z": "c3403a60.92fbb8",
       "name": "is msg.top != null",
       "property": "top",
       "propertyType": "msg",
       "rules": [
           {
               "t": "nnull"
           },
           {
               "t": "null"
           }
       ],
       "checkall": "true",
       "repair": false,
       "outputs": 2,
       "x": 1750,
       "y": 280,
       "wires": [
           [
               "74b0b536.02371c"
           ],
           [
               "7ba7dc21.fdb214"
           ]
       ]
   },
   {
       "id": "7ba7dc21.fdb214",
       "type": "change",
       "z": "c3403a60.92fbb8",
       "name": "payload = warning",
       "rules": [
           {
               "t": "set",
               "p": "payload",
               "pt": "msg",
               "to": "Please define msg.top as root for the object structure",
               "tot": "str"
           },
           {
               "t": "delete",
               "p": "topic",
               "pt": "msg"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1970,
       "y": 300,
       "wires": [
           [
               "ab9b1e85.eea2a"
           ]
       ]
   },
   {
       "id": "ab9b1e85.eea2a",
       "type": "rbe",
       "z": "c3403a60.92fbb8",
       "name": "",
       "func": "rbe",
       "gap": "",
       "start": "",
       "inout": "out",
       "septopics": true,
       "property": "payload",
       "x": 2130,
       "y": 300,
       "wires": [
           []
       ]
   },
   {
       "id": "94876630.f71748",
       "type": "change",
       "z": "c3403a60.92fbb8",
       "name": "",
       "rules": [
           {
               "t": "delete",
               "p": "topic",
               "pt": "msg"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 210,
       "y": 160,
       "wires": [
           [
               "4cdee7cb.910c38"
           ]
       ]
   },
   {
       "id": "3ccd67db.375058",
       "type": "switch",
       "z": "c3403a60.92fbb8",
       "name": "is array?",
       "property": "payload",
       "propertyType": "msg",
       "rules": [
           {
               "t": "istype",
               "v": "array",
               "vt": "array"
           },
           {
               "t": "else"
           }
       ],
       "checkall": "true",
       "repair": false,
       "outputs": 2,
       "x": 700,
       "y": 120,
       "wires": [
           [
               "d839cef8.577f1"
           ],
           [
               "eea737e7.7e8fb8"
           ]
       ]
   },
   {
       "id": "80dde279.c28ec",
       "type": "comment",
       "z": "c3403a60.92fbb8",
       "name": "Array",
       "info": "",
       "x": 400,
       "y": 280,
       "wires": []
   },
   {
       "id": "95ee816e.68a16",
       "type": "comment",
       "z": "c3403a60.92fbb8",
       "name": "object",
       "info": "",
       "x": 1140,
       "y": 100,
       "wires": []
   },
   {
       "id": "d8f58d9b.b6a1",
       "type": "switch",
       "z": "c3403a60.92fbb8",
       "name": "is type?",
       "property": "payload",
       "propertyType": "msg",
       "rules": [
           {
               "t": "istype",
               "v": "object",
               "vt": "object"
           },
           {
               "t": "istype",
               "v": "array",
               "vt": "array"
           },
           {
               "t": "else"
           }
       ],
       "checkall": "true",
       "repair": false,
       "outputs": 3,
       "x": 960,
       "y": 280,
       "wires": [
           [
               "eea737e7.7e8fb8"
           ],
           [
               "d839cef8.577f1"
           ],
           [
               "bdfdae99.f4d9d"
           ]
       ]
   },
   {
       "id": "b1c7e4de.c5e3b8",
       "type": "change",
       "z": "6e170384.60c96c",
       "name": "",
       "rules": [
           {
               "t": "set",
               "p": "payload",
               "pt": "msg",
               "to": "$split(payload, ',')\t",
               "tot": "jsonata"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1770,
       "y": 4500,
       "wires": [
           [
               "dbb1239.52cf7e",
               "3b50374d.40bbc8",
               "8f074db1.50967"
           ]
       ]
   },
   {
       "id": "8088f4f7.6eb0d8",
       "type": "inject",
       "z": "6e170384.60c96c",
       "name": "",
       "props": [
           {
               "p": "payload"
           }
       ],
       "repeat": "",
       "crontab": "",
       "once": false,
       "onceDelay": 0.1,
       "topic": "",
       "payload": "mqtt.0.SmartZähler_4_1.Status None, 32766, 32766, 32766, 32766, C82B961DCB31, FRITZBOX, -64dB, 192.168.178.99, 5  ",
       "payloadType": "str",
       "x": 1580,
       "y": 4500,
       "wires": [
           [
               "b1c7e4de.c5e3b8"
           ]
       ]
   },
   {
       "id": "dbb1239.52cf7e",
       "type": "debug",
       "z": "6e170384.60c96c",
       "name": "",
       "active": true,
       "tosidebar": true,
       "console": false,
       "tostatus": false,
       "complete": "false",
       "statusVal": "",
       "statusType": "auto",
       "x": 1990,
       "y": 4440,
       "wires": []
   },
   {
       "id": "3b50374d.40bbc8",
       "type": "change",
       "z": "6e170384.60c96c",
       "name": "",
       "rules": [
           {
               "t": "set",
               "p": "top",
               "pt": "msg",
               "to": "Example.roland1000",
               "tot": "str"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1990,
       "y": 4500,
       "wires": [
           [
               "c95221db.97524"
           ]
       ]
   },
   {
       "id": "c95221db.97524",
       "type": "subflow:c3403a60.92fbb8",
       "z": "6e170384.60c96c",
       "name": "",
       "x": 2220,
       "y": 4500,
       "wires": [
           [
               "d51846e1.274e08"
           ]
       ]
   },
   {
       "id": "d51846e1.274e08",
       "type": "ioBroker out",
       "z": "6e170384.60c96c",
       "name": "",
       "topic": "",
       "ack": "false",
       "autoCreate": "true",
       "stateName": "",
       "role": "",
       "payloadType": "",
       "readonly": "",
       "stateUnit": "",
       "stateMin": "",
       "stateMax": "",
       "x": 2480,
       "y": 4500,
       "wires": []
   },
   {
       "id": "8f074db1.50967",
       "type": "change",
       "z": "6e170384.60c96c",
       "name": "IP Adress",
       "rules": [
           {
               "t": "set",
               "p": "payload",
               "pt": "msg",
               "to": "payload.8",
               "tot": "msg"
           }
       ],
       "action": "",
       "property": "",
       "from": "",
       "to": "",
       "reg": false,
       "x": 1960,
       "y": 4580,
       "wires": [
           [
               "440328e1.b3b188"
           ]
       ]
   },
   {
       "id": "440328e1.b3b188",
       "type": "debug",
       "z": "6e170384.60c96c",
       "name": "",
       "active": true,
       "tosidebar": true,
       "console": false,
       "tostatus": false,
       "complete": "false",
       "statusVal": "",
       "statusType": "auto",
       "x": 2140,
       "y": 4580,
       "wires": []
   }
]

[roland1000]

@mickym

Im array Modus hab ich nur die Sonderzeichen gehabt. A B C D sind an einen ADS1115 angeschlossen der liefert werte von 4 Stromwandler habe mich deswegen entschieden weil ich dann nur einen ESP8266 verbauen muste.

[roland1000]

@roland1000

Denke mal muss noch einiges lernen mit node red. Dem Hauptteil meiner scripte ist in Blockly weil diese der S7 ähnlich ist .

[mickym]

@roland1000 Bis auf das erste Zeichen in dem String sehe ich zumindest nichts ausgewöhnliches - das kann man ggf. noch mit einem Change rausfiltern - aber ich seh sonst keine Sonderzeichen???

Ich hab mal die Leerzeichen eliminiert:

Dann kommt das eigentlich sehr sauber raus:

[roland1000]

@mickym

Dann hab ich Node red noch nicht ganz verstanden wie gesagt der Datenpunkt wurde zugeordnet aber mit Sonderzeichen die ständig gewechselt haben

[roland1000]

@mickym

Ich danke dir 1000mal für deine Hilfe. Ich hab mir echt einen Abgebrochen .

LG
Roland1000

[mickym]

@roland1000 sagte in Json splitten in 4 Datenpunkten:

@mickym

Dann hab ich Node red noch nicht ganz verstanden wie gesagt der Datenpunkt wurde zugeordnet aber mit Sonderzeichen die ständig gewechselt haben

Da kann ich Dir nur helfen, wenn Du Deinen Flow veröffentlichst und in eine InjectNode - den Quellstring einsetzt, der aus mqtt rauskommt.

Aber wenn es so für Dich funktioniert ist ja alles gut.

Nur wenn man um Hilfe bittet, dann ist es halt wichtig zu sehen, was ist die Ausgangslage und wieviel von dem ist da drin, was man schon selbst versucht hat. ;)

[roland1000]

@mickym

Hab bis jetzt immer wieder alles verworfen dann wieder von vorne angefangen. Mein erstes Projekt hat ungefähr ein halbes Jahr gebraucht um zu funktionieren .

[mickym]

@roland1000 Wie gesagt ich helfe Dir gerne - und ich bin ein NodeRed Fan. wie Du wahrscheinlich schon festgestellt hast. Ich muss halt immer nur alle Fakten und die Zielsetzung vor Augen haben, nur dann kann ich halt effizient helfen.

Im Übrigen schon im Standard - kannst in NodeRed sowohl über die iobroker NOdes - als auch über mqtt-Nodes auf mqtt Daten zugreifen. ;)

und noch ein Tipp: Mach in Deinem NodeRed Adapter gleich die unselige Option aus, dass alles in Strings umgewandelt wird. Das macht nur Verdruss.

[roland1000]

@mickym

Absolut Genial das script dann kann ich endlich den Aufbau starten. Dann wünsche ich dir erstmal ein schönes Wochenende
und Danke nochmal für deine Hilfe.

LG
Roland1000

[smartnoob]

So. Habe gerade nochmal ein bisschen mit blockly rumgespielt. Damit geht es eigentlich ganz einfach über den Baustein
Attribut "" von Object XY. Damit einfach den gewünschten Datenpunkt aktualisieren, ggf. vorher noch in gewünschten Datentyp konvertieren, fertig. LG.

[mickym]

@smartnoob du meinst wohl

[roland1000]

@mickym

Hallo erstmal .Funktioniert super mit dem Node red . Wirklich super das ihr mir hilft hab aber heute Post vom Stromversorger
bekommen jetzt wird unser alter Zähler gewechselt auf Digital. Hab noch gehofft das ich den noch 2 Jahre benutzten kann.