- ioBroker Community Home
- Deutsch
- Skripten / Logik
- Node-Red
- Node-Red Modbus mehrere Slave ID´s abfragen
Node-Red Modbus mehrere Slave ID´s abfragen
Dieses Thema wurde gelöscht. Nur Nutzer mit entsprechenden Rechten können es sehen.
-
@mickym
Die Objekte, die ich abfrage sind bei allen drei Geräten gleich. Sie unterscheiden sich nur von der Geräten ID (unitId).
Ich weiß, du wolltest nur eins, ich hab dir aber mal zwei kopiert, damit der Unterschied bzw. das was gleich ist, ersichtlicher ist.
{ "unitId": 10, "_address": 0, "name": "Voltage", "description": "Voltage", "unit": "V", "type": "floatbe", "len": 2, "factor": 1, "offset": 0, "formula": "", "role": "level", "room": "", "cw": false, "isScale": false }, { "unitId": 10, "_address": 6, "name": "Current", "description": "Current", "unit": "A", "type": "floatbe", "len": 2, "factor": 1, "offset": 0, "formula": "", "role": "level", "room": "", "cw": false, "isScale": false },Das ganze sieht inzwischen bei mir so aus:
Flow:
[ { "id": "c54bca7562265ca3", "type": "tab", "label": "Flow 3", "disabled": false, "info": "", "env": [] }, { "id": "f2922e884087f046", "type": "function", "z": "c54bca7562265ca3", "name": "WriteModbus", "func": "msg = msg;\n\nmsg.payload = {\n value: msg.payload,\n 'fc': 6,\n 'unitid': 1,//msg.unitId,\n 'address': msg.modbusRequest.address,\n 'quantity': msg.modbusRequest.quantity\n}\nreturn msg;\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1030, "y": 280, "wires": [ [ "99c1f11c70531f02" ] ] }, { "id": "815a99d2e6bf9ed4", "type": "split", "z": "c54bca7562265ca3", "name": "Split array", "splt": "\\n", "spltType": "str", "arraySplt": "1", "arraySpltType": "len", "stream": false, "addname": "parts", "x": 360, "y": 320, "wires": [ [ "f3f2d24ab23758cd" ] ] }, { "id": "f3f2d24ab23758cd", "type": "function", "z": "c54bca7562265ca3", "name": "ReadModbus", "func": "msg = msg.payload;\nconst fc = 4;\n//const unitid = 10;\n\nmsg = {\n topic : msg.name,\n payload : {\n 'fc': fc,\n 'unitid': msg.unitId,//JSON.parse(unitid),\n 'address': msg._address,//JSON.parse(y.number),\n 'quantity': 2,\n 'value': 2\n }\n }\n\nnode.send(msg);\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 530, "y": 320, "wires": [ [ "1c1d3d0c781fb502" ] ] }, { "id": "6550c3991f50a8f4", "type": "comment", "z": "c54bca7562265ca3", "name": "L1 ID 10 - read/write", "info": "", "x": 490, "y": 260, "wires": [] }, { "id": "8d95de296353e88f", "type": "comment", "z": "c54bca7562265ca3", "name": "L2 ID 11 - read/write", "info": "", "x": 490, "y": 480, "wires": [] }, { "id": "972d431852b0de4d", "type": "comment", "z": "c54bca7562265ca3", "name": "L3 ID 12 - read/write", "info": "", "x": 490, "y": 680, "wires": [] }, { "id": "1c1d3d0c781fb502", "type": "modbus-flex-getter", "z": "c54bca7562265ca3", "name": "", "showStatusActivities": false, "showErrors": false, "logIOActivities": false, "server": "40f20c7f.13a934", "useIOFile": false, "ioFile": "", "useIOForPayload": false, "emptyMsgOnFail": false, "keepMsgProperties": false, "x": 730, "y": 320, "wires": [ [ "f2922e884087f046" ], [ "ee5558d45eeaf040", "a035f7f84b852f5b" ] ] }, { "id": "ee5558d45eeaf040", "type": "function", "z": "c54bca7562265ca3", "name": "JSON ID11", "func": "let x = msg;\nif (x.topic === \"TotalReactiveEnergy\") {\n\n\nmsg.payload = \n [\n {\n \"unitId\": 11,\n \"_address\": 0,\n \"name\": \"Voltage\",\n \"description\": \"Voltage\",\n \"unit\": \"V\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 6,\n \"name\": \"Current\",\n \"description\": \"Current\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 12,\n \"name\": \"ActivePower\",\n \"description\": \"Active Power\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 18,\n \"name\": \"ApparentPower\",\n \"description\": \"ApparentPower\",\n \"unit\": \"VA\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 24,\n \"name\": \"ReactivePower\",\n \"description\": \"ReactivePower\",\n \"unit\": \"VAr\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 30,\n \"name\": \"PowerFactor\",\n \"description\": \"PowerFactor\",\n \"unit\": \"\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 70,\n \"name\": \"Frequency\",\n \"description\": \"Frequency\",\n \"unit\": \"Hz\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 72,\n \"name\": \"ActiveEnergy\",\n \"description\": \"Active Energy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 74,\n \"name\": \"ExportActiveEnergy\",\n \"description\": \"ExportActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 74,\n \"name\": \"TotalSystemPowerDemand\",\n \"description\": \"TotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 76,\n \"name\": \"ImportReactiveEnergy\",\n \"description\": \"ImportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 76,\n \"name\": \"MaxTotalSystemPowerDemand\",\n \"description\": \"MaxTotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 78,\n \"name\": \"ExportReactiveEnergy\",\n \"description\": \"ExportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 88,\n \"name\": \"ImportSystemPowerDemand\",\n \"description\": \"ImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 90,\n \"name\": \"MaxImportSystemPowerDemand\",\n \"description\": \"MaxImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 92,\n \"name\": \"ExportSystemPowerDemand\",\n \"description\": \"ExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 94,\n \"name\": \"MaxExportSystemPowerDemand\",\n \"description\": \"MaxExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 258,\n \"name\": \"CurrentDemand\",\n \"description\": \"CurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 264,\n \"name\": \"MaxCurrentDemand\",\n \"description\": \"MaxCurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 342,\n \"name\": \"TotalActiveEnergy\",\n \"description\": \"TotalActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 11,\n \"_address\": 344,\n \"name\": \"TotalReactiveEnergy\",\n \"description\": \"TotalReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n }\n\n ]\n\n\nreturn msg;\n}", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 210, "y": 540, "wires": [ [ "82f015af713aaed9" ] ] }, { "id": "7a55b60b988b7063", "type": "modbus-flex-getter", "z": "c54bca7562265ca3", "name": "", "showStatusActivities": false, "showErrors": false, "logIOActivities": false, "server": "40f20c7f.13a934", "useIOFile": false, "ioFile": "", "useIOForPayload": false, "emptyMsgOnFail": false, "keepMsgProperties": false, "x": 730, "y": 540, "wires": [ [ "c41c8139b9c03e79" ], [ "48aa3a74bcafa90e", "363902c7450bf34a" ] ] }, { "id": "82f015af713aaed9", "type": "split", "z": "c54bca7562265ca3", "name": "Split array", "splt": "\\n", "spltType": "str", "arraySplt": "1", "arraySpltType": "len", "stream": false, "addname": "parts", "x": 360, "y": 540, "wires": [ [ "5f7fb500131410b5" ] ] }, { "id": "5f7fb500131410b5", "type": "function", "z": "c54bca7562265ca3", "name": "ReadModbus", "func": "msg = msg.payload;\nconst fc = 4;\n//const unitid = 10;\n\nmsg = {\n topic : msg.name,\n payload : {\n 'fc': fc,\n 'unitid': msg.unitId,//JSON.parse(unitid),\n 'address': msg._address,//JSON.parse(y.number),\n 'quantity': 2,\n 'value': 2\n }\n }\n\nnode.send(msg);\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 530, "y": 540, "wires": [ [ "7a55b60b988b7063" ] ] }, { "id": "48aa3a74bcafa90e", "type": "function", "z": "c54bca7562265ca3", "name": "JSON ID12", "func": "let x = msg;\nif (x.topic === \"TotalReactiveEnergy\") {\n\n\n msg.payload = \n [\n {\n \"unitId\": 12,\n \"_address\": 0,\n \"name\": \"Voltage\",\n \"description\": \"Voltage\",\n \"unit\": \"V\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 6,\n \"name\": \"Current\",\n \"description\": \"Current\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 12,\n \"name\": \"ActivePower\",\n \"description\": \"Active Power\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 18,\n \"name\": \"ApparentPower\",\n \"description\": \"ApparentPower\",\n \"unit\": \"VA\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 24,\n \"name\": \"ReactivePower\",\n \"description\": \"ReactivePower\",\n \"unit\": \"VAr\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 30,\n \"name\": \"PowerFactor\",\n \"description\": \"PowerFactor\",\n \"unit\": \"\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 70,\n \"name\": \"Frequency\",\n \"description\": \"Frequency\",\n \"unit\": \"Hz\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 72,\n \"name\": \"ActiveEnergy\",\n \"description\": \"Active Energy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 74,\n \"name\": \"ExportActiveEnergy\",\n \"description\": \"ExportActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 74,\n \"name\": \"TotalSystemPowerDemand\",\n \"description\": \"TotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 76,\n \"name\": \"ImportReactiveEnergy\",\n \"description\": \"ImportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 76,\n \"name\": \"MaxTotalSystemPowerDemand\",\n \"description\": \"MaxTotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 78,\n \"name\": \"ExportReactiveEnergy\",\n \"description\": \"ExportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 88,\n \"name\": \"ImportSystemPowerDemand\",\n \"description\": \"ImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 90,\n \"name\": \"MaxImportSystemPowerDemand\",\n \"description\": \"MaxImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 92,\n \"name\": \"ExportSystemPowerDemand\",\n \"description\": \"ExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 94,\n \"name\": \"MaxExportSystemPowerDemand\",\n \"description\": \"MaxExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 258,\n \"name\": \"CurrentDemand\",\n \"description\": \"CurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 264,\n \"name\": \"MaxCurrentDemand\",\n \"description\": \"MaxCurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 342,\n \"name\": \"TotalActiveEnergy\",\n \"description\": \"TotalActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 12,\n \"_address\": 344,\n \"name\": \"TotalReactiveEnergy\",\n \"description\": \"TotalReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n }\n\n ]\n\n\n\nreturn msg;\n}", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 210, "y": 740, "wires": [ [ "5ba607adfe619264" ] ] }, { "id": "77c985566abb5e50", "type": "modbus-flex-getter", "z": "c54bca7562265ca3", "name": "", "showStatusActivities": false, "showErrors": false, "logIOActivities": false, "server": "40f20c7f.13a934", "useIOFile": false, "ioFile": "", "useIOForPayload": false, "emptyMsgOnFail": false, "keepMsgProperties": false, "x": 730, "y": 740, "wires": [ [ "e7d9c9ab5ee6383f" ], [ "66b67a91e4198f33", "ebc8a38e5380b0e3" ] ] }, { "id": "5ba607adfe619264", "type": "split", "z": "c54bca7562265ca3", "name": "Split array", "splt": "\\n", "spltType": "str", "arraySplt": "1", "arraySpltType": "len", "stream": false, "addname": "parts", "x": 360, "y": 740, "wires": [ [ "76c860654c1beb5c" ] ] }, { "id": "76c860654c1beb5c", "type": "function", "z": "c54bca7562265ca3", "name": "ReadModbus", "func": "msg = msg.payload;\nconst fc = 4;\n//const unitid = 10;\n\nmsg = {\n topic : msg.name,\n payload : {\n 'fc': fc,\n 'unitid': msg.unitId,//JSON.parse(unitid),\n 'address': msg._address,//JSON.parse(y.number),\n 'quantity': 2,\n 'value': 2\n }\n }\n\nnode.send(msg);\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 530, "y": 740, "wires": [ [ "77c985566abb5e50" ] ] }, { "id": "ebc8a38e5380b0e3", "type": "function", "z": "c54bca7562265ca3", "name": "JSON ID10", "func": "let x = msg;\nif (x.topic === \"TotalReactiveEnergy\") {\n\n\n msg.payload = \n [\n {\n \"unitId\": 10,\n \"_address\": 0,\n \"name\": \"Voltage\",\n \"description\": \"Voltage\",\n \"unit\": \"V\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 6,\n \"name\": \"Current\",\n \"description\": \"Current\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 12,\n \"name\": \"ActivePower\",\n \"description\": \"Active Power\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 18,\n \"name\": \"ApparentPower\",\n \"description\": \"ApparentPower\",\n \"unit\": \"VA\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 24,\n \"name\": \"ReactivePower\",\n \"description\": \"ReactivePower\",\n \"unit\": \"VAr\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 30,\n \"name\": \"PowerFactor\",\n \"description\": \"PowerFactor\",\n \"unit\": \"\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 70,\n \"name\": \"Frequency\",\n \"description\": \"Frequency\",\n \"unit\": \"Hz\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 72,\n \"name\": \"ActiveEnergy\",\n \"description\": \"Active Energy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 74,\n \"name\": \"ExportActiveEnergy\",\n \"description\": \"ExportActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 74,\n \"name\": \"TotalSystemPowerDemand\",\n \"description\": \"TotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 76,\n \"name\": \"ImportReactiveEnergy\",\n \"description\": \"ImportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 76,\n \"name\": \"MaxTotalSystemPowerDemand\",\n \"description\": \"MaxTotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 78,\n \"name\": \"ExportReactiveEnergy\",\n \"description\": \"ExportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 88,\n \"name\": \"ImportSystemPowerDemand\",\n \"description\": \"ImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 90,\n \"name\": \"MaxImportSystemPowerDemand\",\n \"description\": \"MaxImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 92,\n \"name\": \"ExportSystemPowerDemand\",\n \"description\": \"ExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 94,\n \"name\": \"MaxExportSystemPowerDemand\",\n \"description\": \"MaxExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 258,\n \"name\": \"CurrentDemand\",\n \"description\": \"CurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 264,\n \"name\": \"MaxCurrentDemand\",\n \"description\": \"MaxCurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 342,\n \"name\": \"TotalActiveEnergy\",\n \"description\": \"TotalActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 344,\n \"name\": \"TotalReactiveEnergy\",\n \"description\": \"TotalReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n }\n\n ]\n\nreturn msg;\n}", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 210, "y": 320, "wires": [ [ "815a99d2e6bf9ed4" ] ] }, { "id": "7d7e7f06c4fe1986", "type": "inject", "z": "c54bca7562265ca3", "name": "Start", "props": [ { "p": "payload" }, { "p": "topic", "vt": "str" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "", "payloadType": "date", "x": 190, "y": 200, "wires": [ [ "01a58d010ff88442" ] ] }, { "id": "01a58d010ff88442", "type": "function", "z": "c54bca7562265ca3", "name": "JSON ID10", "func": "msg.payload = \n[\n {\n \"unitId\": 10,\n \"_address\": 0,\n \"name\": \"Voltage\",\n \"description\": \"Voltage\",\n \"unit\": \"V\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 6,\n \"name\": \"Current\",\n \"description\": \"Current\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 12,\n \"name\": \"ActivePower\",\n \"description\": \"Active Power\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 18,\n \"name\": \"ApparentPower\",\n \"description\": \"ApparentPower\",\n \"unit\": \"VA\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 24,\n \"name\": \"ReactivePower\",\n \"description\": \"ReactivePower\",\n \"unit\": \"VAr\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 30,\n \"name\": \"PowerFactor\",\n \"description\": \"PowerFactor\",\n \"unit\": \"\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 70,\n \"name\": \"Frequency\",\n \"description\": \"Frequency\",\n \"unit\": \"Hz\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 72,\n \"name\": \"ActiveEnergy\",\n \"description\": \"Active Energy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 74,\n \"name\": \"ExportActiveEnergy\",\n \"description\": \"ExportActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 74,\n \"name\": \"TotalSystemPowerDemand\",\n \"description\": \"TotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 76,\n \"name\": \"ImportReactiveEnergy\",\n \"description\": \"ImportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 76,\n \"name\": \"MaxTotalSystemPowerDemand\",\n \"description\": \"MaxTotalSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 78,\n \"name\": \"ExportReactiveEnergy\",\n \"description\": \"ExportReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 88,\n \"name\": \"ImportSystemPowerDemand\",\n \"description\": \"ImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 90,\n \"name\": \"MaxImportSystemPowerDemand\",\n \"description\": \"MaxImportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 92,\n \"name\": \"ExportSystemPowerDemand\",\n \"description\": \"ExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 94,\n \"name\": \"MaxExportSystemPowerDemand\",\n \"description\": \"MaxExportSystemPowerDemand\",\n \"unit\": \"W\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 258,\n \"name\": \"CurrentDemand\",\n \"description\": \"CurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 264,\n \"name\": \"MaxCurrentDemand\",\n \"description\": \"MaxCurrentDemand\",\n \"unit\": \"A\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 342,\n \"name\": \"TotalActiveEnergy\",\n \"description\": \"TotalActiveEnergy\",\n \"unit\": \"kWh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n },\n {\n \"unitId\": 10,\n \"_address\": 344,\n \"name\": \"TotalReactiveEnergy\",\n \"description\": \"TotalReactiveEnergy\",\n \"unit\": \"kvarh\",\n \"type\": \"floatbe\",\n \"len\": 2,\n \"factor\": 1,\n \"offset\": 0,\n \"formula\": \"\",\n \"role\": \"level\",\n \"room\": \"\",\n \"cw\": false,\n \"isScale\": false\n }\n]\n\nreturn msg;\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 330, "y": 200, "wires": [ [ "815a99d2e6bf9ed4" ] ] }, { "id": "99c1f11c70531f02", "type": "modbus-flex-write", "z": "c54bca7562265ca3", "name": "", "showStatusActivities": true, "showErrors": true, "server": "17022420f90b4c00", "emptyMsgOnFail": false, "keepMsgProperties": false, "x": 1330, "y": 500, "wires": [ [ "d6ba8355a5f61ed8" ], [] ] }, { "id": "c41c8139b9c03e79", "type": "function", "z": "c54bca7562265ca3", "name": "WriteModbus", "func": "msg = msg;\n\nmsg.payload = {\n value: msg.payload,\n 'fc': 6,\n 'unitid': 1,//msg.unitId,\n 'address': msg.modbusRequest.address + 1000,\n 'quantity': msg.modbusRequest.quantity\n}\nreturn msg;\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1030, "y": 500, "wires": [ [ "99c1f11c70531f02" ] ] }, { "id": "d6ba8355a5f61ed8", "type": "modbus-response", "z": "c54bca7562265ca3", "name": "", "registerShowMax": 20, "x": 1550, "y": 500, "wires": [] }, { "id": "e7d9c9ab5ee6383f", "type": "function", "z": "c54bca7562265ca3", "name": "WriteModbus", "func": "msg = msg;\n\nmsg.payload = {\n value: msg.payload,\n 'fc': 6,\n 'unitid': 1,//msg.unitId,\n 'address': msg.modbusRequest.address + 2000,\n 'quantity': msg.modbusRequest.quantity\n}\nreturn msg;\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1030, "y": 700, "wires": [ [ "99c1f11c70531f02" ] ] }, { "id": "31181ec89d6ec4a7", "type": "modbus-flex-server", "z": "c54bca7562265ca3", "name": "", "logEnabled": true, "serverAddress": "192.168.60.153", "serverPort": "502", "responseDelay": 100, "unitId": "1", "delayUnit": "ms", "coilsBufferSize": 20000, "registersBufferSize": 20000, "minAddress": 0, "splitAddress": 10000, "funcGetCoil": "function getFlexCoil(addr, unitID) {\n\tif (unitID === node.unitId && \n\t\taddr >= node.minAddress && \n\t\taddr <= node.splitAddress) { \n\n\t\treturn node.coils.readUInt8(addr * node.bufferFactor) \n\t} \n}", "funcGetDiscreteInput": "function getFlexDiscreteInput(addr, unitID) {\n\taddr += node.splitAddress\n\tif (unitID === node.unitId && \n\t\taddr >= node.splitAddress && \n\t\taddr <= node.splitAddress * 2) { \n\n\t\treturn node.coils.readUInt8(addr * node.bufferFactor) \n\t} \n}", "funcGetInputRegister": "function getFlexInputRegister(addr, unitID) { \n\tif (unitID === node.unitId && \n\t\taddr >= node.minAddress && \n\t\taddr <= node.splitAddress) { \n\n\t\treturn node.registers.readUInt16BE(addr * node.bufferFactor) \n\t} \n}", "funcGetHoldingRegister": "function getFlexHoldingRegsiter(addr, unitID) { \n\taddr += node.splitAddress\n\tif (unitID === node.unitId && \n\t\taddr >= node.splitAddress && \n\t\taddr <= node.splitAddress * 2) { \n\n\t\treturn node.registers.readUInt16BE(addr * node.bufferFactor) \n\t} \n}", "funcSetCoil": "function setFlexCoil(addr, value, unitID) { \n\tif (unitID === node.unitId && \n\t\taddr >= node.minAddress && \n\t\taddr <= node.splitAddress) { \n\n\t\tnode.coils.writeUInt8(value, addr * node.bufferFactor) \n\t} \n}", "funcSetRegister": "function setFlexRegister(addr, value, unitID) { \n\taddr += node.splitAddress\n\tif (unitID === node.unitId && \n\t\taddr >= node.splitAddress && \n\t\taddr <= node.splitAddress * 2) { \n\n\t\tnode.registers.writeUInt16BE(value, addr * node.bufferFactor) \n\t} \n}", "showErrors": true, "x": 1240, "y": 160, "wires": [ [], [], [], [], [] ] }, { "id": "a035f7f84b852f5b", "type": "modbus-response", "z": "c54bca7562265ca3", "name": "", "registerShowMax": 20, "x": 1030, "y": 340, "wires": [] }, { "id": "363902c7450bf34a", "type": "modbus-response", "z": "c54bca7562265ca3", "name": "", "registerShowMax": 20, "x": 1030, "y": 560, "wires": [] }, { "id": "66b67a91e4198f33", "type": "modbus-response", "z": "c54bca7562265ca3", "name": "", "registerShowMax": 20, "x": 1030, "y": 760, "wires": [] }, { "id": "40f20c7f.13a934", "type": "modbus-client", "name": "Serial_10", "clienttype": "serial", "bufferCommands": true, "stateLogEnabled": false, "queueLogEnabled": true, "failureLogEnabled": true, "tcpHost": "127.0.0.1", "tcpPort": "502", "tcpType": "DEFAULT", "serialPort": "/dev/ttyUSB0", "serialType": "RTU", "serialBaudrate": "9600", "serialDatabits": "8", "serialStopbits": "2", "serialParity": "none", "serialConnectionDelay": "100", "serialAsciiResponseStartDelimiter": "", "unit_id": "10", "commandDelay": "20", "clientTimeout": "2000", "reconnectOnTimeout": false, "reconnectTimeout": "5000", "parallelUnitIdsAllowed": true }, { "id": "17022420f90b4c00", "type": "modbus-client", "name": "neutral", "clienttype": "tcp", "bufferCommands": true, "stateLogEnabled": false, "queueLogEnabled": false, "failureLogEnabled": true, "tcpHost": "192.168.60.153", "tcpPort": "502", "tcpType": "DEFAULT", "serialPort": "/dev/ttyUSB", "serialType": "RTU-BUFFERD", "serialBaudrate": "9600", "serialDatabits": "8", "serialStopbits": "1", "serialParity": "none", "serialConnectionDelay": "100", "serialAsciiResponseStartDelimiter": "0x3A", "unit_id": 1, "commandDelay": 1, "clientTimeout": 1000, "reconnectOnTimeout": true, "reconnectTimeout": 2000, "parallelUnitIdsAllowed": true } ]@malaus So ich habe ja kein Modbus - und im Prinzip sendest Du ja nicht nur ein Nachricht in dieses Flex Getter, sondern wie ich das sehe 21 * 3 - und dass da die Hardware aus dem Tritt kommt, das wundert mich ehrlich gesagt nicht.
Mir ist auch nicht klar, warum Dein Array oder Deine Objekte soviele Informationen haben (aber vielleicht ist das nur ein anderer Output), wenn Du dann bei Deinem ReadModbus dann die meisten Informationen wieder wegschmeisst.
So hier ein paar Optimierungsvorschläge: ;)
Nun wie bekannt, bin ich kein Freund von Codierung und function Nodes, wenn es nicht sein muss. Wenn es also um reine Änderungen der payload geht - solltest Du es in meinen Augen vermeiden - dafür gibts die Change Nodes. Wie sowas geht habe ich Dir in meinem Flow mal gezeigt.
Als erstes habe ich festgestellt, dass Du in Deiner split Node hier msg.parts eingetragen hast - ich weiß das Feld ist rot - aber Du kannst es ignorieren, weil Du ja kein Objekt aufsplittest, sondern ein Array. Insofern gilt das für Dich gar nicht.
So ich musst natürlich diese Modbus Flex Getter Node simulieren - deshalb hab ich nur mal in etwas das angenommen, was vielleicht aus dieser Node rauskommen könnte anhand der Screenshots die ich gesehen habe.
Du hast ja auch bereits schon viel richtiges gesagt und festgestellt:
Die einfachste Variante ist wohl einfach wirklich die Nachrichtenrate mit einer delay Node zu begrenzen, um der Getter Node genügend Zeit zu geben bzw. der Hardware genügend Zeit zu geben, die Anfragen zu kompletieren. Die werden halt nicht selbst gepuffert. (dann kommt man auch ganz ohne function Nodes aus).
Die 2. Variante entspricht in etwa der, die Du jetzt hast, wobei - da alles gleich ist bis auf die ID - ich diese 3 Flows halt zusammengefasst habe. In dem Fall musst Du wirklich mit einer function Nodes arbeiten, da diese einen Kontext hat, der durch das Array der IDs, durch die Du iterieren willst speichern kann und einen zugrhörigen pointer. Mit jeder payload wird der pointer wieder zurückgesetzt.
Der Code ist nicht kompliziert - aber ist halt wirklich eine der Fälle, wo eine Function Node Sinn macht und ein paar JS Kenntnisse haben sollte. ;)
if (msg.payload) { context.set("data",msg.payload); context.set("pointer",0) } var array = context.get("data"); var pointer = context.get("pointer"); pointer ++; if ( pointer <= array.length) { msg.payload = array[pointer - 1]; context.set("pointer",pointer); return msg; }Wie gesagt woher diese Mengen Adressen etc. herkommen das weiss ich alles nicht und muss es auch nicht wissen. Ich hab nur einfach das was Du mit Deinen Function Nodes machst, mit Change Nodes vereinfacht. ;) Was aus der Getter Node rauskommt ist natürlich reine Fantasie. ;)
msg.payload = { data : [0,0], buffer: Buffer.alloc(3) } msg.modbusRequest = { address : 99, quantity : 2 } if (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];Ich hab jetzt halt nur gewartet bist das ganze Array mit den 21 Nachrichten durchgelaufen ist. ;)
Viel Spass beim Nachvollziehen - wenn ich keine groben Fehler gemacht habe und ich Deinen Flow einigermassen verstanden habe, sollte dann meine Optimierung funktionieren. ;)
[ { "id": "ee9289b738d222e9", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 210, "y": 700, "wires": [ [ "1f7b484dfe38737d" ] ] }, { "id": "1f7b484dfe38737d", "type": "split", "z": "7e6af0015415146d", "name": "", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 370, "y": 700, "wires": [ [ "78f4943b61ab8c1f" ] ] }, { "id": "78f4943b61ab8c1f", "type": "delay", "z": "7e6af0015415146d", "name": "", "pauseType": "rate", "timeout": "5", "timeoutUnits": "seconds", "rate": "1", "nbRateUnits": "1", "rateUnits": "second", "randomFirst": "1", "randomLast": "5", "randomUnits": "seconds", "drop": false, "allowrate": false, "outputs": 1, "x": 560, "y": 700, "wires": [ [ "db6d5fd49b87aecb" ] ] }, { "id": "db6d5fd49b87aecb", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 770, "y": 700, "wires": [ [ "99c71b0c490445ea" ] ] }, { "id": "d60cf4b733f4031c", "type": "debug", "z": "7e6af0015415146d", "name": "Write Modbus", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1760, "y": 680, "wires": [] }, { "id": "c5a4f19c99adb81f", "type": "change", "z": "7e6af0015415146d", "name": "Read Modubis", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "name", "tot": "msg" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1120, "y": 700, "wires": [ [ "35a644d37a829731" ] ] }, { "id": "99c71b0c490445ea", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 940, "y": 700, "wires": [ [ "c5a4f19c99adb81f" ] ] }, { "id": "35a644d37a829731", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "msg.payload = {\n data : [0,0],\n buffer: Buffer.alloc(3)\n }\n\nmsg.modbusRequest = {\n address : 99,\n quantity : 2\n }\n\n\nif (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1350, "y": 700, "wires": [ [ "411349fd18118a0e" ], [] ] }, { "id": "411349fd18118a0e", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1570, "y": 680, "wires": [ [ "d60cf4b733f4031c" ] ] }, { "id": "99637116a4a92e38", "type": "comment", "z": "7e6af0015415146d", "name": "Einfache Variante fixes Delay", "info": "", "x": 240, "y": 640, "wires": [] }, { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 610, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 430, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "4661666a374e732c", "type": "debug", "z": "7e6af0015415146d", "name": "Write Modbus", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1600, "y": 840, "wires": [] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modubis", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "name", "tot": "msg" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 960, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 780, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "msg.payload = {\n data : [0,0],\n buffer: Buffer.alloc(3)\n }\n\nmsg.modbusRequest = {\n address : 99,\n quantity : 2\n }\n\n\nif (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1190, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "4a433464d06dc6d8" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1410, "y": 840, "wires": [ [ "4661666a374e732c" ] ] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 740, "y": 940, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] } ]Auch und noch eine kleine Bemerkung:
node.send zu nutzen, sollte man vermeiden und lieber return msg verwenden. Warum manche meinen sie wollen jetzt node.send verwenden, weiß ich nicht. node.send sollte man nur bei asynchroner Verarbeitung nutzen und dann auch mit node.done abschließen. Also sollte das immer der Sonderfall sein.
Hier ein Auszug aus der Online Doku. Was sonst nämlich passieren kann ist, dass die function Node noch weiter wurschtelt und der Flow hinten dran schon munter weiter läuft.
Bei Dir machte das zwar nichts aus, da es der letzte Befehl ist, aber muss ja nicht sein, wenn man mit return msg die function Node korrekt beenden kann.
Fazit aus dem Ganzen: Funktioniert eigentlich wie es soll - nur sollte man warten, bis ein Gerät auch alle Anfragen bearbeiten konnte und deshalb wartet bis die Getter Node wieder aufnahmefähig sind. ;)
Den Rechtschreibfehler in der ChangeNode mit Read Modubis statt Read Modbus im Namen der Change NOde möge man mir verzeihen, deswegen exportiere ich nicht wieder alles neu. ;)
EDIT:
Falls das aber mit der einen GETTER Node nicht funktioniert mit dem Trigger und Dein Flow nur funktioniert, weil Du 3 Getter-Nodes hast, dann muss Dein Flow so bleiben, da nur dann die GETTER Nodes parallel arbeiten können. Oder Du setzt wirklich die Delay Node ein. Die Frage ist halt ob der 2. Ausgang der Getter Node wirklich signalisiert, dass sie fertig ist oder nicht. Wie gesagt, ich tu mir bei dem Ganzen halt schwer, weil ich diese Hardware nicht kenne und deshalb auch die Nodes nicht. Aber in jedem Fall denke ich, hab ich ein paar Alternativen aufgezeigt-Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus So ich habe ja kein Modbus - und im Prinzip sendest Du ja nicht nur ein Nachricht in dieses Flex Getter, sondern wie ich das sehe 21 * 3 - und dass da die Hardware aus dem Tritt kommt, das wundert mich ehrlich gesagt nicht.
Mir ist auch nicht klar, warum Dein Array oder Deine Objekte soviele Informationen haben (aber vielleicht ist das nur ein anderer Output), wenn Du dann bei Deinem ReadModbus dann die meisten Informationen wieder wegschmeisst.
So hier ein paar Optimierungsvorschläge: ;)
Nun wie bekannt, bin ich kein Freund von Codierung und function Nodes, wenn es nicht sein muss. Wenn es also um reine Änderungen der payload geht - solltest Du es in meinen Augen vermeiden - dafür gibts die Change Nodes. Wie sowas geht habe ich Dir in meinem Flow mal gezeigt.
Als erstes habe ich festgestellt, dass Du in Deiner split Node hier msg.parts eingetragen hast - ich weiß das Feld ist rot - aber Du kannst es ignorieren, weil Du ja kein Objekt aufsplittest, sondern ein Array. Insofern gilt das für Dich gar nicht.
So ich musst natürlich diese Modbus Flex Getter Node simulieren - deshalb hab ich nur mal in etwas das angenommen, was vielleicht aus dieser Node rauskommen könnte anhand der Screenshots die ich gesehen habe.
Du hast ja auch bereits schon viel richtiges gesagt und festgestellt:
Die einfachste Variante ist wohl einfach wirklich die Nachrichtenrate mit einer delay Node zu begrenzen, um der Getter Node genügend Zeit zu geben bzw. der Hardware genügend Zeit zu geben, die Anfragen zu kompletieren. Die werden halt nicht selbst gepuffert. (dann kommt man auch ganz ohne function Nodes aus).
Die 2. Variante entspricht in etwa der, die Du jetzt hast, wobei - da alles gleich ist bis auf die ID - ich diese 3 Flows halt zusammengefasst habe. In dem Fall musst Du wirklich mit einer function Nodes arbeiten, da diese einen Kontext hat, der durch das Array der IDs, durch die Du iterieren willst speichern kann und einen zugrhörigen pointer. Mit jeder payload wird der pointer wieder zurückgesetzt.
Der Code ist nicht kompliziert - aber ist halt wirklich eine der Fälle, wo eine Function Node Sinn macht und ein paar JS Kenntnisse haben sollte. ;)
if (msg.payload) { context.set("data",msg.payload); context.set("pointer",0) } var array = context.get("data"); var pointer = context.get("pointer"); pointer ++; if ( pointer <= array.length) { msg.payload = array[pointer - 1]; context.set("pointer",pointer); return msg; }Wie gesagt woher diese Mengen Adressen etc. herkommen das weiss ich alles nicht und muss es auch nicht wissen. Ich hab nur einfach das was Du mit Deinen Function Nodes machst, mit Change Nodes vereinfacht. ;) Was aus der Getter Node rauskommt ist natürlich reine Fantasie. ;)
msg.payload = { data : [0,0], buffer: Buffer.alloc(3) } msg.modbusRequest = { address : 99, quantity : 2 } if (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];Ich hab jetzt halt nur gewartet bist das ganze Array mit den 21 Nachrichten durchgelaufen ist. ;)
Viel Spass beim Nachvollziehen - wenn ich keine groben Fehler gemacht habe und ich Deinen Flow einigermassen verstanden habe, sollte dann meine Optimierung funktionieren. ;)
[ { "id": "ee9289b738d222e9", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 210, "y": 700, "wires": [ [ "1f7b484dfe38737d" ] ] }, { "id": "1f7b484dfe38737d", "type": "split", "z": "7e6af0015415146d", "name": "", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 370, "y": 700, "wires": [ [ "78f4943b61ab8c1f" ] ] }, { "id": "78f4943b61ab8c1f", "type": "delay", "z": "7e6af0015415146d", "name": "", "pauseType": "rate", "timeout": "5", "timeoutUnits": "seconds", "rate": "1", "nbRateUnits": "1", "rateUnits": "second", "randomFirst": "1", "randomLast": "5", "randomUnits": "seconds", "drop": false, "allowrate": false, "outputs": 1, "x": 560, "y": 700, "wires": [ [ "db6d5fd49b87aecb" ] ] }, { "id": "db6d5fd49b87aecb", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 770, "y": 700, "wires": [ [ "99c71b0c490445ea" ] ] }, { "id": "d60cf4b733f4031c", "type": "debug", "z": "7e6af0015415146d", "name": "Write Modbus", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1760, "y": 680, "wires": [] }, { "id": "c5a4f19c99adb81f", "type": "change", "z": "7e6af0015415146d", "name": "Read Modubis", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "name", "tot": "msg" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1120, "y": 700, "wires": [ [ "35a644d37a829731" ] ] }, { "id": "99c71b0c490445ea", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 940, "y": 700, "wires": [ [ "c5a4f19c99adb81f" ] ] }, { "id": "35a644d37a829731", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "msg.payload = {\n data : [0,0],\n buffer: Buffer.alloc(3)\n }\n\nmsg.modbusRequest = {\n address : 99,\n quantity : 2\n }\n\n\nif (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1350, "y": 700, "wires": [ [ "411349fd18118a0e" ], [] ] }, { "id": "411349fd18118a0e", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1570, "y": 680, "wires": [ [ "d60cf4b733f4031c" ] ] }, { "id": "99637116a4a92e38", "type": "comment", "z": "7e6af0015415146d", "name": "Einfache Variante fixes Delay", "info": "", "x": 240, "y": 640, "wires": [] }, { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 610, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 430, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "4661666a374e732c", "type": "debug", "z": "7e6af0015415146d", "name": "Write Modbus", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1600, "y": 840, "wires": [] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modubis", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "name", "tot": "msg" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 960, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 780, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "msg.payload = {\n data : [0,0],\n buffer: Buffer.alloc(3)\n }\n\nmsg.modbusRequest = {\n address : 99,\n quantity : 2\n }\n\n\nif (msg.parts.index === msg.parts.count -1) return [msg,{payload:true}];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1190, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "4a433464d06dc6d8" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1410, "y": 840, "wires": [ [ "4661666a374e732c" ] ] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 740, "y": 940, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] } ]Auch und noch eine kleine Bemerkung:
node.send zu nutzen, sollte man vermeiden und lieber return msg verwenden. Warum manche meinen sie wollen jetzt node.send verwenden, weiß ich nicht. node.send sollte man nur bei asynchroner Verarbeitung nutzen und dann auch mit node.done abschließen. Also sollte das immer der Sonderfall sein.
Hier ein Auszug aus der Online Doku. Was sonst nämlich passieren kann ist, dass die function Node noch weiter wurschtelt und der Flow hinten dran schon munter weiter läuft.
Bei Dir machte das zwar nichts aus, da es der letzte Befehl ist, aber muss ja nicht sein, wenn man mit return msg die function Node korrekt beenden kann.
Fazit aus dem Ganzen: Funktioniert eigentlich wie es soll - nur sollte man warten, bis ein Gerät auch alle Anfragen bearbeiten konnte und deshalb wartet bis die Getter Node wieder aufnahmefähig sind. ;)
Den Rechtschreibfehler in der ChangeNode mit Read Modubis statt Read Modbus im Namen der Change NOde möge man mir verzeihen, deswegen exportiere ich nicht wieder alles neu. ;)
EDIT:
Falls das aber mit der einen GETTER Node nicht funktioniert mit dem Trigger und Dein Flow nur funktioniert, weil Du 3 Getter-Nodes hast, dann muss Dein Flow so bleiben, da nur dann die GETTER Nodes parallel arbeiten können. Oder Du setzt wirklich die Delay Node ein. Die Frage ist halt ob der 2. Ausgang der Getter Node wirklich signalisiert, dass sie fertig ist oder nicht. Wie gesagt, ich tu mir bei dem Ganzen halt schwer, weil ich diese Hardware nicht kenne und deshalb auch die Nodes nicht. Aber in jedem Fall denke ich, hab ich ein paar Alternativen aufgezeigt-@mickym sagte in Node-Red Modbus mehrere Slave ID´s abfragen:
Mir ist auch nicht klar, warum Dein Array oder Deine Objekte soviele Informationen haben (aber vielleicht ist das nur ein anderer Output), wenn Du dann bei Deinem ReadModbus dann die meisten Informationen wieder wegschmeisst.
Das liegt daran, dass ich diese Daten direkt aus dem Modbus Adapter genommen habe. Aber wie du schon bemerkt hast, sind die meisten Daten irrelevant.
So hier ein paar Optimierungsvorschläge: ;)
Nun wie bekannt, bin ich kein Freund von Codierung und function Nodes, wenn es nicht sein muss. Wenn es also um reine Änderungen der payload geht - solltest Du es in meinen Augen vermeiden - dafür gibts die Change Nodes. Wie sowas geht habe ich Dir in meinem Flow mal gezeigt.
Sehr schöne Idee, diese Change Nodes für sowas zu nutzen!
Als erstes habe ich festgestellt, dass Du in Deiner split Node hier msg.parts eingetragen hast - ich weiß das Feld ist rot - aber Du kannst es ignorieren, weil Du ja kein Objekt aufsplittest, sondern ein Array. Insofern gilt das für Dich gar nicht.
Das kam von ein paar vorherigen Versuchen, das ganze zu splitten, Modbus Abfrage und mit dessen Wert, das ganze wieder zusammenzufügen.
Die 2. Variante entspricht in etwa der, die Du jetzt hast, wobei - da alles gleich ist bis auf die ID - ich diese 3 Flows halt zusammengefasst habe. In dem Fall musst Du wirklich mit einer function Nodes arbeiten, da diese einen Kontext hat, der durch das Array der IDs, durch die Du iterieren willst speichern kann und einen zugrhörigen pointer. Mit jeder payload wird der pointer wieder zurückgesetzt.
Die 2. Variante funktioniert nicht. Ich vermute, dass es daran liegt, dass nun jeder Wert einzeln abgefragt wird und dadurch der Trigger next ID aktiviert wird. Durch mein Abfragen der Namen habe ich das verhindert.
Auch und noch eine kleine Bemerkung:
node.send zu nutzen, sollte man vermeiden und lieber return msg verwenden. Warum manche meinen sie wollen jetzt node.send verwenden, weiß ich nicht. node.send sollte man nur bei asynchroner Verarbeitung nutzen und dann auch mit node.done abschließen. Also sollte das immer der Sonderfall sein.Hier ein Auszug aus der Online Doku. Was sonst nämlich passieren kann ist, dass die function Node noch weiter wurschtelt und der Flow hinten dran schon munter weiter läuft.
Bei Dir machte das zwar nichts aus, da es der letzte Befehl ist, aber muss ja nicht sein, wenn man mit return msg die function Node korrekt beenden kann.Danke für diesen Hinweis! Werde ich mir merken.
EDIT:
Es wird mir das topic nicht mitgenommen.
vor dem Read Modbus
Nach dem Read Modbus
-
@mickym sagte in Node-Red Modbus mehrere Slave ID´s abfragen:
Mir ist auch nicht klar, warum Dein Array oder Deine Objekte soviele Informationen haben (aber vielleicht ist das nur ein anderer Output), wenn Du dann bei Deinem ReadModbus dann die meisten Informationen wieder wegschmeisst.
Das liegt daran, dass ich diese Daten direkt aus dem Modbus Adapter genommen habe. Aber wie du schon bemerkt hast, sind die meisten Daten irrelevant.
So hier ein paar Optimierungsvorschläge: ;)
Nun wie bekannt, bin ich kein Freund von Codierung und function Nodes, wenn es nicht sein muss. Wenn es also um reine Änderungen der payload geht - solltest Du es in meinen Augen vermeiden - dafür gibts die Change Nodes. Wie sowas geht habe ich Dir in meinem Flow mal gezeigt.
Sehr schöne Idee, diese Change Nodes für sowas zu nutzen!
Als erstes habe ich festgestellt, dass Du in Deiner split Node hier msg.parts eingetragen hast - ich weiß das Feld ist rot - aber Du kannst es ignorieren, weil Du ja kein Objekt aufsplittest, sondern ein Array. Insofern gilt das für Dich gar nicht.
Das kam von ein paar vorherigen Versuchen, das ganze zu splitten, Modbus Abfrage und mit dessen Wert, das ganze wieder zusammenzufügen.
Die 2. Variante entspricht in etwa der, die Du jetzt hast, wobei - da alles gleich ist bis auf die ID - ich diese 3 Flows halt zusammengefasst habe. In dem Fall musst Du wirklich mit einer function Nodes arbeiten, da diese einen Kontext hat, der durch das Array der IDs, durch die Du iterieren willst speichern kann und einen zugrhörigen pointer. Mit jeder payload wird der pointer wieder zurückgesetzt.
Die 2. Variante funktioniert nicht. Ich vermute, dass es daran liegt, dass nun jeder Wert einzeln abgefragt wird und dadurch der Trigger next ID aktiviert wird. Durch mein Abfragen der Namen habe ich das verhindert.
Auch und noch eine kleine Bemerkung:
node.send zu nutzen, sollte man vermeiden und lieber return msg verwenden. Warum manche meinen sie wollen jetzt node.send verwenden, weiß ich nicht. node.send sollte man nur bei asynchroner Verarbeitung nutzen und dann auch mit node.done abschließen. Also sollte das immer der Sonderfall sein.Hier ein Auszug aus der Online Doku. Was sonst nämlich passieren kann ist, dass die function Node noch weiter wurschtelt und der Flow hinten dran schon munter weiter läuft.
Bei Dir machte das zwar nichts aus, da es der letzte Befehl ist, aber muss ja nicht sein, wenn man mit return msg die function Node korrekt beenden kann.Danke für diesen Hinweis! Werde ich mir merken.
EDIT:
Es wird mir das topic nicht mitgenommen.
vor dem Read Modbus
Nach dem Read Modbus
@malaus Ok das war mein Fehler. Wenn das alles war - ansonsten schau ich gerade - dass man erst wenn sich die id wechselt triggert.
Du musst die Change node im Read Modbus entsprechend ändern, um das topic zu setzen:
Bei Dir war aber der Name auch nicht Bestandteil der payload, sondern im topic:
msg = { topic : msg.name, payload : { 'fc': fc, 'unitid': msg.unitId,//JSON.parse(unitid), 'address': msg._address,//JSON.parse(y.number), 'quantity': 2, 'value': 2 } }Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Ok das war mein Fehler. Wenn das alles war - ansonsten schau ich gerade - dass man erst wenn sich die id wechselt triggert.
Du musst die Change node im Read Modbus entsprechend ändern, um das topic zu setzen:
Bei Dir war aber der Name auch nicht Bestandteil der payload, sondern im topic:
msg = { topic : msg.name, payload : { 'fc': fc, 'unitid': msg.unitId,//JSON.parse(unitid), 'address': msg._address,//JSON.parse(y.number), 'quantity': 2, 'value': 2 } }@mickym ich hätte bei bei dem trigger ein switch benutzt, der Ausschau nach dem letzten Wert hält.
Muss das nicht anders herum sein?
Ich hab ja vor dem Read Modbus ein payload.name
und möchte diese nun als topicDann sollte das doch so aussehen:
Das kommt nach der Änderung zurück:
-
@mickym ich hätte bei bei dem trigger ein switch benutzt, der Ausschau nach dem letzten Wert hält.
Muss das nicht anders herum sein?
Ich hab ja vor dem Read Modbus ein payload.name
und möchte diese nun als topicDann sollte das doch so aussehen:
Das kommt nach der Änderung zurück:
@malaus Nein das sieht nicht andersrum aus. Du musst das Lesen wie es geschrieben ist.
Setze msg.topic auf msg.payload.name. Du willst das topic doch setzen - das vorher gar nicht da war. ;)
Bei mir kommt wenn du die Change Node entsprechend änderst, der Name aus dem ursprünglichen Objekt als payload an:
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Nein das sieht nicht andersrum aus. Du musst das Lesen wie es geschrieben ist.
Setze msg.topic auf msg.payload.name. Du willst das topic doch setzen - das vorher gar nicht da war. ;)
Bei mir kommt wenn du die Change Node entsprechend änderst, der Name aus dem ursprünglichen Objekt als payload an:
-
@malaus Nein das sieht nicht andersrum aus. Du musst das Lesen wie es geschrieben ist.
Setze msg.topic auf msg.payload.name. Du willst das topic doch setzen - das vorher gar nicht da war. ;)
Bei mir kommt wenn du die Change Node entsprechend änderst, der Name aus dem ursprünglichen Objekt als payload an:
Wie sieht der switch aus? ggf. kannst dann auch eine filter Node nehmen. ;)
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Na ja - ich verstehe, weil Du sagst das ist das letzte Element in Deinem array. Dann finde ich es intuitiver und besser - wirklich die id als topic zu nehmen und hab mal eine filter Node verwendet. Ich weiss nicht, ob aus dem unteren Teil einfach die Eingangsobjekte durchgereicht werden. Aber dann spart man sich das topic einfach.
Falls also am unteren Ausgang der GETTER Node einfach das Eingangsobjekt durchkommt:
Für mich wäre dann das am saubersten:
[ { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 730, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 550, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75", "1332eadf8470bb16" ] ] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1080, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 900, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "var newmsg= {\n payload : {\n data : [0,0],\n buffer: Buffer.alloc(3)\n },\n modbusRequest : {\n address : 99,\n quantity : 2\n }\n}\n\n\nreturn [newmsg,msg];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1310, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "7b697360af0a0b1f" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1530, "y": 840, "wires": [ [] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 880, "y": 920, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "7b697360af0a0b1f", "type": "rbe", "z": "7e6af0015415146d", "name": "", "func": "rbe", "gap": "", "start": "", "inout": "out", "septopics": false, "property": "payload.unitid", "topi": "topic", "x": 1310, "y": 980, "wires": [ [ "4a433464d06dc6d8", "d3be5bf799cfff52" ] ] }, { "id": "1332eadf8470bb16", "type": "change", "z": "7e6af0015415146d", "name": "", "rules": [ { "t": "set", "p": "reset", "pt": "msg", "to": "true", "tot": "bool" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 460, "y": 980, "wires": [ [ "7b697360af0a0b1f" ] ] }, { "id": "d3be5bf799cfff52", "type": "debug", "z": "7e6af0015415146d", "name": "new ID", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1500, "y": 980, "wires": [] } ]Dann kann man nämlich auch mal eine andere Reihenfolge beim createArray erstellen verwenden ohne das es Folgen haben würde. ;)
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Na ja - ich verstehe, weil Du sagst das ist das letzte Element in Deinem array. Dann finde ich es intuitiver und besser - wirklich die id als topic zu nehmen und hab mal eine filter Node verwendet. Ich weiss nicht, ob aus dem unteren Teil einfach die Eingangsobjekte durchgereicht werden. Aber dann spart man sich das topic einfach.
Falls also am unteren Ausgang der GETTER Node einfach das Eingangsobjekt durchkommt:
Für mich wäre dann das am saubersten:[ { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 730, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 550, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75", "1332eadf8470bb16" ] ] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1080, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 900, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "var newmsg= {\n payload : {\n data : [0,0],\n buffer: Buffer.alloc(3)\n },\n modbusRequest : {\n address : 99,\n quantity : 2\n }\n}\n\n\nreturn [newmsg,msg];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1310, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "7b697360af0a0b1f" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1530, "y": 840, "wires": [ [] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 880, "y": 920, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "7b697360af0a0b1f", "type": "rbe", "z": "7e6af0015415146d", "name": "", "func": "rbe", "gap": "", "start": "", "inout": "out", "septopics": false, "property": "payload.unitid", "topi": "topic", "x": 1310, "y": 980, "wires": [ [ "4a433464d06dc6d8", "d3be5bf799cfff52" ] ] }, { "id": "1332eadf8470bb16", "type": "change", "z": "7e6af0015415146d", "name": "", "rules": [ { "t": "set", "p": "reset", "pt": "msg", "to": "true", "tot": "bool" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 460, "y": 980, "wires": [ [ "7b697360af0a0b1f" ] ] }, { "id": "d3be5bf799cfff52", "type": "debug", "z": "7e6af0015415146d", "name": "new ID", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "payload", "targetType": "msg", "statusVal": "", "statusType": "auto", "x": 1500, "y": 980, "wires": [] } ]Dann kann man nämlich auch mal eine andere Reihenfolge beim createArray erstellen verwenden ohne das es Folgen haben würde. ;)
Bei debug 19 erhalte ich keine Werte. Der Durchlauf wird nur mit einer ID gemacht.
Den Filter verstehe ich nicht so ganz:
Bei Read Modbus hast du das Topic rausgenommen, ist das so gewollt? Ändert aber auch nichts, wenn ich es wieder einsetze.
-
Bei debug 19 erhalte ich keine Werte. Der Durchlauf wird nur mit einer ID gemacht.
Den Filter verstehe ich nicht so ganz:
Bei Read Modbus hast du das Topic rausgenommen, ist das so gewollt? Ändert aber auch nichts, wenn ich es wieder einsetze.
@malaus Ja ich weiss - ich war der Meinung . dass unten einfach die Eingangsobjekte rauskommen - deswegen habe ich das topic auch wieder raus genommen. Kannst Du mal die Nachrichten, die aus debug 18 rauskommen posten und ist da die ID drin? Ich kann halt immer nur Vermutungen anstellen, was die GETTER Node ausspukt. ;) Am Besten das ganze Nachrichtenobjekt in debug 18 ausgeben lassen und hier in CodeTags einbetten.
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Ja ich weiss - ich war der Meinung . dass unten einfach die Eingangsobjekte rauskommen - deswegen habe ich das topic auch wieder raus genommen. Kannst Du mal die Nachrichten, die aus debug 18 rauskommen posten und ist da die ID drin? Ich kann halt immer nur Vermutungen anstellen, was die GETTER Node ausspukt. ;) Am Besten das ganze Nachrichtenobjekt in debug 18 ausgeben lassen und hier in CodeTags einbetten.
-
Nein ok - ich habe gerade einen Denkfehler gemacht - es wird ja nun bei jedem 1. Element geändert - sorry mein Fehler. Ich werde was einbauen, dass man das letzte Element automatisch erkennt. Sorry - einen Augenblick!!!
Noch eine Frage ich sehe gerade die GETTER node - und deshalb auch der Fehler die queued je ID. ;)Kannst Du mal schauen, ob das letzte Element aus debug 18 queuelength 0 hat?
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
Nein ok - ich habe gerade einen Denkfehler gemacht - es wird ja nun bei jedem 1. Element geändert - sorry mein Fehler. Ich werde was einbauen, dass man das letzte Element automatisch erkennt. Sorry - einen Augenblick!!!
Noch eine Frage ich sehe gerade die GETTER node - und deshalb auch der Fehler die queued je ID. ;)Kannst Du mal schauen, ob das letzte Element aus debug 18 queuelength 0 hat?
-
Ok danke. ;) - Das heißt die queuelänge baut sich auf und wird nur intern abgearbeitet ;)
Die msg.parts Eigenschaft scheint nicht durch zu kommen, sondern nur das topic - dann müssen wir ggf. doch das topic nutzen aber nicht anhand des Namens sondern dann würde ich wirklich nach der msg.parts Eigenschaft das topic setzen.
das heißt wir wissen ja wieviele Elemente kommen und setzten da topic entsprechend.
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
Ok danke. ;) - Das heißt die queuelänge baut sich auf und wird nur intern abgearbeitet ;)
Die msg.parts Eigenschaft scheint nicht durch zu kommen, sondern nur das topic - dann müssen wir ggf. doch das topic nutzen aber nicht anhand des Namens sondern dann würde ich wirklich nach der msg.parts Eigenschaft das topic setzen.
das heißt wir wissen ja wieviele Elemente kommen und setzten da topic entsprechend.
-
@malaus Ok wenn das topic das Einzige war was durchkommt (das msg.parts Objekt wird leider durch die GETTER Node nicht durchgereicht oder ist das enthalten?) , dann nehmen wir im Prinzip deine Lösung, setzen das topic aber nicht einen bestimmten Namen in dem array, sondern lassen einfach runterzählen. ;)
Das sollte dann aber auch tun. ;)
Ist also im Prinzip dein Flow mit dem switch als trigger nur das ich im topic nun die Anzahl der noch zu erwartenden Elemente durchreiche:
[ { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 730, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 550, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modbus", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "parts.count - parts.index - 1", "tot": "jsonata" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1080, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 900, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "var msg2 = {\n topic : msg.topic,\n queueLengthByUnitId : {\n unitID: msg.payload.unitid,\n queueLength: msg.parts.index\n }\n}\n\n\nvar msg1 = {\n payload : {\n data : [0,0],\n buffer: Buffer.alloc(3)\n },\n modbusRequest : {\n address : 99,\n quantity : 2\n }\n}\n\n\nreturn [msg1,msg2];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1310, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "3a68bda0a135f481" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1530, "y": 840, "wires": [ [] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 780, "y": 920, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "315c37ef4aceb5d4", "type": "debug", "z": "7e6af0015415146d", "name": "next ID wenn topic 0 (array zu ende)", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "true", "targetType": "full", "statusVal": "", "statusType": "auto", "x": 1330, "y": 980, "wires": [] }, { "id": "3a68bda0a135f481", "type": "switch", "z": "7e6af0015415146d", "name": "", "property": "topic", "propertyType": "msg", "rules": [ { "t": "eq", "v": "0", "vt": "num" } ], "checkall": "true", "repair": false, "outputs": 1, "x": 1050, "y": 980, "wires": [ [ "4a433464d06dc6d8", "315c37ef4aceb5d4" ] ] } ]Hier konntest Du ja auch nach dem topic filtern: https://forum.iobroker.net/post/947167 - also sollte es jetzt auch gehen.
Wie gesagt Deine Lösung https://forum.iobroker.net/post/947177 funktioniert ja auch - aber mich würde halt stören, dass ich als Marker für das array Ende einen festen Namen im Array verwenden muss. ;)
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Ok wenn das topic das Einzige war was durchkommt (das msg.parts Objekt wird leider durch die GETTER Node nicht durchgereicht oder ist das enthalten?) , dann nehmen wir im Prinzip deine Lösung, setzen das topic aber nicht einen bestimmten Namen in dem array, sondern lassen einfach runterzählen. ;)
Das sollte dann aber auch tun. ;)
Ist also im Prinzip dein Flow mit dem switch als trigger nur das ich im topic nun die Anzahl der noch zu erwartenden Elemente durchreiche:
[ { "id": "36239d1d9d361a2e", "type": "change", "z": "7e6af0015415146d", "name": "create Array", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "[\t {\t \"unitId\": payload,\t \"_address\": 0,\t \"name\": \"Voltage\",\t \"description\": \"Voltage\",\t \"unit\": \"V\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 6,\t \"name\": \"Current\",\t \"description\": \"Current\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 12,\t \"name\": \"ActivePower\",\t \"description\": \"Active Power\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 18,\t \"name\": \"ApparentPower\",\t \"description\": \"ApparentPower\",\t \"unit\": \"VA\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 24,\t \"name\": \"ReactivePower\",\t \"description\": \"ReactivePower\",\t \"unit\": \"VAr\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 30,\t \"name\": \"PowerFactor\",\t \"description\": \"PowerFactor\",\t \"unit\": \"\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 70,\t \"name\": \"Frequency\",\t \"description\": \"Frequency\",\t \"unit\": \"Hz\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 72,\t \"name\": \"ActiveEnergy\",\t \"description\": \"Active Energy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"ExportActiveEnergy\",\t \"description\": \"ExportActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 74,\t \"name\": \"TotalSystemPowerDemand\",\t \"description\": \"TotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"ImportReactiveEnergy\",\t \"description\": \"ImportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 76,\t \"name\": \"MaxTotalSystemPowerDemand\",\t \"description\": \"MaxTotalSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 78,\t \"name\": \"ExportReactiveEnergy\",\t \"description\": \"ExportReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 88,\t \"name\": \"ImportSystemPowerDemand\",\t \"description\": \"ImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 90,\t \"name\": \"MaxImportSystemPowerDemand\",\t \"description\": \"MaxImportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 92,\t \"name\": \"ExportSystemPowerDemand\",\t \"description\": \"ExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 94,\t \"name\": \"MaxExportSystemPowerDemand\",\t \"description\": \"MaxExportSystemPowerDemand\",\t \"unit\": \"W\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 258,\t \"name\": \"CurrentDemand\",\t \"description\": \"CurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 264,\t \"name\": \"MaxCurrentDemand\",\t \"description\": \"MaxCurrentDemand\",\t \"unit\": \"A\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 342,\t \"name\": \"TotalActiveEnergy\",\t \"description\": \"TotalActiveEnergy\",\t \"unit\": \"kWh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t },\t {\t \"unitId\": payload,\t \"_address\": 344,\t \"name\": \"TotalReactiveEnergy\",\t \"description\": \"TotalReactiveEnergy\",\t \"unit\": \"kvarh\",\t \"type\": \"floatbe\",\t \"len\": 2,\t \"factor\": 1,\t \"offset\": 0,\t \"formula\": \"\",\t \"role\": \"level\",\t \"room\": \"\",\t \"cw\": false,\t \"isScale\": false\t }\t]", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 730, "y": 860, "wires": [ [ "833e22472f593063" ] ] }, { "id": "8b8fb28987277d75", "type": "function", "z": "7e6af0015415146d", "name": "Trigger IDs", "func": "if (msg.payload) {\n context.set(\"data\",msg.payload);\n context.set(\"pointer\",0)\n}\nvar array = context.get(\"data\");\nvar pointer = context.get(\"pointer\");\npointer ++;\n\nif ( pointer <= array.length)\n{\n msg.payload = array[pointer - 1];\n context.set(\"pointer\",pointer);\n return msg;\n}\n\n", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 550, "y": 860, "wires": [ [ "36239d1d9d361a2e" ] ] }, { "id": "6521f44463e25c3c", "type": "inject", "z": "7e6af0015415146d", "name": "Mehrere IDs", "props": [ { "p": "payload" } ], "repeat": "", "crontab": "", "once": false, "onceDelay": 0.1, "topic": "", "payload": "[10,11,12]", "payloadType": "json", "x": 230, "y": 860, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "557989f42ddad473", "type": "change", "z": "7e6af0015415146d", "name": "Read Modbus", "rules": [ { "t": "set", "p": "topic", "pt": "msg", "to": "parts.count - parts.index - 1", "tot": "jsonata" }, { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"fc\": 4,\t \"unitid\": payload.unitId,\t \"address\": payload._address,\t \"quantity\": 2,\t \"value\": 2\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1080, "y": 860, "wires": [ [ "0f4f661c760aa72b" ] ] }, { "id": "833e22472f593063", "type": "split", "z": "7e6af0015415146d", "name": "split Array", "splt": "\\n", "spltType": "str", "arraySplt": 1, "arraySpltType": "len", "stream": false, "addname": "", "x": 900, "y": 860, "wires": [ [ "557989f42ddad473" ] ] }, { "id": "0f4f661c760aa72b", "type": "function", "z": "7e6af0015415146d", "name": "Simulate Modbus getter", "func": "var msg2 = {\n topic : msg.topic,\n queueLengthByUnitId : {\n unitID: msg.payload.unitid,\n queueLength: msg.parts.index\n }\n}\n\n\nvar msg1 = {\n payload : {\n data : [0,0],\n buffer: Buffer.alloc(3)\n },\n modbusRequest : {\n address : 99,\n quantity : 2\n }\n}\n\n\nreturn [msg1,msg2];", "outputs": 2, "noerr": 0, "initialize": "", "finalize": "", "libs": [], "x": 1310, "y": 860, "wires": [ [ "5e5a202488c31ae0" ], [ "3a68bda0a135f481" ] ] }, { "id": "5e5a202488c31ae0", "type": "change", "z": "7e6af0015415146d", "name": "WriteModbus", "rules": [ { "t": "set", "p": "payload", "pt": "msg", "to": "{\t \"value\": payload,\t \"fc\": 6,\t \"unitid\" : 1, /* unitId */\t \"address\": modbusRequest.address,\t \"quantity\": modbusRequest.quantity\t}", "tot": "jsonata" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 1530, "y": 840, "wires": [ [] ] }, { "id": "112befc65439e8b7", "type": "comment", "z": "7e6af0015415146d", "name": "Getriggert by Getter Node", "info": "", "x": 230, "y": 800, "wires": [] }, { "id": "4a433464d06dc6d8", "type": "change", "z": "7e6af0015415146d", "name": "Trigger next ID", "rules": [ { "t": "set", "p": "trigger", "pt": "msg", "to": "true", "tot": "bool" }, { "t": "delete", "p": "payload", "pt": "msg" } ], "action": "", "property": "", "from": "", "to": "", "reg": false, "x": 780, "y": 920, "wires": [ [ "8b8fb28987277d75" ] ] }, { "id": "315c37ef4aceb5d4", "type": "debug", "z": "7e6af0015415146d", "name": "next ID wenn topic 0 (array zu ende)", "active": true, "tosidebar": true, "console": false, "tostatus": false, "complete": "true", "targetType": "full", "statusVal": "", "statusType": "auto", "x": 1330, "y": 980, "wires": [] }, { "id": "3a68bda0a135f481", "type": "switch", "z": "7e6af0015415146d", "name": "", "property": "topic", "propertyType": "msg", "rules": [ { "t": "eq", "v": "0", "vt": "num" } ], "checkall": "true", "repair": false, "outputs": 1, "x": 1050, "y": 980, "wires": [ [ "4a433464d06dc6d8", "315c37ef4aceb5d4" ] ] } ]Hier konntest Du ja auch nach dem topic filtern: https://forum.iobroker.net/post/947167 - also sollte es jetzt auch gehen.
Wie gesagt Deine Lösung https://forum.iobroker.net/post/947177 funktioniert ja auch - aber mich würde halt stören, dass ich als Marker für das array Ende einen festen Namen im Array verwenden muss. ;)
@mickym ich musste die zahlen um eins erhöhen, weil der die null nicht wollte aber jetzt funktioniert es.
Die letzte Zahl ist also die 1.Ich habe den Trigger ID´s nochmal angepasst, damit am Ende es automatisch wieder von vorne anfängt.
Ansonsten funktioniert es jetzt.
Danke! -
@mickym ich musste die zahlen um eins erhöhen, weil der die null nicht wollte aber jetzt funktioniert es.
Die letzte Zahl ist also die 1.Ich habe den Trigger ID´s nochmal angepasst, damit am Ende es automatisch wieder von vorne anfängt.
Ansonsten funktioniert es jetzt.
Danke!@malaus Ich habs zwar nicht verstanden, warum die 0 nicht funktioniert - aber wenn es jetzt funktioniert bin ich erst mal raus. Ich denke Du hast das Prinzip ja verstanden. Vielleicht setzt die GETTER Node ein eigenes topic wenn keines gesetzt war und interpretiert deshalb die 0 als falsch. Das kann natürlich sein und Du hast Dir ja dann geholfen. Wie gesagt, ich habe halt keine getter Nodes und tapse deshalb bissi im Dunkeln.
Jeder Flow bzw. jedes Script, das ich hier poste implementiert jeder auf eigene Gefahr. Flows und Scripts können Fehler aufweisen und weder der Seitenbetreiber noch ich persönlich können hierfür haftbar gemacht werden. Das gleiche gilt für Empfehlungen aller Art.
-
@malaus Ich habs zwar nicht verstanden, warum die 0 nicht funktioniert - aber wenn es jetzt funktioniert bin ich erst mal raus. Ich denke Du hast das Prinzip ja verstanden. Vielleicht setzt die GETTER Node ein eigenes topic wenn keines gesetzt war und interpretiert deshalb die 0 als falsch. Das kann natürlich sein und Du hast Dir ja dann geholfen. Wie gesagt, ich habe halt keine getter Nodes und tapse deshalb bissi im Dunkeln.
@mickym mir ist aufgefallen, wenn das ganze mal z.B. durch einen Neustart oä gestoppt wird, nicht von alleine weiter macht. Gibt es bei NodeRed sowas, dass bestimmte Sachen gestartet werden, wenn die Instanz startet?
Ebenfalls habe ich das Gefühl, dass das ganze durch Backitup unterbrochen wird und danach nicht wieder anläuft.Oder ist sinnvoller eine Art Überwachung, wenn nach x Minuten keine neue Variable eingelesen wird, mache Neustart.
Hast du Erfahrung mit sowas? Bzw. hattest du so einen ähnlichen Fall schon mal?
Support us
682
Online32.5k
Benutzer81.8k
Themen1.3m
Beiträge
ioBroker Community 2014-2025
