influxdb节点模块不插入数据

我刚开始尝试influxDB和influxdb节点模块。

我有以下代码，每秒插入一些随机数据。 我没有得到任何的错误，但没有数据被添加到我的时间系列。

代码是

var influxdb = require（'influxdb'）; var sleep = require（'sleep'）; var connection = influxdb（'172.21.5.67'，8086）; connection.auth（{name：'root'，password：'root'}）;

var db; var ISCSIDataSeries;

函数random（low，high）{return Math.floor（Math.random（）*（high – low）+ low）; }

函数doInsert（i）{if（db == undefined）{db = connection.database（'test'）; console.log（'build立数据库连接'）; }

if (ISCSIDataSeries == undefined) { ISCSIDataSeries = db.series('SCSIData'); console.log('the series SCSIData is established'); } var reads = random(1000, 10000); var writes = random(2000, 20000); var IOS = random(100000, 1000000); ISCSIDataSeries.writePoints({ 'columns': ['Volume', 'Reads', 'Writes'], 'points': [reads, writes, IOS] } ); db.save(); } 

var i = 0; while（i <10）{sleep.sleep（1）;

 doInsert(i); i ++; } 

console.log（'这么长的人'）;

在运行结束时，我看不到input的数据。 这个包的任何经验？

Answer 1

我是InfluxDB的维护者之一。 我们不使用节点，所以我不熟悉这个库，但是我尝试了一下你的代码片断，而且确实不起作用。 事实certificate， influxdb库并不是最新的，并在四个月前更新，在这期间InfluxDB API经历了重大变化。 我build议你切换到涌入包，而不是似乎更积极维护。 我修改了你的代码片段与其他包一起工作，它可以成功地工作：

 var influxdb = require('influx'); var sleep = require('sleep'); var root = new influxdb.InfluxDB('localhost', 8086, 'root', 'root'); root.createDatabase('SCSIData', function(err) { if (err && err.message.indexOf("exist") == -1) { console.log("Cannot create db", err); process.exit(1); }; var client = new influxdb.InfluxDB('localhost', 8086, 'root', 'root', 'SCSIData'); function random (low, high) { return Math.floor(Math.random() * (high - low) + low); } function doInsert(i) { var reads = random(1000, 10000); var writes = random(2000, 20000); var IOS = random(100000, 1000000); client.writePoint("series.name", { 'Volume': IOS, 'Reads': reads, 'Writes': writes }, function(err) { if (err) { console.log("Cannot write data", err); process.exit(1); } }); } var i = 0; while (i < 10) { doInsert(i); i++; } client.query("select count(Reads) from series.name", function(err, result) { if (err) { console.log("Cannot write data", err); } console.log("result", result) console.log("Number of points: ", result[0].points[0][1]); }) }); console.log('so long folks');