NEWS
Gelöst: Wert in dynamische Struktur im ioBroker ablegen
-
@mickym
Der Flow funktioniert (natürlich :blush: ) 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:
-
@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 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.
-
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
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?
Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
@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).
-
@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?Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
@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": "" } ]Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
@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": "" } ] -
@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 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.
-
@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 :anguished: ) mache ich hier falsch.Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
@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 :anguished: ) 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.
Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
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.
-
Auch hier der Fehler. Der Cron ist bei schedule auf "flow.payload" gestellt.
Nur der untere Teil ist relevant.@martybr Was soll das - Du hast keine Flowvariable payload - ich hab Dir doch einen fertigen Flow geschickt.
-
Auch hier der Fehler. Der Cron ist bei schedule auf "flow.payload" gestellt.
Nur der untere Teil ist relevant.@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:
-
@martybr Was soll das - Du hast keine Flowvariable payload - ich hab Dir doch einen fertigen Flow geschickt.
@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.Gruß
Martin
Intel NUCs mit Proxmox / Iobroker als VM unter Debian
Raspeberry mit USB Leseköpfen für Smartmeter
Homematic und Homematic IP -
@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.
Support us
818
Online32.4k
Users81.5k
Topics1.3m
Posts