当我运行以下代码时,收到错误消息“MongoError:server instance pool已销毁”。知道为什么或者如何解决这个问题吗
var csv=require('./importer.js');
var MongoClient=require('mongodb')。MongoClient;
var assert=require('assert');
var ObjectId=require('mongodb')。ObjectId;
var url='1〕mongodb://.....';
连接(url,函数(err,db){
assert.equal(null,err);
log(“已正确连接到服务器”);
csv.foreach('data/airports.csv',函数(airport){
db.collection(“airports”).insertOne(机场、功能(错误、结果){
如果(错误){
console.log(错误)
}否则{
控制台日志(“插入:+airport.ident”);
}
});
});
db.close();
});
csv.foreach和insertOne调用(大概)都是异步的,因此在插入完成之前调用了db.close()
您需要想出一种等待调用db.close()的方法,直到调用了所有INSERT的回调。如何做到这一点取决于csv模块的工作方式,但是使用类似于异步模块的东西可以帮助实现异步流控制