• Register
    • Login
    • Search
    • Categories
    • Recent
    • Tags
    • Popular
    • Users
    • Groups
    • Search

    unipi1.1. evok to MQTT using Node-Red

    Official EVOK API
    1
    2
    994
    Loading More Posts
    • Oldest to Newest
    • Newest to Oldest
    • Most Votes
    Reply
    • Reply as topic
    Log in to reply
    This topic has been deleted. Only users with topic management privileges can see it.
    • J
      juntiedt last edited by

      I am using this NODE-RED flow to read all unipi data into my MQTT server.
      It initializes all states for my unipi control panel. Then it uses websocket for real time unipi events but with one exception.```
      1-wire sensors are read every 5 min (bulk request) which gives me better statistics and charts.
      I hope this will give interested persons some ideas but also I would appreciate suggestions to make it better.

      [{"id":"f8678f60.d5327","type":"tab","label":"unipi to MQTT","disabled":false,"info":""},{"id":"425e99ca.4a2418","type":"mqtt out","z":"f8678f60.d5327","name":"Relay, input, ai, ao Status","topic":"","qos":"0","retain":"","broker":"f75fab70.b2cd18","x":830,"y":580,"wires":[]},{"id":"29777893.b1a018","type":"function","z":"f8678f60.d5327","name":"format ai","func":"var t_loc = \"home/ug/Buero/unipi/1/\";\nmsg.topic = t_loc + msg.payload.dev + \"/\" + msg.payload.circuit +\"/\";\nif(msg.payload.dev == \"ai\"){\n    msg.payload = msg.payload.value.toFixed(4);    \n}\nelse{\n    msg.payload = msg.payload.value;\n}\nreturn msg;","outputs":1,"noerr":0,"x":640,"y":580,"wires":[["425e99ca.4a2418"]]},{"id":"5ede4ca2.f90cb4","type":"websocket in","z":"f8678f60.d5327","name":"","server":"","client":"990d9908.58cdd8","x":140,"y":580,"wires":[["46654644.1df548"]]},{"id":"a864b8fe.d45638","type":"function","z":"f8678f60.d5327","name":"no temp","func":"if(msg.payload.dev != \"temp\"){\n    return msg;   \n}\n","outputs":1,"noerr":0,"x":500,"y":580,"wires":[["29777893.b1a018"]]},{"id":"f08bf24b.e7a51","type":"function","z":"f8678f60.d5327","name":"temp-1 DS18B20","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/1/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = msg.payload.value;\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":160,"wires":[["3be383a8.548c6c"]]},{"id":"3be383a8.548c6c","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 1","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":160,"wires":[]},{"id":"b3ec1ef1.54292","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 2","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":200,"wires":[]},{"id":"c71ef89e.5b24c8","type":"function","z":"f8678f60.d5327","name":"temp-2 DS18B20","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/2/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = msg.payload.value;\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":200,"wires":[["b3ec1ef1.54292"]]},{"id":"bca1e190.e9d98","type":"function","z":"f8678f60.d5327","name":"temp-3 DS18B20","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/3/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = msg.payload.value;\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":240,"wires":[["f029bb17.3d1618"]]},{"id":"f029bb17.3d1618","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 3","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":240,"wires":[]},{"id":"5ad4d62d.5e80c8","type":"function","z":"f8678f60.d5327","name":"temp-4 DS18B20","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/4/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = msg.payload.value;\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":280,"wires":[["f9333318.bb5a2"]]},{"id":"b4c4344.57a9dc8","type":"function","z":"f8678f60.d5327","name":"humidity DS2438","func":"var vdd = parseFloat(msg.payload.vdd);\nvar vad = parseFloat(msg.payload.vad);\nvar temp = parseFloat(msg.payload.temp);\nvar stdhum = ((vad / vdd) - 0.16) / 0.0062; \nvar truehum = (stdhum / (1.0546 - (0.00216 * temp)));\nmsg.payload = truehum.toFixed(2);\nmsg.payload = msg.payload.trim();\nif (msg.payload > 100){\n    msg.payload = global.get('ghum');\n}\n//\nvar t_loc = \"home/ug/Buero/unipi/1/humidity/1/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\n//\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":420,"wires":[["30b11170.1e2a1e"]]},{"id":"7e250c5f.fd3ee4","type":"function","z":"f8678f60.d5327","name":"temp 6 DS2438","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/6/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = parseFloat(msg.payload.temp);\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1060,"y":460,"wires":[["45936118.dcbbe"]]},{"id":"f9333318.bb5a2","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 4","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":280,"wires":[]},{"id":"30b11170.1e2a1e","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 humidity 1","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1250,"y":420,"wires":[]},{"id":"45936118.dcbbe","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 6","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":460,"wires":[]},{"id":"e5025120.5b355","type":"function","z":"f8678f60.d5327","name":"temp-5 DS2438","func":"var t_loc = \"home/ug/Buero/unipi/1/temp/5/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar output = parseFloat(msg.payload.temp);\nmsg.payload = output.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1060,"y":380,"wires":[["9ed8047c.f3f058"]]},{"id":"9ed8047c.f3f058","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 temp 5","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1240,"y":380,"wires":[]},{"id":"4c1b3270.369abc","type":"function","z":"f8678f60.d5327","name":"light DS2438","func":"var t_loc = \"home/ug/Buero/unipi/1/light/1/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar intensity = parseFloat(msg.payload.vis);\nif(intensity <= 0){\n    intensity = 0.00;\n}\nelse{\n    intensity = intensity * 100/0.25;\n}\nmsg.payload = intensity.toFixed(2);\nmsg.payload = msg.payload.trim();\n//if (msg.payload >= 100){\n//    msg.payload = global.get('glight');\n//}\nreturn msg;","outputs":1,"noerr":0,"x":1070,"y":500,"wires":[["15aedf8f.c552f"]]},{"id":"15aedf8f.c552f","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 light 1","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1230,"y":500,"wires":[]},{"id":"ef3a8f6d.2f621","type":"function","z":"f8678f60.d5327","name":"Pressure DS18B20","func":"var t_loc = \"home/ug/Buero/unipi/1/pressure/1/\";\nt_loc = t_loc + msg.payload.circuit +\"/\";\nmsg.topic = t_loc;\nvar p1 = parseFloat(msg.payload.value);\nvar p2 = (p1*3.2)+700;\nvar prel = p2/Math.pow((1-482/44330), 5.255);\nmsg.payload = prel.toFixed(2);\nreturn msg;","outputs":1,"noerr":0,"x":1050,"y":320,"wires":[["d8a2d644.9554c8"]]},{"id":"d8a2d644.9554c8","type":"mqtt out","z":"f8678f60.d5327","name":"unipi 1 pressure 1","topic":"","qos":"","retain":"","broker":"f75fab70.b2cd18","x":1250,"y":320,"wires":[]},{"id":"97eb1941.4ecc08","type":"function","z":"f8678f60.d5327","name":"","func":"if (msg.payload.circuit === \"28B01DC107000045\"){\n    return [msg,null,null,null,null,null,null];    \n} \nelse if (msg.payload.circuit === \"282836C1070000DD\"){\n    return [null,msg,null,null,null,null,null];    \n}  \nelse if (msg.payload.circuit === \"2892844D07000012\"){\n    return [null,null,msg,null,null,null,null];    \n}  \nelse if (msg.payload.circuit === \"281893C00700005E\"){\n    return [null,null,null,msg,null,null,null];    \n} \nelse if (msg.payload.circuit === \"28A2DC8400000366\"){\n    return [null,null,null,null,msg,null,null];    \n} \nelse if (msg.payload.circuit === \"266B64140200002D\"){\n    return [null,null,null,null,null,msg,null];    \n}\nelse if (msg.payload.circuit === \"2616BF0A020000FC\"){\n    return [null,null,null,null,null,null,msg];    \n}","outputs":7,"noerr":0,"x":770,"y":300,"wires":[["f08bf24b.e7a51"],["c71ef89e.5b24c8"],["bca1e190.e9d98"],["5ad4d62d.5e80c8"],["ef3a8f6d.2f621"],["e5025120.5b355","b4c4344.57a9dc8"],["7e250c5f.fd3ee4","4c1b3270.369abc"]]},{"id":"46654644.1df548","type":"function","z":"f8678f60.d5327","name":"parse JSON","func":"return{payload : JSON.parse(msg.payload)};","outputs":1,"noerr":0,"x":350,"y":580,"wires":[["a864b8fe.d45638"]]},{"id":"b6b92a45.1c8d28","type":"function","z":"f8678f60.d5327","name":"","func":"msg.url = \"http://10.0.0.52:8080/bulk\";\nmsg.headers =JSON.stringify({\"content-type\":\"application/json\"});\nmsg.payload = JSON.stringify({\"group_queries\": [{\"device_types\": [\"temp\",\"relay\",\"input\"]}]});\nreturn msg;\n\n","outputs":1,"noerr":0,"x":250,"y":80,"wires":[["bf0c4b0b.b56638"]]},{"id":"8c0f4577.83b128","type":"inject","z":"f8678f60.d5327","name":"","topic":"","payload":"","payloadType":"date","repeat":"","crontab":"","once":true,"onceDelay":"0.3","x":110,"y":80,"wires":[["b6b92a45.1c8d28"]]},{"id":"bf0c4b0b.b56638","type":"http request","z":"f8678f60.d5327","name":"unipi 1","method":"POST","ret":"obj","url":"","tls":"","x":370,"y":80,"wires":[["b6115323.a444e"]]},{"id":"91f83346.6450f","type":"split","z":"f8678f60.d5327","name":"","splt":"\\n","spltType":"str","arraySplt":1,"arraySpltType":"len","stream":false,"addname":"","x":610,"y":80,"wires":[["6012b09e.6dac6"]]},{"id":"6012b09e.6dac6","type":"function","z":"f8678f60.d5327","name":"","func":"if (msg.payload.dev === \"relay\"){\n    return [msg,null,null];    \n}\nelse if (msg.payload.dev === \"input\"){\n    return [null,msg,null];    \n}\nelse if (msg.payload.dev === \"temp\"){\n    return [null,null,msg];    \n}","outputs":3,"noerr":0,"x":730,"y":80,"wires":[["b8044d09.5d792"],["417274e8.91ca7c"],["97eb1941.4ecc08"]]},{"id":"b6115323.a444e","type":"function","z":"f8678f60.d5327","name":"","func":"return{payload : msg.payload.data.group_queries[0]};","outputs":1,"noerr":0,"x":490,"y":80,"wires":[["91f83346.6450f"]]},{"id":"8a9fbef6.b5fcd","type":"mqtt out","z":"f8678f60.d5327","name":"MQTT relay Status","topic":"","qos":"","retain":"","broker":"813194e1.4ab8a8","x":1050,"y":60,"wires":[]},{"id":"b8044d09.5d792","type":"function","z":"f8678f60.d5327","name":"relay","func":"msg.topic = \"home/ug/Buero/unipi/1/relay/\" + msg.payload.circuit +\"/\";\nmsg.payload = msg.payload.value;\nreturn msg;","outputs":1,"noerr":0,"x":890,"y":60,"wires":[["8a9fbef6.b5fcd"]]},{"id":"417274e8.91ca7c","type":"function","z":"f8678f60.d5327","name":"input","func":"msg.topic = \"home/ug/Buero/unipi/1/input/\" + msg.payload.circuit +\"/\";\nmsg.payload = msg.payload.value;\nreturn msg;","outputs":1,"noerr":0,"x":890,"y":100,"wires":[["8696be09.54cce"]]},{"id":"8696be09.54cce","type":"mqtt out","z":"f8678f60.d5327","name":"MQTT input Status","topic":"","qos":"","retain":"","broker":"813194e1.4ab8a8","x":1050,"y":100,"wires":[]},{"id":"c2c30d37.de6ae","type":"inject","z":"f8678f60.d5327","name":"","topic":"","payload":"","payloadType":"date","repeat":"300","crontab":"","once":false,"onceDelay":0.1,"x":110,"y":300,"wires":[["f5f849f5.62eb48"]]},{"id":"f5f849f5.62eb48","type":"function","z":"f8678f60.d5327","name":"","func":"msg.url = \"http://10.0.0.52:8080/bulk\";\nmsg.headers =JSON.stringify({\"content-type\":\"application/json\"});\nmsg.payload = JSON.stringify({\"group_queries\": [{\"device_types\": [\"temp\"]}]});\nreturn msg;\n\n","outputs":1,"noerr":0,"x":250,"y":300,"wires":[["6f854ab0.64d634"]]},{"id":"6f854ab0.64d634","type":"http request","z":"f8678f60.d5327","name":"unipi 1","method":"POST","ret":"obj","url":"","tls":"","x":370,"y":300,"wires":[["7fbfe0ea.7be2f"]]},{"id":"f3df64d3.5075e8","type":"split","z":"f8678f60.d5327","name":"","splt":"\\n","spltType":"str","arraySplt":1,"arraySpltType":"len","stream":false,"addname":"","x":610,"y":300,"wires":[["97eb1941.4ecc08"]]},{"id":"7fbfe0ea.7be2f","type":"function","z":"f8678f60.d5327","name":"","func":"return{payload : msg.payload.data.group_queries[0]};","outputs":1,"noerr":0,"x":490,"y":300,"wires":[["f3df64d3.5075e8"]]},{"id":"597a13df.071aec","type":"comment","z":"f8678f60.d5327","name":"Initialisation  (bulk request)","info":"","x":130,"y":40,"wires":[]},{"id":"c29cc9fa.d7b108","type":"comment","z":"f8678f60.d5327","name":"read 1-Wire every 5 minutes (bulk request)","info":"","x":180,"y":260,"wires":[]},{"id":"60c51296.d7872c","type":"comment","z":"f8678f60.d5327","name":"websocket receive realtime events of unipi","info":"","x":180,"y":540,"wires":[]},{"id":"f75fab70.b2cd18","type":"mqtt-broker","z":"","broker":"10.0.0.43","port":"1883","clientid":"","usetls":false,"compatmode":true,"keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","willTopic":"","willQos":"0","willPayload":""},{"id":"990d9908.58cdd8","type":"websocket-client","z":"","path":"ws://10.0.0.52:8080/ws","tls":"","wholemsg":"false"},{"id":"813194e1.4ab8a8","type":"mqtt-broker","z":"","broker":"10.0.0.43","port":"1883","clientid":"","usetls":false,"compatmode":true,"keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthPayload":"","willTopic":"","willQos":"0","willPayload":""}]
      1 Reply Last reply Reply Quote 0
      • J
        juntiedt last edited by

        0_1551607450428_unipi-mqttt.JPG

        1 Reply Last reply Reply Quote 0
        • First post
          Last post