node-red-contrib-stackhero-influxdb-v2

Node-RED node to read and write to an InfluxDB v2 database.

Remember: if you like it, please star it! 🥰

Official repository: https://github.com/uspatata/node-red-contrib-stackhero-influxdb-v2

Sponsors

node-red-contrib-uspatata-influxdb-v2 is a fork of node-red-contrib-stackhero-influxdb-v2 developed by Stackhero. The purpose of this fork is mainly to adjust the code to make Self signed Certificat of InfluxDB 2.0 working properly.

Usage

We have 2 nodes here. A write node, to send data to InfluxDB and a query node, to retrieve data using the Flux language.

Write data

The write node requires a payload object like this one:

msg.payload = {
  // You bucket
  // Optional (it can be defined in the node credentials settings)
  bucket: 'myBucket',

  // Precision of timestamp
  // Optional
  // Can be `ns` (nanoseconds),
  //        `us` (microseconds),
  //        `ms` (milliseconds),
  //        `s` (seconds).
  // The default is `ns`
  // Note: if you set the `timestamp` field to `Date.now()`, you have to set the `precision` to `ms`
  precision: 'ms',

  // Data to send to InfluxDB
  // Can be an array of objects or only one object
  data: [
    {
      measurement: 'machinerySensor',

      tags: {
        deviceId: 'gyh43',
        hardwareVersion: '1.0.2',
        softwareVersion: '2.5.1',
        location: 'factory-1'
      },

      fields: {
        temperature: 12,
        humidity: 46,
        vibrations: 18,
        batteryVoltage: 3.6
      },

      timestamp: Date.now()
    },

    // More data can be send here, simply re add an object
    // { ... },
  ]
};

return msg;

Query data

The query node requires a topic string containing a Flux query.

msg.topic = 'from(bucket: "myBucket") |> range(start: -1h)';
return msg;

You can write multiple lines queries like this:

msg.topic = [
  'from(bucket: "myBucket")',
  '  |> range(start: -1d, stop: now)',
  '  |> filter(fn: (r) => r._measurement == "machinerySensor")',
  '  |> filter(fn: (r) => r._field == "vibrations")',
  '  |> aggregateWindow(every: 1h, fn: mean)',
  '  |> yield(name: "mean")',

  'from(bucket: "myBucket")',
  '  |> range(start: -1d, stop: now)',
  '  |> filter(fn: (r) => r._measurement == "machinerySensor")',
  '  |> filter(fn: (r) => r._field == "vibrations")',
  '  |> aggregateWindow(every: 1h, fn: max)',
  '  |> yield(name: "max")',
].join('\n');

return msg;