@jabba76 So ich habe noch ein bisschen weiter gebastelt 😉 😉 - weil mir eingefallen ist, dass Du vielleicht mit mqtt Wildcards als Input arbeiten möchtest und dann muss man nicht einen Datenpunkt abgreifen, sondern es können beliebig viele ankommen.
Dann muss man das Ganze ordnen und ich habe das jetzt mal manuell gemacht indem ich über eine Change Node mit 13 Regeln 😉 so ein msg.parts Objekt gefüllt habe - damit eine Join Node das automatisch zusammensetzen kann. Das könnte man ggf. auch aufteilen - aber das überlasse ich jemand anders.
Eine Beschreibung zum msg.parts Objekt findet man hier:
Füllt man diese werden über die Change Node erst dann Nachrichten ausgegeben, wenn alle 3 Werte (Temperatur, Druck und Feuchtigkeit) komplett sind.
Man sieht auch hier anhand der Debug Node - wie erst alle 3 Werte eines Sensors ankommen müssen, bevor die endgültige Nachricht erzeugt wurde.
Beim ersten Node habe ich mal gezeigt, wie das msg.parts Objekt gefüllt wird, damit die JOIN Node das automatisch zusammensetzen kann.
0afaa3cb-ccbc-4f11-aab6-93b88ad08deb-image.png
Die Ausgabe ist die gleiche nur dass nun die Ausgabe welchen Sensors variabel und nicht mehr fix ist:
d90ebdfe-9744-4209-8753-ed6a2ef61d03-image.png
Diese wird wie man sieht nun über den msg. topic geschrieben (hier mal der Inhalt der Template Node):
<p> Dies sind Werte des Sensors {{msg.topic}}:<br>
Temperatur: {{msg.payload.temperature}} °Celsius<br>
Druck: {{msg.payload.pressure}} %<br>
Feuchtigkeit: {{msg.payload.humidity}} hPa<br>
</p>
Hier wieder der Flow zum Import:
Spoiler
[
{
"id": "ab61c658.d5e478",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp01/temperature",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp01/temperature\",\"payload\":\"27.71\",\"qos\":1,\"retain\":true,\"_topic\":\"esp01/temperature\",\"_msgid\":\"9c900137.efb7b\"}",
"payloadType": "str",
"x": 2450,
"y": 3240,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "3f35b8e2.762838",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp01/humidity",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp01/humidity\",\"payload\":\"46.65\",\"qos\":1,\"retain\":true,\"_topic\":\"esp01/humidity\",\"_msgid\":\"3d6f2cec.f64da4\"}",
"payloadType": "str",
"x": 2440,
"y": 3320,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "26c66965.fdf586",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp01/pressure",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp01/pressure\",\"payload\":\"1030.77\",\"qos\":1,\"retain\":true,\"_topic\":\"esp01/pressure\",\"_msgid\":\"402e6b69.3286b4\"}",
"payloadType": "str",
"x": 2440,
"y": 3280,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "2f3f7e6e.6a06b2",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp02/temperature",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp02/temperature\",\"payload\":\"15.48\",\"qos\":1,\"retain\":true,\"_topic\":\"esp02/temperature\",\"_msgid\":\"9c900137.efb7b\"}",
"payloadType": "str",
"x": 2450,
"y": 3380,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "9feefd2c.8feea",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp01/humidity",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp02/humidity\",\"payload\":\"66.85\",\"qos\":1,\"retain\":true,\"_topic\":\"esp02/humidity\",\"_msgid\":\"3d6f2cec.f64da4\"}",
"payloadType": "str",
"x": 2440,
"y": 3460,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "d416cac9.ba0cb8",
"type": "inject",
"z": "6e170384.60c96c",
"name": "esp02/pressure",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "{\"topic\":\"esp02/pressure\",\"payload\":\"968.22\",\"qos\":1,\"retain\":true,\"_topic\":\"esp02/pressure\",\"_msgid\":\"402e6b69.3286b4\"}",
"payloadType": "str",
"x": 2440,
"y": 3420,
"wires": [
[
"eee07f4a.41fa4"
]
]
},
{
"id": "eee07f4a.41fa4",
"type": "json",
"z": "6e170384.60c96c",
"name": "",
"property": "payload",
"action": "",
"pretty": false,
"x": 2680,
"y": 3340,
"wires": [
[
"f5cdaa11.5bb828"
]
]
},
{
"id": "f5cdaa11.5bb828",
"type": "change",
"z": "6e170384.60c96c",
"name": "",
"rules": [
{
"t": "move",
"p": "payload",
"pt": "msg",
"to": "sensor",
"tot": "msg"
},
{
"t": "set",
"p": "parts",
"pt": "msg",
"to": "{\"type\":\"object\",\"index\":\"\",\"count\":3}",
"tot": "json"
},
{
"t": "set",
"p": "topic",
"pt": "msg",
"to": "sensor.topic",
"tot": "msg"
},
{
"t": "change",
"p": "topic",
"pt": "msg",
"from": "(.*)\\/.*",
"fromt": "re",
"to": "$1",
"tot": "str"
},
{
"t": "set",
"p": "parts.id",
"pt": "msg",
"to": "topic",
"tot": "msg"
},
{
"t": "set",
"p": "payload",
"pt": "msg",
"to": "sensor.payload",
"tot": "msg"
},
{
"t": "set",
"p": "parts.key",
"pt": "msg",
"to": "sensor.topic",
"tot": "msg"
},
{
"t": "change",
"p": "parts.key",
"pt": "msg",
"from": ".*\\/(.*)",
"fromt": "re",
"to": "$1",
"tot": "str"
},
{
"t": "set",
"p": "parts.index",
"pt": "msg",
"to": "parts.key",
"tot": "msg"
},
{
"t": "change",
"p": "parts.index",
"pt": "msg",
"from": "temperature",
"fromt": "str",
"to": "0",
"tot": "num"
},
{
"t": "change",
"p": "parts.index",
"pt": "msg",
"from": "pressure",
"fromt": "str",
"to": "1",
"tot": "num"
},
{
"t": "change",
"p": "parts.index",
"pt": "msg",
"from": "humidity",
"fromt": "str",
"to": "2",
"tot": "num"
},
{
"t": "delete",
"p": "sensor",
"pt": "msg"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 2860,
"y": 3340,
"wires": [
[
"e773f7b7.ec4878",
"55b76254.f5de9c"
]
]
},
{
"id": "a02344a8.acdd78",
"type": "debug",
"z": "6e170384.60c96c",
"name": "",
"active": false,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "true",
"targetType": "full",
"statusVal": "",
"statusType": "auto",
"x": 3250,
"y": 3280,
"wires": []
},
{
"id": "e773f7b7.ec4878",
"type": "join",
"z": "6e170384.60c96c",
"name": "",
"mode": "auto",
"build": "string",
"property": "payload",
"propertyType": "msg",
"key": "topic",
"joiner": "\\n",
"joinerType": "str",
"accumulate": false,
"timeout": "",
"count": "",
"reduceRight": false,
"reduceExp": "",
"reduceInit": "",
"reduceInitType": "",
"reduceFixup": "",
"x": 3050,
"y": 3340,
"wires": [
[
"a02344a8.acdd78",
"90c0d28c.cca2f"
]
]
},
{
"id": "90c0d28c.cca2f",
"type": "ui_template",
"z": "6e170384.60c96c",
"group": "9efdcbae.2c5598",
"name": "ESP03",
"order": 8,
"width": "6",
"height": "5",
"format": "<p> Dies sind Werte des Sensors {{msg.topic}}:<br>\nTemperatur: {{msg.payload.temperature}} °Celsius<br>\nDruck: {{msg.payload.pressure}} %<br>\nFeuchtigkeit: {{msg.payload.humidity}} hPa<br>\n</p>",
"storeOutMessages": true,
"fwdInMessages": true,
"resendOnRefresh": true,
"templateScope": "local",
"x": 3260,
"y": 3340,
"wires": [
[]
]
},
{
"id": "55b76254.f5de9c",
"type": "debug",
"z": "6e170384.60c96c",
"name": "",
"active": false,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "true",
"targetType": "full",
"statusVal": "",
"statusType": "auto",
"x": 3050,
"y": 3400,
"wires": []
},
{
"id": "9efdcbae.2c5598",
"type": "ui_group",
"name": "Sensordaten",
"tab": "dc25fe35.866f",
"order": 3,
"disp": true,
"width": "6",
"collapse": false
},
{
"id": "dc25fe35.866f",
"type": "ui_tab",
"name": "Test",
"icon": "dashboard",
"order": 14,
"disabled": false,
"hidden": false
}
]
Damit sollte das Prinzip eigentlich verstanden sein. 😉
