Node-RED - with InfluxDB - Revision history

Tinker: /* Connecting to the Database */

2021-03-27T02:15:24Z

Connecting to the Database

Tinker: /* Connecting to the Database */

2021-03-27T02:13:46Z

Connecting to the Database

Tinker: /* Getting data from the Database */

2020-12-02T00:03:54Z

Getting data from the Database

Tinker: /* Sending data to the Database */

2020-12-01T23:29:25Z

Sending data to the Database

Tinker: /* Connecting to the Database */

2020-12-01T23:24:46Z

Connecting to the Database

Tinker: /* Getting data from the Database */

2020-12-01T23:23:58Z

Getting data from the Database

Tinker: /* Sending data to the Database */

2020-12-01T23:22:00Z

Sending data to the Database

Tinker: Created page with "== First things == # Install the '''[https://flows.nodered.org/node/node-red-contrib-influxdb node-red-contrib-influxdb]''' Palette. (You'll kinda need it.) # InfluxDB#Set..."

2020-12-01T23:20:07Z

Created page with "== First things == # Install the '''[https://flows.nodered.org/node/node-red-contrib-influxdb node-red-contrib-influxdb]''' Palette. (You'll kinda need it.) # InfluxDB#Set..."

New page

== First things ==

# Install the '''[https://flows.nodered.org/node/node-red-contrib-influxdb node-red-contrib-influxdb]''' Palette. (You'll kinda need it.)
# [[InfluxDB#Setting up a Database|Create a database]] in InfluxDB for use from Node-Red.
#* I'll be using a test DB named <code>FooBar</code>
#* I'll also be using input from a Tasmota-based BME280 sensor device.

== Connecting to the Database ==
The first time to add an '''influxdb''' node to a flow, its Server box will contain ''Add a new influxdb...''

# Click the edit button (pencil icon) next to the box.
# Enter the hostname or IP of the host running InfluxDB.
# Fill in the '''Database''' box (FooBar in these examples).
# Fill in the '''Username''' and '''Password''' boxes if you've set up the database to require them.
# Put something meaningful in the '''Name''' box. (I put ''InfluxDB Testing'')
# Click the '''Add''' button.

== Sending data to the Database ==
[[File:Feeding.png|frameless|800x800px]]

The '''MQTT in''' node is subscribed to <code>tele/Inside_Weather/SENSOR</code>

The '''JSON node''' simply ensures that any data being passed forward is passed as JSON

The '''FUNCTION node''' formats the data into what InfluxDB wants to see.

Its content:<blockquote>msg.measurement = "Readings"

msg.payload = {Sensor:"Inside_Weather",

Temperature:msg.payload.BME280.Temperature,

Humidity:msg.payload.BME280.Humidity,

DewPoint:msg.payload.BME280.DewPoint,

Pressure:msg.payload.BME280.Pressure

};

return msg;</blockquote>The '''InfluxDB out''' node sends the data to the database. (At this point, the only thing entered into the '''Properties''' of this node is the '''Server''' entry we created above)

This creates an entry in a table named '''Readings''' with 4 data-points in the database every time the device spits out SENSOR telemetry. (Temperature, Humidity, DewPoint & Pressure)

== Getting data from the Database ==
[[File:Regurgitating.png|frameless|800x800px]]

The '''INJECT node''' injects a timestamp

The first '''FUNCTION node''' generates the QUERY for the database

Its content:<blockquote>msg.query = "SELECT Temperature, Humidity, DewPoint, Pressure FROM Readings Where Sensor = 'Inside_Weather' and time > now() -" + msg.payload;

return msg;</blockquote>The '''InfluxDB in node''' sends the query off to the database. (Again, at this point, the only thing entered into the '''Properties''' of this node is the '''Server''' entry we created above)

The second '''FUNCTION node''' formats the data to be passed on to the '''CHART node'''

Its content:
var series = ["temp DegC"];

var labels = ["Data Values"];

var data = "[[";

var thetime;

for (var i=0; i < msg.payload.length; i++) {

thetime = Number(msg.payload[i].time); // Some manipulation of the time may be required

data += '{ "x":' + thetime + ', "y":' + msg.payload[i].Temperature + '}';

if (i < (msg.payload.length - 1)) {

data += ","

} else {

data += "]]"

}

}

var jsondata = JSON.parse(data);

msg.payload = [{"series": series, "data": jsondata, "labels": labels}];

