Gelöst: Wert in dynamische Struktur im ioBroker ablegen
-
@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.
-
@martybr Was soll das - Du hast keine Flowvariable payload - ich hab Dir doch einen fertigen Flow geschickt.
-
@martybr sagte in Wert in dynamische Struktur im ioBroker ablegen:
Auch hier der Fehler. Der Cron ist bei schedule auf "flow.payload" gestellt.
Der Eingang der cron Node ist NUR ZUM STEUERN der Cron Node da. Schau Dir die Hilfe zur Cronnode an. Das bombardieren dieser Node mit irgendwelchen Nachrichten bzw. payloads ist Kontraproduktiv.
Mit dem Eingang kannst Du zum Beispiel dynamisch irgendwelche Zeitereignisse erstellen, siehe wie gesagt die Hilfe zur cronplus Node:
-
@mickym
Ich hatte deinen Flow nicht gesehen und hatte meine "Programmierung" in einem Flow gesetzt. Sorry, hatte versucht das Problem zu lösen.Nun habe ich deinen Ansatz verstanden: Die Trigger-Node schreibt ihren Wert in eine Flow-Variable (flow.irgendwas) und die cron-plus-node triggert diesen Flow flow.irgendwas.
Jetzt ist mir das klar.
Zu deiner Frage wegen der dreissig Sekunden. Das ist ein Trigger, der häufig Daten liefert.
Im echten Flow nehme ich dann Datenpunkte mit täglich aggregierten Werten, die ich dann mit einem Timestamp vom Vortag in Influx schreibe.
Dazu reicht der normale influx-out aus. Der influx-batch ist nicht notwendig. -
@martybr sagte in Wert in dynamische Struktur im ioBroker ablegen:
Nun habe ich deinen Ansatz verstanden: Die Trigger-Node schreibt ihren Wert in eine Flow-Variable (flow.irgendwas) und die cron-plus-node triggert diesen Flow flow.irgendwas.
Die mqtt-In Node schreibt ihren Wert in eine Flow-Variable ....
Die cronplus Node triggert zum konfigurierten Zeitpunkt und schickt als payload den Inhalt der Flow Variable.
Zu deiner Frage wegen der dreissig Sekunden. Das ist ein Trigger, der häufig Daten liefert.
Im echten Flow nehme ich dann Datenpunkte mit täglich aggregierten Werten, die ich dann mit einem Timestamp vom Vortag in Influx schreibe.
War keine Frage - aber Du willst ja in die Influx zu definierten Zeitpunkten schreiben, sprich wenn die cronplus triggert und nicht wenn die mqtt-In triggert.
Gut dann sollte dieses Kapitel aber gelöst und geklärt sein.
-
@mickym
Genau. Und vielen Dank.
