A flow that's collect mqtt meassages from Husdatas H60 gateway. Store it in GlobarVars uses Influxdb and Initialstate Rest API.
A flow that's collect mqtt meassages from Husdatas H60 gateway. Store it in GlobarVars uses Influxdb and Initialstate Rest API.
https://husdata.se/produkter.asp?prodid=14
[{"id":"b84964ae.d21338","type":"tab","label":"Nibe geothermal heat pump","disabled":false,"info":""},{"id":"85bd383.339d7c8","type":"debug","z":"b84964ae.d21338","name":"","active":false,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","x":850,"y":140,"wires":[]},{"id":"9e4e0e5d.1b74e","type":"comment","z":"b84964ae.d21338","name":"mqtt message ","info":"","x":74.60000610351562,"y":71.60000610351562,"wires":[]},{"id":"9abe7619.bd0358","type":"function","z":"b84964ae.d21338","name":"splitup to GVL & out to UI","func":"if (msg.topic === \"fcf5c492d7f6/HP/0003\") {\n msg.topic = \"RadRetur\";\n var GlobalNibe1 = msg.payload;\n global.set(\"P-RadRetur\", GlobalNibe1); // P = Payload \n global.set(\"T-RadRetur\", msg.topic); // T = Topic\n return [msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0004\") {\n msg.topic = \"RadTill\";\n var GlobalNibe2 = msg.payload;\n global.set(\"P-RadTill\", GlobalNibe2); // P = Payload\n global.set(\"T-RadTill\", msg.topic); // T = Topic\n return [null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0001\") {\n msg.topic = \"HeatRetur\";\n var GlobalNibe3 = msg.payload;\n global.set(\"P-HeatRetur\", GlobalNibe3); // P = Payload\n global.set(\"T-HeatRetur\", msg.topic); // T = Topic\n return [null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0002\") {\n msg.topic = \"HeatTill\";\n var GlobalNibe4 = msg.payload;\n global.set(\"P-HeatTill\", GlobalNibe4); // P = Payload\n global.set(\"T-HeatTill\", msg.topic); // T = Topic\n return [null, null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0005\") {\n msg.topic = \"BrineIn\";\n var GlobalNibe5 = msg.payload;\n global.set(\"P-BrineIn\", GlobalNibe5); // P = Payload\n global.set(\"T-BrineIn\", msg.topic); // T = Topic\n return [null, null, null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null,null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0006\") {\n msg.topic = \"BrineUt\";\n var GlobalNibe6 = msg.payload;\n global.set(\"P-BrineUt\", GlobalNibe6); // P = Payload\n global.set(\"T-BrineUt\", msg.topic); // T = Topic\n return [null, null, null, null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0007\") {\n msg.topic = \"Utetemp\";\n var GlobalNibe7 = msg.payload;\n global.set(\"P-Utetemp\", GlobalNibe7); // P = Payload\n global.set(\"T-Utetemp\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0008\") {\n msg.topic = \"Innetemp\";\n var GlobalNibe8 = msg.payload;\n global.set(\"P-Innetemp\", GlobalNibe8); // P = Payload\n global.set(\"T-Innetemp\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, msg, null, null, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/000B\") {\n msg.topic = \"HetGas\";\n var GlobalNibe9 = msg.payload;\n global.set(\"P-HetGas\", GlobalNibe9); // P = Payload\n global.set(\"T-HetGas\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, msg, null,null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/3104\") {\n msg.topic = \"Eltillsats\";\n var GlobalNibe10 = msg.payload;\n global.set(\"P-Eltillsats\", GlobalNibe10); // P = Payload\n global.set(\"T-Eltillsats\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/4101\") {\n msg.topic = \"FasL1\";\n var GlobalNibe11 = msg.payload;\n global.set(\"P-FasL1\", GlobalNibe11); // P = Payload\n global.set(\"T-FasL1\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/4102\") {\n msg.topic = \"FasL2\";\n var GlobalNibe12 = msg.payload;\n global.set(\"P-FasL2\", GlobalNibe12); // P = Payload\n global.set(\"T-FasL2\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/4103\") {\n msg.topic = \"FasL3\";\n var GlobalNibe13 = msg.payload;\n global.set(\"P-FasL3\", GlobalNibe13); // P = Payload\n global.set(\"T-FasL3\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/8105\") {\n msg.topic = \"Gradminuter\";\n var GlobalNibe14 = msg.payload;\n global.set(\"P-Gradminuter\", GlobalNibe14); // P = Payload\n global.set(\"T-Gradminuter\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/0107\") {\n msg.topic = \"Setpoint\";\n var GlobalNibe15 = msg.payload;\n global.set(\"P-Setpoint\", GlobalNibe15); // P = Payload\n global.set(\"T-Setpoint\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/1A01\") {\n msg.topic = \"Kompressor\";\n var GlobalNibe16 = msg.payload;\n global.set(\"P-Kompressor\", GlobalNibe16); // P = Payload\n global.set(\"T-Kompressor\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/1A04\") {\n msg.topic = \"Brinepump\";\n var GlobalNibe17 = msg.payload;\n global.set(\"P-Brinepump\", GlobalNibe17); // P = Payload\n global.set(\"T-Brinepump\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, msg, null, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/1A05\") {\n msg.topic = \"Vspump\";\n var GlobalNibe18 = msg.payload;\n global.set(\"P-Vspump\", GlobalNibe18); // P = Payload\n global.set(\"T-Vspump\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null,null , msg, null, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/2A20\") {\n msg.topic = \"alarm\";\n var GlobalNibe19 = msg.payload;\n global.set(\"P-alarm\", GlobalNibe19); // P = Payload\n global.set(\"T-alarm\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null,null, msg, null];\n}\nelse if (msg.topic === \"fcf5c492d7f6/HP/2A20\") {\n msg.topic = \"VvVsVentil\";\n var GlobalNibe20 = msg.payload;\n global.set(\"P-VvVsVentil\", GlobalNibe20); // P = Payload\n global.set(\"T-VvVsVentil\", msg.topic); // T = Topic\n return [null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, msg];\n}","outputs":20,"noerr":0,"x":510,"y":140,"wires":[["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"],["85bd383.339d7c8"]]},{"id":"cfbb3396.c6d7e","type":"function","z":"b84964ae.d21338","name":"GVL to Influxdb","func":"msg1 = {};\nmsg2 = {};\nmsg3 = {};\nmsg4 = {};\nmsg5 = {};\nmsg6 = {};\nmsg7 = {};\nmsg8 = {};\nmsg9 = {};\nmsg10 = {};\nmsg11 = {};\nmsg12 = {};\nmsg13 = {};\nmsg14 = {};\nmsg15 = {};\nmsg16 = {};\nmsg17 = {};\nmsg18 = {};\nmsg19 = {};\nmsg20 = {};\n\nmsg1.payload = global.get(\"P-RadRetur\");\nmsg1.topic = global.get(\"T-RadRetur\");\n\nmsg2.payload = global.get(\"P-RadTill\");\nmsg2.topic = global.get(\"T-RadTill\");\n\nmsg3.payload = global.get(\"P-HeatRetur\");\nmsg3.topic = global.get(\"T-HeatRetur\");\n\nmsg4.payload = global.get(\"P-HeatTill\");\nmsg4.topic = global.get(\"T-HeatTill\");\n\nmsg5.payload = global.get(\"P-BrineIn\");\nmsg5.topic = global.get(\"T-BrineIn\");\n\nmsg6.payload = global.get(\"P-BrineUt\");\nmsg6.topic = global.get(\"T-BrineUt\");\n\nmsg7.payload = global.get(\"P-innetemp\");\nmsg7.topic = global.get(\"T-innetemp\");\n\nmsg8.payload = global.get(\"P-Utetemp\");\nmsg8.topic = global.get(\"T-Utetemp\");\n\nmsg9.payload = global.get(\"P-HetGas\");\nmsg9.topic = global.get(\"T-HetGas\");\n\nmsg10.payload = global.get(\"P-Eltillsats\");\nmsg10.topic = global.get(\"T-Eltillsats\");\n\nmsg11.payload = global.get(\"P-FasL1\");\nmsg11.topic = global.get(\"T-FasL1\");\n\nmsg12.payload = global.get(\"P-FasL2\");\nmsg12.topic = global.get(\"T-FasL2\");\n\nmsg13.payload = global.get(\"P-FasL3\");\nmsg13.topic = global.get(\"T-FasL3\");\n\nmsg14.payload = global.get(\"P-Gradminuter\");\nmsg14.topic = global.get(\"T-Gradminuter\");\n\nmsg15.payload = global.get(\"P-Setpoint\");\nmsg15.topic = global.get(\"T-Setpoint\");\n\nmsg16.payload = global.get(\"P-Kompressor\");\nmsg16.topic = global.get(\"T-Kompressor\");\n\nmsg17.payload = global.get(\"P-Brinepump\");\nmsg17.topic = global.get(\"T-Brinepump\");\n\nmsg18.payload = global.get(\"P-Vspump\");\nmsg18.topic = global.get(\"T-Vspump\");\n\nmsg19.payload = global.get(\"P-alarm\");\nmsg19.topic = global.get(\"T-alarm\");\n\nmsg20.payload = global.get(\"P-VvVsVentil\");\nmsg20.topic = global.get(\"T-VvVsVentil\");\n\nreturn [msg1, msg2, msg3, msg4, msg5, msg6, msg7, msg8, msg9, msg10, msg11, msg12, msg13, msg14, msg15, msg16, msg17, msg18, msg19, msg20];\n","outputs":20,"noerr":0,"x":460,"y":500,"wires":[["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"],["d2446201.fac75"]]},{"id":"9393af8d.99edb","type":"function","z":"b84964ae.d21338","name":"GVL to InitialState","func":"msg1 = {};\nmsg2 = {};\nmsg3 = {};\nmsg4 = {};\nmsg5 = {};\nmsg6 = {};\nmsg7 = {};\nmsg8 = {};\nmsg9 = {};\nmsg10 = {};\nmsg11 = {};\nmsg12 = {};\nmsg13 = {};\nmsg14 = {};\nmsg15 = {};\nmsg16 = {};\nmsg17 = {};\nmsg18 = {};\nmsg19 = {};\nmsg20 = {};\n\nmsg1.payload = global.get(\"P-RadRetur\");\nmsg1.topic = global.get(\"T-RadRetur\");\n\nmsg2.payload = global.get(\"P-RadTill\");\nmsg2.topic = global.get(\"T-RadTill\");\n\nmsg3.payload = global.get(\"P-HeatRetur\");\nmsg3.topic = global.get(\"T-HeatRetur\");\n\nmsg4.payload = global.get(\"P-HeatTill\");\nmsg4.topic = global.get(\"T-HeatTill\");\n\nmsg5.payload = global.get(\"P-BrineIn\");\nmsg5.topic = global.get(\"T-BrineIn\");\n\nmsg6.payload = global.get(\"P-BrineUt\");\nmsg6.topic = global.get(\"T-BrineUt\");\n\nmsg7.payload = global.get(\"P-innetemp\");\nmsg7.topic = global.get(\"T-innetemp\");\n\nmsg8.payload = global.get(\"P-Utetemp\");\nmsg8.topic = global.get(\"T-Utetemp\");\n\nmsg9.payload = global.get(\"P-HetGas\");\nmsg9.topic = global.get(\"T-HetGas\");\n\nmsg10.payload = global.get(\"P-Eltillsats\");\nmsg10.topic = global.get(\"T-Eltillsats\");\n\nmsg11.payload = global.get(\"P-FasL1\");\nmsg11.topic = global.get(\"T-FasL1\");\n\nmsg12.payload = global.get(\"P-FasL2\");\nmsg12.topic = global.get(\"T-FasL2\");\n\nmsg13.payload = global.get(\"P-FasL3\");\nmsg13.topic = global.get(\"T-FasL3\");\n\nmsg14.payload = global.get(\"P-Gradminuter\");\nmsg14.topic = global.get(\"T-Gradminuter\");\n\nmsg15.payload = global.get(\"P-Setpoint\");\nmsg15.topic = global.get(\"T-Setpoint\");\n\nmsg16.payload = global.get(\"P-Kompressor\");\nmsg16.topic = global.get(\"T-Kompressor\");\n\nmsg17.payload = global.get(\"P-Brinepump\");\nmsg17.topic = global.get(\"T-Brinepump\");\n\nmsg18.payload = global.get(\"P-Vspump\");\nmsg18.topic = global.get(\"T-Vspump\");\n\nmsg19.payload = global.get(\"P-alarm\");\nmsg19.topic = global.get(\"T-alarm\");\n\nmsg20.payload = global.get(\"P-VvVsVentil\");\nmsg20.topic = global.get(\"T-VvVsVentil\");\n\nreturn [msg1, msg2, msg3, msg4, msg5, msg6, msg7, msg8, msg9, msg10, msg11, msg12, msg13, msg14, msg15, msg16, msg17, msg18, msg19, msg20];\n","outputs":20,"noerr":0,"x":450,"y":840,"wires":[["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"],["e9556b71.d7cd88"]]},{"id":"4e8b4425.f960cc","type":"inject","z":"b84964ae.d21338","name":"","topic":"","payload":"","payloadType":"date","repeat":"60","crontab":"","once":false,"onceDelay":0.1,"x":150,"y":500,"wires":[["cfbb3396.c6d7e"]]},{"id":"ab3756ec.b47058","type":"inject","z":"b84964ae.d21338","name":"","topic":"","payload":"","payloadType":"date","repeat":"300","crontab":"","once":false,"onceDelay":0.1,"x":150,"y":840,"wires":[["9393af8d.99edb"]]},{"id":"9ffba400.1df89","type":"mqtt in","z":"b84964ae.d21338","name":"NIBE Heatpump","topic":"+/HP/#","qos":"2","datatype":"auto","broker":"1413f426.0dc69c","x":200,"y":140,"wires":[["9abe7619.bd0358"]]},{"id":"e9556b71.d7cd88","type":"initialstate","z":"b84964ae.d21338","name":"Initialstate Push","bucketKey":"","accessKey":"","x":840,"y":760,"wires":[]},{"id":"d2446201.fac75","type":"function","z":"b84964ae.d21338","name":"Mqtt to InfluxDB","func":"var tokens = msg.topic;\nmsg.url =\"http://192.168.1.10:8086/write?db=nibe\";\nmsg.payload = \" device=\" + msg.topic + \" value=\" + msg.payload;\nreturn msg;","outputs":1,"noerr":0,"x":800,"y":420,"wires":[["91df907e.f1011"]]},{"id":"91df907e.f1011","type":"http request","z":"b84964ae.d21338","name":"","method":"POST","ret":"txt","paytoqs":false,"url":"http://192.168.1.10:8086/write?db=nibe","tls":"","persist":false,"proxy":"","authType":"","x":990,"y":420,"wires":[[]]},{"id":"1413f426.0dc69c","type":"mqtt-broker","z":"","name":"","broker":"192.168.1.10","port":"1883","clientid":"","usetls":false,"compatmode":false,"keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","closeTopic":"","closeQos":"0","closePayload":"","willTopic":"","willQos":"0","willPayload":""}]
