The data collected by the ispindle IoT can be forwarded to a server, MQTT broker, brewery web site, ...
The following node-red flow has been designed to collect from a MQTT broker running on a laptop (or raspberry pi)
the data which are then enriched in order to post them on ubidots
Before to start the flow locally, install node-red and mosquitto as MQTT broker
Edit the mosquitto config file (e.g: /usr/local/etc/mosquitto/mosquitto.conf) to append the following 2 parameters supporting to access the broker without user/pwd and to use non localhost as hostname
listener 1883
allow_anonymous true
Open a terminal, start the MQTT broker (e.g: `brew services start mosquitto)
To be able to work with the ubidots_out node flow, it is needed to specify as token your own API Token that you can find here
within the ubidots_dots config
{
"id": "9882cb140721248b",
"type": "ubidots_out",
"z": "a490cb4b563e3faf",
"name": "",
"token": "BBFF-xxxxxxxxTO_BE_CHANGEDxxxxxx",
...Change also the mqtt-broker object to specify the IP address (see broker) of yourpi, laptop where the MQTT broker is running
like also thename to be used (e.g mosquitto-mac`)
{
"id": "e7a90bd264380835",
"type": "mqtt-broker",
"name": "mosquitto-mac",
"broker": "192.168.1.90",
"port": "1883",
...When done, you can launch node-red using the following flow
export DEVICE_NAME="ispindle001"
node-red ./flows/ispindle-mqtt-ubidots.jsonNOTE: Don't forget to pass as parameter the device name to be used to report the data under https://stem.ubidots.com/app/devices/ web page
node-red and ubidots: https://help.ubidots.com/en/articles/1440402-connect-node-red-with-ubidots
from mqtt topics created by ispindle -> to ubidots_out (= another mqtt broker) where density is calculated from gravity
[
{
"id": "a490cb4b563e3faf",
"type": "tab",
"label": "ispindle-mqtt-ubidots",
"disabled": false,
"info": "",
"env": []
},
{
"id": "9882cb140721248b",
"type": "ubidots_out",
"z": "a490cb4b563e3faf",
"name": "",
"token": "BBFF-xxxxxx",
"label_device": "",
"device_label": "MacDabou_x",
"tier": "educational",
"tls_checkbox": true,
"x": 890,
"y": 160,
"wires": []
},
{
"id": "bf0fb6917ad986ab",
"type": "mqtt in",
"z": "a490cb4b563e3faf",
"name": "Ispindel001",
"topic": "ispindel/Ispindel001/#",
"qos": "2",
"datatype": "auto",
"broker": "e7a90bd264380835",
"nl": false,
"rap": true,
"rh": 0,
"inputs": 0,
"x": 100,
"y": 80,
"wires": [
[
"189e3da5981418b1"
]
]
},
{
"id": "d1d642a53b8169ed",
"type": "debug",
"z": "a490cb4b563e3faf",
"name": "",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "payload",
"targetType": "msg",
"statusVal": "",
"statusType": "auto",
"x": 890,
"y": 80,
"wires": []
},
{
"id": "189e3da5981418b1",
"type": "function",
"z": "a490cb4b563e3faf",
"name": "enrich_messages",
"func": "var deviceLabel = env.get('DEVICE_NAME')\nvar label, new_payload\nvar topic_prefix = \"ispindel/Ispindel001\"\n\nswitch (msg.topic) {\n case topic_prefix + \"/tilt\":\n label = \"tilt\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break;\n \n case topic_prefix + \"/battery\":\n label = \"battery\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break;\n \n case topic_prefix + \"/temperature\":\n label = \"temperature\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break;\n \n case topic_prefix + \"/gravity\":\n label = \"gravity\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break;\n \n case topic_prefix + \"/RSSI\":\n label = \"RSSI\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break;\n\n case topic_prefix + \"/interval\":\n label = \"interval\";\n new_payload = {[label]: parseFloat(msg.payload)};\n break; \n \n case topic_prefix + \"/temp_units\":\n label = \"temp_units\";\n // new_payload = {[label]: {value: msg.payload}};\n new_payload = {[label]: {value: 1, context: {units: \"°C\"}}}\n break; \n}\n\n\nmsg.topic = label \nmsg.payload = new_payload\nmsg.payload.ubidotsDeviceLabel = deviceLabel\n\n// node.log(\"Device name: \" + env.get('DEVICE_NAME'))\n\nnode.log(\"Payload: \" + JSON.stringify(msg.payload))\nnode.log(\"Topic : \" + msg.topic)\n \nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 330,
"y": 80,
"wires": [
[
"05c0f15d683d6d25"
]
]
},
{
"id": "d1a744cf2741bc63",
"type": "comment",
"z": "a490cb4b563e3faf",
"name": "ispindle name",
"info": "The device name defined part of the ispindle configuration should match exactly the `DEVICE_NAME` of the topic\n\nexample:\n\nDEVICENAME=\"Ispindle001\"\n\n->\n\nTOPIC=\"ispindle/$DEVICENAME/#\"",
"x": 210,
"y": 300,
"wires": []
},
{
"id": "05c0f15d683d6d25",
"type": "join",
"z": "a490cb4b563e3faf",
"name": "",
"mode": "custom",
"build": "merged",
"property": "payload",
"propertyType": "msg",
"key": "topic",
"joiner": "\\n",
"joinerType": "str",
"accumulate": false,
"timeout": "5",
"count": "",
"reduceRight": false,
"reduceExp": "",
"reduceInit": "",
"reduceInitType": "",
"reduceFixup": "",
"x": 530,
"y": 80,
"wires": [
[
"5cb2a16a39de19ee"
]
]
},
{
"id": "a9d9ffa86e798a29",
"type": "mqtt out",
"z": "a490cb4b563e3faf",
"name": "",
"topic": "ispindel/Ispindel001/tilt",
"qos": "2",
"retain": "",
"respTopic": "",
"contentType": "application/json",
"userProps": "",
"correl": "",
"expiry": "",
"broker": "e7a90bd264380835",
"x": 330,
"y": 160,
"wires": []
},
{
"id": "2e8bc76c70ad6df3",
"type": "inject",
"z": "a490cb4b563e3faf",
"name": "tilt",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "tilt",
"payload": "23.24",
"payloadType": "num",
"x": 110,
"y": 160,
"wires": [
[
"a9d9ffa86e798a29"
]
]
},
{
"id": "cf148097a0c4e7a4",
"type": "mqtt out",
"z": "a490cb4b563e3faf",
"name": "",
"topic": "ispindel/Ispindel001/gravity",
"qos": "2",
"retain": "",
"respTopic": "",
"contentType": "application/json",
"userProps": "",
"correl": "",
"expiry": "",
"broker": "e7a90bd264380835",
"x": 340,
"y": 220,
"wires": []
},
{
"id": "abb5f2116cea26f5",
"type": "inject",
"z": "a490cb4b563e3faf",
"name": "gravity",
"props": [
{
"p": "payload"
},
{
"p": "topic",
"vt": "str"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "gravity",
"payload": "0.59",
"payloadType": "num",
"x": 110,
"y": 220,
"wires": [
[
"cf148097a0c4e7a4"
]
]
},
{
"id": "5cb2a16a39de19ee",
"type": "function",
"z": "a490cb4b563e3faf",
"name": "gravity-to-sg",
"func": "var density = 1+(msg.payload.gravity/(258.6-((msg.payload.gravity/258.2)*227.1)))\n\nnode.log(\"#### Density: \" + density)\n\nmsg.payload.density = density\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 710,
"y": 80,
"wires": [
[
"d1d642a53b8169ed",
"9882cb140721248b"
]
]
},
{
"id": "e7a90bd264380835",
"type": "mqtt-broker",
"name": "mosquitto-mac",
"broker": "192.168.1.90",
"port": "1883",
"clientid": "",
"autoConnect": true,
"usetls": false,
"protocolVersion": "4",
"keepalive": "60",
"cleansession": true,
"birthTopic": "",
"birthQos": "0",
"birthPayload": "",
"birthMsg": {},
"closeTopic": "",
"closeQos": "0",
"closePayload": "",
"closeMsg": {},
"willTopic": "",
"willQos": "0",
"willPayload": "",
"willMsg": {},
"sessionExpiry": ""
}
]