Gelöst: Wert in dynamische Struktur im ioBroker ablegen
-
@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? -
@martybr Die cronplus verändert nicht die payload - weil die ja triggert - sie erzeugt eine payload. Woher willst Du denn die payload nehmen?
Als trigger steht die cronplus deshalb immer am Anfang. -
@mickym
Ich habe das mal so gemacht:
(der mqtt hat ja keinen Eingang)
Fehler:
Code:
[ { "id": "9e09070debba5a70", "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": 150, "y": 1700, "wires": [ [ "458daafa3e776526" ] ] }, { "id": "458daafa3e776526", "type": "cronplus", "z": "2987494fe96ff2fb", "name": "", "outputField": "payload", "timeZone": "", "storeName": "", "commandResponseMsgOutput": "output1", "defaultLocation": "", "defaultLocationType": "default", "outputs": 1, "options": [ { "name": "schedule2", "topic": "topic2", "payloadType": "default", "payload": "", "expressionType": "cron", "expression": "0 * * * * *", "location": "", "offset": "0", "solarType": "all", "solarEvents": "sunrise,sunset" } ], "x": 360, "y": 1700, "wires": [ [ "18e23ebeebdc502e" ] ] }, { "id": "18e23ebeebdc502e", "type": "change", "z": "2987494fe96ff2fb", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\"value\":payload,\"time\": $millis() -43200*1000}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 550, "y": 1700, "wires": [ [ "379bfe9421c88668" ] ] }, { "id": "379bfe9421c88668", "type": "debug", "z": "2987494fe96ff2fb", "name": "Ausgabe JSONATA mit identischer Ausgabe", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 870, "y": 1700, "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": "" } ] -
@martybr
P.S. brauche einen switch node? Nur wenn beide "wahr" sind? -
@martybr Nein das ist verkehrt. Wie gesagt die cronplus triggert - und der Eingang in die cronplus-Node dient alleine zum Steuern der cronplus Node.
In dem Fall musst Du den Wert aus dem mqtt Node in einer Flowvariablen zwischenspeichern und diese kann dann die cronplus bei triggern als payload verschicken.
Da die mqtt Node die Flowvariable ja kontinuierlich aktualisiert, hast Du somit zum Triggerzeitpunkt immer den letzten, aktuellsten Wert in der Flowvariable, der dann von der cron-plus auf die Reise geschickt wird.
-
@mickym
Das sieht nicht gut aus:
[ { "id": "379bfe9421c88668", "type": "debug", "z": "2987494fe96ff2fb", "name": "Ausgabe JSONATA mit identischer Ausgabe", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 850, "y": 1700, "wires": [] }, { "id": "18e23ebeebdc502e", "type": "change", "z": "2987494fe96ff2fb", "name": "", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\"value\":payload,\"time\": $millis() -43200*1000}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 530, "y": 1700, "wires": [ [ "379bfe9421c88668" ] ] }, { "id": "9e09070debba5a70", "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": 270, "y": 1740, "wires": [ [ "18e23ebeebdc502e" ] ] }, { "id": "458daafa3e776526", "type": "cronplus", "z": "2987494fe96ff2fb", "name": "", "outputField": "payload", "timeZone": "", "storeName": "", "commandResponseMsgOutput": "output1", "defaultLocation": "", "defaultLocationType": "default", "outputs": 1, "options": [ { "name": "schedule2", "topic": "topic", "payloadType": "flow", "payload": "payload", "expressionType": "cron", "expression": "0 */5 * * * *", "location": "", "offset": "0", "solarType": "all", "solarEvents": "sunrise,sunset" } ], "x": 280, "y": 1640, "wires": [ [ "18e23ebeebdc502e" ] ] }, { "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": "" } ]Der mqtt triggert alle 30 Sekunden. Mit dem cron-plus zusammen wird der payload wieder gelöscht.
Irgendetwas (oder alles
) mache ich hier falsch. -
Ich hatte doch gesagt, dass Du die Ausgabe aus dem Mqtt in einer Flowvariable speichern sollst. Ich habe nun ein Objekt genommen - du kannst natürlich auch eine skalare Variable nehmen.
Merke wenn 2 Trigger zu unterschiedlichen Zeitpunkten triggern (in diesem Fall cronplus und mqtt) bringst Du die Nachrichtenobjekte nie zusammen (JOIN Node macht hier keinen Sinn), sondern dann speicherst Du den Wert im Kontext und nutzt ihn dann im anderen Trigger.
Hier siehst Du wie ich die mqtt In Ausgabe im Flow-Kontext speichere:
Wenn die cronplus Node dann triggert, dann schnappt sie sich den Wert aus der Flowvariable
und sendet ihn als payload in Deine ChangeNode.
Hier wieder der Import:
-
Auch hier der Fehler. Der Cron ist bei schedule auf "flow.payload" gestellt.
Nur der untere Teil ist relevant.
-
Wenn Du das so wie Du geplant hättest, dann hätte ja deine mqtt alle 30 s getriggert und du hättest alle 30 s in die Influx geschrieben.