return msg;
(yup... that's every bit as FUGLY as it seems...)

The '''CHART node''' puts the data out on a dashboard.

@@ Line 12: / Line 12: @@
 #Enter the hostname or IP of the host running InfluxDB.
 #Fill in the '''Database''' box (FooBar in these examples).
-#Fill in the '''Measurement''' box (Readings in tese examples).
+#Fill in the '''Measurement''' box (Readings in these examples).
 #Fill in the '''Username''' and '''Password''' boxes if you've set up the database to require them.
 #Put something meaningful in the '''Name''' box. (I put ''InfluxDB Testing'')

@@ Line 12: / Line 12: @@
 #Enter the hostname or IP of the host running InfluxDB.
 #Fill in the '''Database''' box (FooBar in these examples).
 #Fill in the '''Username''' and '''Password''' boxes if you've set up the database to require them.
 #Put something meaningful in the '''Name''' box. (I put ''InfluxDB Testing'')

@@ Line 50: / Line 50: @@
 [[File:Regurgitating.png|frameless|800x800px]]
-The '''INJECT node''' injects a timestamp
+The '''INJECT node''' just triggers the sequence.  (You could replace this with any kind of trigger you like.  You could even inject things to cause the '''Create Query''' function to modify the query...)
 The first '''FUNCTION node''' generates the QUERY for the database
@@ Line 56: / Line 56: @@
 Its content:
-<blockquote>msg.query = "SELECT Temperature, Humidity, DewPoint, Pressure FROM Readings Where Sensor = 'Inside_Weather' and time > now() -" + msg.payload;
+<blockquote>msg.query = "SELECT Temperature, Humidity, DewPoint, Pressure FROM Readings Where Sensor = 'Inside_Weather'";
 return msg;</blockquote>

@@ Line 1: / Line 1: @@
-== First things ==
+==First things==
-# Install the '''[https://flows.nodered.org/node/node-red-contrib-influxdb node-red-contrib-influxdb]''' Palette.  (You'll kinda need it.)
+#Install the '''[https://flows.nodered.org/node/node-red-contrib-influxdb node-red-contrib-influxdb]''' Palette.  (You'll kinda need it.)
-# [[InfluxDB#Setting up a Database|Create a database]] in InfluxDB for use from Node-Red.
+#[[InfluxDB#Setting up a Database|Create a database]] in InfluxDB for use from Node-Red.
-#* I'll be using a test DB named <code>FooBar</code>
+#*I'll be using a test DB named <code>FooBar</code>
-#* I'll also be using input from a Tasmota-based BME280 sensor device.
+#*I'll also be using input from a Tasmota-based BME280 sensor device.
-== Connecting to the Database ==
+==Connecting to the Database==
 The first time you add an '''influxdb''' node to a flow, its Server box will contain ''Add a new influxdb...''
-# Click the edit button (pencil icon) next to the box.
+#Click the edit button (pencil icon) next to the box.
-# Enter the hostname or IP of the host running InfluxDB.
+#Enter the hostname or IP of the host running InfluxDB.
-# Fill in the '''Database''' box (FooBar in these examples).
+#Fill in the '''Database''' box (FooBar in these examples).
-# Fill in the '''Username''' and '''Password''' boxes if you've set up the database to require them.
+#Fill in the '''Username''' and '''Password''' boxes if you've set up the database to require them.
-# Put something meaningful in the '''Name''' box. (I put ''InfluxDB Testing'')
+#Put something meaningful in the '''Name''' box. (I put ''InfluxDB Testing'')
-# Click the '''Add''' button.
+#Click the '''Add''' button.
-== Sending data to the Database ==
+==Sending data to the Database==
 [[File:Feeding.png|frameless|800x800px]]
@@ Line 47: / Line 47: @@
 This creates an entry in a table named '''Readings''' with 4 data-points in the database every time the device spits out SENSOR telemetry. (Temperature, Humidity, DewPoint & Pressure)
-== Getting data from the Database ==
+==Getting data from the Database==
 [[File:Regurgitating.png|frameless|800x800px]]
@@ Line 102: / Line 102: @@
 The '''CHART node''' puts the data out on a dashboard.

@@ Line 54: / Line 54: @@
 The first '''FUNCTION node''' generates the QUERY for the database
-Its content:<blockquote>msg.query = "SELECT Temperature, Humidity, DewPoint, Pressure FROM Readings Where Sensor = 'Inside_Weather' and time > now() -" + msg.payload;
+Its content:
-return msg;</blockquote>The '''InfluxDB in node''' sends the query off to the database. (Again, at this point, the only thing entered into the '''Properties''' of this node is the '''Server''' entry we created above)
+<blockquote>msg.query = "SELECT Temperature, Humidity, DewPoint, Pressure FROM Readings Where Sensor = 'Inside_Weather' and time > now() -" + msg.payload;
 The second '''FUNCTION node''' formats the data to be passed on to the '''CHART node'''
 Its content:
   var series = ["temp DegC"];
@@ Line 91: / Line 97: @@
   msg.payload = [{"series": series, "data": jsondata, "labels": labels}];
-  return msg;
+  return msg;</blockquote>
 (yup...  that's every bit as FUGLY as it seems...)
 The '''CHART node''' puts the data out on a dashboard.

@@ Line 25: / Line 25: @@
 The '''FUNCTION node''' formats the data into what InfluxDB wants to see.
-Its content:<blockquote>msg.measurement = "Readings"
+Its content:
 msg.payload = {Sensor:"Inside_Weather",
@@ Line 39: / Line 41: @@
     };
-return msg;</blockquote>The '''InfluxDB out''' node sends the data to the database.  (At this point, the only thing entered into the '''Properties''' of this node is the '''Server''' entry we created above)
+return msg;</blockquote>
 This creates an entry in a table named '''Readings''' with 4 data-points in the database every time the device spits out SENSOR telemetry. (Temperature, Humidity, DewPoint & Pressure)