Gelöst: Wert in dynamische Struktur im ioBroker ablegen
-
@martybr Gut - wie Du auf einzelne Elemente mittels einer ChangeNode zugreifst, habe ich Dir ja untengepostet.
Wenn Du programmatisch ein Array mit einer definierten Zahl an Elementen erstellen willst.
[0..payload-1].($:=0) -
@mickym
Okay, ich setze mich mal dran.
Danke für deine Geduld. -
So ich habe Dir mal - glaub nach Deinen Wünschen - das mal theoratisch über ChangeNodes implementiert.
Eingespeist wird eine Temperatur über die Inject Node und über die Change Node habe ich hier mal folgendes gemacht:
- Regel - Ermittlung der Anzahhl Tage des aktuellen Monats:
$moment().endOf("month").date()Ermittelt die Anzahl der Tage des aktuellen Monats. (Du siehst wie kurz man das anstelle der function Nodes machen kann).
- Regel - Erstellt ein Array mit Anzahl Elementen anhand der Tage des aktuellen Monats wird dann durch Einlesen des Datenpunkts ersetzt
[0..numDaysOfMonth-1].($:=0)- Regel - Ermittelt den aktuellen Tag des Monats:
$moment().date()- Regel - Iteriert durch das Array und setzt am Index (da mit 0 beginnt, also an Position 8), die payload.
$map(array,function($v,$i){$i=dayOfMonth-1 ? payload : $v })So ich hoffe das hilft Dir weiter:
-
@mickym
Danke dir. Ich setze das Morgen um. Aktuell muss ich das Rededuell Merz-Scholz noch sacken lassen. -
@MartyBr
So hier muss ich selbst immer probieren, wenn ich innerhalb eines Arrays was updaten will und nicht die explizite map Funktion nutzen will.Um also das X.te Element des Monats einen arrays zu aktualisieren, kann man anstelle von
$map(array,function($v,$i){$i=dayOfMonth-1 ? payload : $v })auch folgendes schreiben:
array#$i.($i=$$.dayOfMonth -1 ? $$.payload : $) -
@mickym
Vielen Dank. Ich habe den Node in meine Flows eingebaut und lasse das mal ein paar Tage laufen. Dann sollten ja Daten in den Arrays sein.Die Flows sind nun erheblich kürzer geworden. Wenn alles läuft stelle ich den Flow hier ein.
Vielleicht kann ja noch jemand davon profitieren. -
@martybr Im Fall der variablen Adressierung innerhalb eines Arrays bietet sich dann doch eher ein Function Node mit Javascript an.
-
@mickym
Ich stelle hier mal den gesamten Flow vor. Ziel war, aus einem Temperatursensor den Mittelwert (== mean), den Minimalwert (== min) und den Maximalwert (==max) über einen Tag gemittelt in ein Array zu speichern.
Dabei soll das erste Element den 1. Tag im Monat entsprechend, das 2. Element entsprechend die zweite Position im Array gespeichert werden.
Die Datenstruktur ist {min: 2, mean:4,max:12}
Zur Einhaltung der Reihenfolge dienen die delay Nodes.Die Ablage des Arrays liegt unter 0_userdata.0.Hauptpfad.Jahr.Monat.
Als Beispiel:
0_userdata.0.Heizung.2025.Februar.meanTmpDie Werte werden um Mitternacht geschrieben. Die Struktur der Ablage wird automatisch angelegt, d.h. am 1. März wird der nächste Datenpunkt geschrieben.
Aus historischen Gründen ersetze ich März durch Maerz (nicht Merz
)Hier der Flow:
[ { "id": "ae673cf6cd8433a0", "type": "subflow", "name": "Datum in Topic", "info": "", "category": "", "in": [ { "x": 60, "y": 80, "wires": [ { "id": "2e1ea06b2e94bf1a" } ] } ], "out": [ { "x": 820, "y": 80, "wires": [ { "id": "fc37f5f9d2b0297b", "port": 0 } ] } ], "env": [ { "name": "basePath", "type": "str", "value": "Test1.Test2" } ], "meta": {}, "color": "#DDAA99" }, { "id": "2e1ea06b2e94bf1a", "type": "change", "z": "ae673cf6cd8433a0", "name": "", "rules": [ { "t": "set", "p": "datum", "pt": "msg", "to": "$moment().locale('de').format('YYYY.MMMM')", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 230, "y": 80, "wires": [ [ "0e8de9437c3c420a" ] ] }, { "id": "0e8de9437c3c420a", "type": "change", "z": "ae673cf6cd8433a0", "name": "März zu Maerz", "rules": [ { "t": "change", "p": "datum", "pt": "msg", "from": "März", "fromt": "str", "to": "Maerz", "tot": "str" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 440, "y": 80, "wires": [ [ "fc37f5f9d2b0297b" ] ] }, { "id": "fc37f5f9d2b0297b", "type": "change", "z": "ae673cf6cd8433a0", "name": "", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "\"0_userdata.0.\" & $env(\"basePath\") & \".\" & datum & \".\" & topic", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 660, "y": 80, "wires": [ [] ] }, { "id": "8736b5d7e2d039bf", "type": "aggregator", "z": "3146dc7f943a9f88", "name": "Mean", "topic": "mean", "intervalCount": "1", "intervalUnits": "d", "submitIncompleteInterval": true, "submitPerTopic": false, "aggregationType": "mean", "x": 330, "y": 180, "wires": [ [ "ae4126ab345fb69f" ] ] }, { "id": "c628f16d0dd75f88", "type": "aggregator", "z": "3146dc7f943a9f88", "name": "Min", "topic": "min", "intervalCount": "1", "intervalUnits": "d", "submitIncompleteInterval": true, "submitPerTopic": false, "aggregationType": "min", "x": 330, "y": 120, "wires": [ [ "73aeeccad69fe289" ] ] }, { "id": "433c29573c06f6d3", "type": "aggregator", "z": "3146dc7f943a9f88", "name": "Max", "topic": "max", "intervalCount": "1", "intervalUnits": "d", "submitIncompleteInterval": true, "submitPerTopic": false, "aggregationType": "max", "x": 330, "y": 240, "wires": [ [ "b15148679b3cdfe5" ] ] }, { "id": "73aeeccad69fe289", "type": "join", "z": "3146dc7f943a9f88", "name": "", "mode": "custom", "build": "object", "property": "payload", "propertyType": "msg", "key": "topic", "joiner": "\\n", "joinerType": "str", "accumulate": true, "timeout": "60", "count": "3", "reduceRight": false, "reduceExp": "", "reduceInit": "", "reduceInitType": "", "reduceFixup": "", "x": 710, "y": 120, "wires": [ [ "7c8ab4f951a11b2c" ] ] }, { "id": "7c8ab4f951a11b2c", "type": "change", "z": "3146dc7f943a9f88", "name": "", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "meanTmp", "tot": "str" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 880, "y": 120, "wires": [ [ "95c361f9dc2dcb9f" ] ] }, { "id": "95c361f9dc2dcb9f", "type": "subflow:ae673cf6cd8433a0", "z": "3146dc7f943a9f88", "name": "Datum in Topic", "env": [ { "name": "basePath", "value": "Heizung2.MonatsTabellen", "type": "str" } ], "x": 1080, "y": 120, "wires": [ [ "3c1d0873dbaa5be4" ] ] }, { "id": "ae4126ab345fb69f", "type": "delay", "z": "3146dc7f943a9f88", "name": "", "pauseType": "delay", "timeout": "5", "timeoutUnits": "seconds", "rate": "1", "nbRateUnits": "1", "rateUnits": "second", "randomFirst": "1", "randomLast": "5", "randomUnits": "seconds", "drop": false, "allowrate": false, "outputs": 1, "x": 500, "y": 180, "wires": [ [ "73aeeccad69fe289" ] ] }, { "id": "b15148679b3cdfe5", "type": "delay", "z": "3146dc7f943a9f88", "name": "", "pauseType": "delay", "timeout": "10", "timeoutUnits": "seconds", "rate": "1", "nbRateUnits": "1", "rateUnits": "second", "randomFirst": "1", "randomLast": "5", "randomUnits": "seconds", "drop": false, "allowrate": false, "outputs": 1, "x": 510, "y": 240, "wires": [ [ "73aeeccad69fe289" ] ] }, { "id": "3c1d0873dbaa5be4", "type": "change", "z": "3146dc7f943a9f88", "name": "Save to Array", "rules": [ { "t": "set", "p": "numDaysOfMonth", "pt": "msg", "to": "$moment().endOf(\"month\").date()", "tot": "jsonata" }, { "t": "set", "p": "array", "pt": "msg", "to": "[0..numDaysOfMonth-1].($:=0)", "tot": "jsonata" }, { "t": "set", "p": "dayOfMonth", "pt": "msg", "to": "$moment().date()", "tot": "jsonata" }, { "t": "set", "p": "payload", "pt": "msg", "to": "array#$i.($i=$$.dayOfMonth -1 ? $$.payload : $)", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 780, "y": 220, "wires": [ [ "642675605be1e9ba" ] ] }, { "id": "12be244299d16c40", "type": "ioBroker out", "z": "3146dc7f943a9f88", "name": "", "topic": "", "ack": "true", "autoCreate": "true", "stateName": "", "role": "", "payloadType": "", "readonly": "false", "stateUnit": "°C", "stateMin": "", "stateMax": "", "x": 1140, "y": 220, "wires": [] }, { "id": "642675605be1e9ba", "type": "json", "z": "3146dc7f943a9f88", "name": "", "property": "payload", "action": "", "pretty": false, "x": 970, "y": 220, "wires": [ [ "12be244299d16c40" ] ] }, { "id": "ced5eb48c2a75d2e", "type": "ioBroker in", "z": "3146dc7f943a9f88", "name": "Aussentemperatur", "attrname": "payload", "topic": "mqtt.0.vitocal.outside_temperature", "payloadType": "value", "onlyack": "", "func": "all", "gap": "", "fireOnStart": "false", "outFormat": "MQTT", "x": 130, "y": 180, "wires": [ [ "8736b5d7e2d039bf", "c628f16d0dd75f88", "433c29573c06f6d3" ] ] } ] -
@martybr Warum die delay Nodes?
bei der JOIN Node:
Wenn Du den Haken rausmachst, dann wartet diee JOIN Node bis sie von allen aggregator Nodes ihre Nachricht bekommen hat.
-
@mickym
Mit den Delay Nodes kommen sie in der richtigen Abfolge. Das war der Grund. -
@martybr Wieso braucht es eine Abfolge - nur wegen dem Verständnis - es wird doch eh alles in einem Objekt gesammelt. Im Prinzip ist die Reihenfolge der Eigenschaften in einem Objekt doch völlig egal.
Wenn man unbedingt eine Reihenfolge erzwingen wird, dann strukturiert man das Objekt einfach um
Hier zum Ausprobieren:
Es ist wichtig, dass Du diese einfachen Umstrukturierungsmöglichkeiten von Objekten verstehst, das ist ein riesiger Vorteil gegenüber den Puzzlefreunden. Du kannst die "Attribute" umbenennen, welche weglassen, welche hinzufügen etc.
-
@mickym
Der Flow funktioniert (natürlich
) und ich habe ihn direkt in meinen Testflow eingebaut.JSONata scheint ja mächtige Funktionen zu haben.
Das habe ich was zu lesen. -
@martybr sagte in Wert in dynamische Struktur im ioBroker ablegen:
JSONata scheint ja mächtige Funktionen zu haben.
Ja und was ich nicht verstehe, dass auch die Puzzlefreunde viel zu wenige Gebrauch von dieser tollen Bibliothek machen:
-
@mickym
Ich habe mal eine Suche über das Forum laufen lassen. Es sind schon einige Threads dazu im Forum. Nach meiner kurzen Recherche mit Durchweg sehr positiver Resonanz.
Das motiviert weiter
-
@mickym
Ich habe ein neues Problem, wo ich nicht weiterkomme.Die Idee ist, einen Datenpunkt (den täglichen Strombezug) um 00:05 Uhr mit einem Zeitstempel vom Vortag (also von dem Tag, an dem der Strombezug angefallen ist) in Influxdb2 zu speichern.
In Blockly gibt es dazu entsprechende Funktionsblöcke, die ich aktuell zum speichern nutze.
Meine Vorarbeit hier:
- Generiere globale Variable "gestern" mit dem Vortagsdatum
- Setze timestamp auf "gestern"
- Speicher Datenpunkt in Influxdb
Der Punkt 3 scheitert.
Hier der Flow:
Hier der Fehler:
Hier der Code:
[ { "id": "3af60aa82603a460", "type": "inject", "z": "3ebdbbcf49e0ac40", "name": "", "props": [ { "p": "payload" }, { "p": "topic", "vt": "str" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "", "payloadType": "date", "x": 160, "y": 840, "wires": [ [ "7ccee6b8c9cf5ec1" ] ] }, { "id": "7ccee6b8c9cf5ec1", "type": "change", "z": "3ebdbbcf49e0ac40", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "$moment().locale('de').add(-24,'hours')", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 370, "y": 840, "wires": [ [ "1ea6bb475e356038" ] ] }, { "id": "1ea6bb475e356038", "type": "change", "z": "3ebdbbcf49e0ac40", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "gestern", "tot": "global" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 610, "y": 840, "wires": [ [] ] }, { "id": "f26c4899a33b8475", "type": "debug", "z": "3ebdbbcf49e0ac40", "name": "debug 189", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "false", "statusVal": "", "statusType": "auto", "x": 630, "y": 920, "wires": [] }, { "id": "406857da365d597c", "type": "debug", "z": "3ebdbbcf49e0ac40", "name": "debug 190", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "false", "statusVal": "", "statusType": "auto", "x": 390, "y": 920, "wires": [] }, { "id": "b8a9409a42dbae35", "type": "debug", "z": "3ebdbbcf49e0ac40", "name": "debug 188", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "false", "statusVal": "", "statusType": "auto", "x": 150, "y": 920, "wires": [] }, { "id": "12f8e712328509a0", "type": "inject", "z": "3ebdbbcf49e0ac40", "name": "", "props": [ { "p": "payload" }, { "p": "topic", "vt": "str" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "test", "payload": "gestern", "payloadType": "global", "x": 170, "y": 980, "wires": [ [ "b8a9409a42dbae35", "8529604e9d2970d9" ] ] }, { "id": "8529604e9d2970d9", "type": "change", "z": "3ebdbbcf49e0ac40", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "", "tot": "date" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 390, "y": 980, "wires": [ [ "a7394618f04eb825", "406857da365d597c" ] ] }, { "id": "a7394618f04eb825", "type": "change", "z": "3ebdbbcf49e0ac40", "name": "", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "test-topic2", "tot": "str" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 600, "y": 980, "wires": [ [ "f26c4899a33b8475", "031edbcc8819c8f7" ] ] }, { "id": "031edbcc8819c8f7", "type": "influxdb batch", "z": "3ebdbbcf49e0ac40", "influxdb": "4d3e21e6d3a637e2", "precision": "", "retentionPolicy": "", "name": "", "database": "database", "precisionV18FluxV20": "ms", "retentionPolicyV18Flux": "", "org": "Home", "bucket": "iobroker", "x": 650, "y": 1080, "wires": [] }, { "id": "4d3e21e6d3a637e2", "type": "influxdb", "hostname": "127.0.0.1", "port": "8086", "protocol": "http", "database": "database", "name": "influx2", "usetls": false, "tls": "", "influxdbVersion": "2.0", "url": "http://192.168.178.111:8086", "timeout": "", "rejectUnauthorized": false } ]Im Forum wird über Probleme beim Ändern vom Timestamp beim speichern in Influx diskutiert. Gibt es einen Tipp, wie ich den Datenpunkt mit dem geänderten Timestamp in Influxdb2 speichern kann?
-
Timestamps kannst Du meiner Meinung nicht mit den influx Out Node setzen, sondern Du brauchst die Batch Nodes.
In die Batch Nodes kommen Objekte
Falls Du noch tags hast, dann ist das genauso ein Objekt wie fields.
-
@mickym
Okay, probiere ich aus. -
@mickym
Ich habe es mit der Change Node nicht hinbekommen. Mit einer Funktion und der normalen influx-out (nicht influx-batch) funktioniert es. In der Function ziehe ich 12 Stunden ab (43200 Sek.) und schreibe es in Time:
[ { "id": "88f12c4fab5f8e9b", "type": "mqtt in", "z": "2987494fe96ff2fb", "name": "Vitovent ZuluftTemp", "topic": "vitocal/ZuluftTemp", "qos": "0", "datatype": "auto-detect", "broker": "bcf16446273a18e6", "nl": false, "rap": true, "rh": 0, "inputs": 0, "x": 130, "y": 1040, "wires": [ [ "0e5f1ebe84c213fc" ] ] }, { "id": "0e5f1ebe84c213fc", "type": "change", "z": "2987494fe96ff2fb", "name": "", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "zuluft", "tot": "str" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 340, "y": 1040, "wires": [ [ "a8b5d292c778eeb7" ] ] }, { "id": "a8b5d292c778eeb7", "type": "function", "z": "2987494fe96ff2fb", "name": "function 22", "func": "function getHistoryTimestamp(seconds) {\n var historyDate = new Date(Date.now() - (seconds * 1000));\n return historyDate.getTime();\n}\n\nvar historyTimestamp = getHistoryTimestamp(43200);\n\nmsg.payload = { value: msg.payload, time: historyTimestamp }\n\nreturn msg;", "outputs": 1, "timeout": 0, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 550, "y": 1040, "wires": [ [ "7f48f630a7765a4a" ] ] }, { "id": "7f48f630a7765a4a", "type": "influxdb out", "z": "2987494fe96ff2fb", "influxdb": "5d7e54ca.019d44", "name": "outside", "measurement": "test.test3.outside", "precision": "", "retentionPolicy": "", "database": "database", "precisionV18FluxV20": "ms", "retentionPolicyV18Flux": "", "org": "Home", "bucket": "iobroker", "x": 740, "y": 1040, "wires": [] }, { "id": "bcf16446273a18e6", "type": "mqtt-broker", "name": "Mosquito", "broker": "192.168.178.10", "port": 1883, "clientid": "", "autoConnect": true, "usetls": false, "protocolVersion": 4, "keepalive": 60, "cleansession": true, "autoUnsubscribe": true, "birthTopic": "", "birthQos": "0", "birthRetain": "false", "birthPayload": "", "birthMsg": {}, "closeTopic": "", "closeQos": "0", "closeRetain": "false", "closePayload": "", "closeMsg": {}, "willTopic": "", "willQos": "0", "willRetain": "false", "willPayload": "", "willMsg": {}, "userProps": "", "sessionExpiry": "" }, { "id": "5d7e54ca.019d44", "type": "influxdb", "hostname": "127.0.0.1", "port": "8086", "protocol": "http", "database": "database", "name": "Influxdb2", "usetls": false, "tls": "d50d0c9f.31e858", "influxdbVersion": "2.0", "url": "http://192.168.178.111:8086", "timeout": "", "rejectUnauthorized": false }, { "id": "d50d0c9f.31e858", "type": "tls-config", "name": "", "cert": "", "key": "", "ca": "", "certname": "", "keyname": "", "caname": "", "servername": "", "verifyservercert": false } ]Eigentlich müsste es mit einer Change und JSONata auch funktionieren.
Hier ein Versuch:
[ { "id": "26d58a13f8c13bd6", "type": "change", "z": "2987494fe96ff2fb", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "payload.{ \"measurement\":msg.payload, \"timestamp\":$millis() }", "tot": "jsonata" }, { "t": "set", "p": "topic", "pt": "msg", "to": "zuluft", "tot": "str" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 370, "y": 800, "wires": [ [ "6a3df3f89e66d61c" ] ] } ]Leider funktioniert es nicht. Kannst du mir hier einen Tipp geben?
-
@martybr Das ist eigentlich ganz einfach:
- Da die payload kein Objekt sondern ein skalarer Wert ist, kann auch kein Objekt neu definiert werden. Also musst Du der payload Eigenschaft einfach ein Objekt zuweisen.
- In einer ChangeNode gibst Du das Wurzelobjekt - also das Nachrichtenobjekt msg - nie an. Das ist in der ChangeNode bereits festgelegt, deswegen kann man auch nicht auf Eigenschaften außerhalb des Nachrichtenobjektes zugreifen.
Deine ChangeNode hätte als bereits wie folgt funktioniert:
Um die gleiche Ausgabe wie mit Deinem Javascriptcode zu erhalten:
function getHistoryTimestamp(seconds) { var historyDate = new Date(Date.now() - (seconds * 1000)); return historyDate.getTime(); } var historyTimestamp = getHistoryTimestamp(43200); msg.payload = { value: msg.payload, time: historyTimestamp } return msg;schreibst Du in JSONATA also nur folgendes:
{ "value":payload, "time": $millis() -43200*1000 }
Hier wieder alles zusammen zum Import:
3-5 ms Laufzeitunterschied ist rasend schnell - diesen Unterschied musst du verkraften.
(wobei die ChangeNode in dem Fall schneller ist, als die function Node). -
@mickym
Wenn ich vom mqtt triggere, dann ist der Laufzeitunterschied nur 1 ms, aber weiterhin zugunsten der JSONata-Version.
Das klappt perfekt.Eine Frage dazu:
Ich möchte das täglich um Mitternacht + 1 Minute triggern. Dazu habe ich den cron-plus genommen. Dieser verändert aber den msg.payload. Wo setze ich den Node am besten hin?
