在NodeJS中stream到MongoDB

我使用模块streamToMongoDB的node.js从Web APIstream到MongoDB。

var streamToMongoDB = require("stream-to-mongo-db").streamToMongoDB; var JSONStream = require("JSONStream"); var request = require("request"); var fs = require("fs"); // where the data will end up var outputDBConfig = { dbURL : "mongodb://user:password@0.0.0.0/test", collection : "temperature" }; // create the writable stream var writableStream = streamToMongoDB(outputDBConfig); // create readable stream and consume it request("http://0.0.0.0:8081/getTemp") .pipe(JSONStream.parse('*')) .pipe(writableStream); 

但是我正在提取follwing错误：

 Unhandled rejection TypeError: Cannot read property 'close' of undefined at Writable.<anonymous> (C:\Users\User\node_modules\stream-to-mongo-db\out\index.js:98:16) at tryBlock (C:\Users\User\node_modules\asyncawait\src\async\fiberManager.js:39:33) at runInFiber (C:\Users\User\node_modules\asyncawait\src\async\fiberManager.js:26:9) 

我也试图stream本地json文件到mongdb具有相同的结果。