diff --git a/lib/plugins/influxdb/sender.js b/lib/plugins/influxdb/sender.js index f724cd322..082e8aee7 100644 --- a/lib/plugins/influxdb/sender.js +++ b/lib/plugins/influxdb/sender.js @@ -15,15 +15,15 @@ class InfluxDBSender { } send(data) { - return Promise.resolve(data) - .map(point => { - return { - tags: point.tags, - measurement: point.seriesName, - fields: point.point - }; - }) - .then(points => this.client.writePoints(points)); + const points = []; + for (let point of data) { + points.push({ + tags: point.tags, + measurement: point.seriesName, + fields: point.point + }); + } + return this.client.writePoints(points); } }