31 lines
566 B
JavaScript
31 lines
566 B
JavaScript
'use strict';
|
|
|
|
const Influx = require('influx');
|
|
|
|
class InfluxDBSender {
|
|
constructor({ protocol, host, port, database, username, password }) {
|
|
this.client = new Influx.InfluxDB({
|
|
protocol,
|
|
host,
|
|
port,
|
|
database,
|
|
username,
|
|
password
|
|
});
|
|
}
|
|
|
|
send(data) {
|
|
const points = [];
|
|
for (let point of data) {
|
|
points.push({
|
|
tags: point.tags,
|
|
measurement: point.seriesName,
|
|
fields: point.point
|
|
});
|
|
}
|
|
return this.client.writePoints(points);
|
|
}
|
|
}
|
|
|
|
module.exports = InfluxDBSender;
|