Connessione a InfluxDB con Node.js

In questo articolo vediamo come eseguire una connessione a InfluxDB in Javascript e Node.js.

La prima cosa da fare è installare la libreria apposita.

Possiamo farlo tramite npm:

npm install @influxdata/influxdb-client

Qui sotto il codice:

// repl.repl.ignoreUndefined = true;

const {InfluxDB, Point} = require('@influxdata/influxdb-client')

const token = 'TOKEN';
const url = 'https://eu-central-1-1.aws.cloud2.influxdata.com';
let org = 'EMAIL';
let bucket = 'test';

const client = new InfluxDB({url, token});

let writeClient = client.getWriteApi(org, bucket, 'ns')

for (let i = 0; i < 5; i++) {
    let point = new Point('measurement1')
        .tag('tagname1', 'tagvalue1')
        .intField('field1', i);

    void setTimeout(() => {
        writeClient.writePoint(point);
    }, i * 1000);

    void setTimeout(() => {
        writeClient.flush();
    }, 5000);
}

let queryClient = client.getQueryApi(org)
let fluxQuery = `from(bucket: "test")
 |> range(start: -10m)
 |> filter(fn: (r) => r._measurement == "measurement1")`;

queryClient.queryRows(fluxQuery, {
    next: (row, tableMeta) => {
        const tableObject = tableMeta.toObject(row);
        console.log(tableObject);
    },
    error: (error) => {
        console.error('ERRORE:', error);
    },
    complete: () => {
        console.log('Operazione avvenuta con successo!');
    },
});

Dove org è la email con la quale vi siete iscritti; e bucket è quello che avete creato.

Enjoy!