1

我有一个传感器值的 mongoDB 集合,我试图在集合中查找特定日期范围内的所有文档。我已经阅读了文档并实际实现了查找所有数据的代码。但是,我随后将所有文档写入 CSV 文件,以便我可以从 Web 下载它们。我遇到的问题是查询似乎正在寻找正确日期范围内的所有数据(我已经在服务器端和客户端打印了日期,并且都与正确的日期范围相匹配)但是,CSV 文件只返回大约一半的数据(它永远不会一致)。例如,假设我正在查询我的集合以返回存储在以下之间的所有文档:

(2013 年 5 月 9 日星期四 07:57:06 GMT-0400)和(2013 年 5 月 14 日星期二 00:40:43 GMT-0400)

当我单击下载数据按钮时,它会向服务器发送请求以查找此范围内的所有文档,然后将文档流式传输到文本文件并将其返回给客户端。我将服务器和客户端上的日期打印到控制台,并且一切都匹配......所以我很确定 mongodb find 函数在其查询中使用了正确的日期。

但是,当我为此查询打开 CSV 文件时,它给了我一个文档列表,范围从(2013 年 5 月 9 日星期四 07:57:15 -> 第一个日期条目 gte 到开始日期)......但只返回值(2013 年 5 月 11 日星期六 01:04:09)。这是查询中似乎缺少的大约三天的数据。由于我的传感器每 8 秒将数据上传到集合中,因此有数千个条目。使用 find 函数可以检索的文档数量是否存在某种数据限制?CSV 文件有近 6,850 个条目(从周四到周六)......但为什么不返回周四到周二之间的完整值列表呢?我检查了数据库并知道它在这段时间范围内始终如一地存储数据......所以我认为这不是问题。有没有人有任何想法?

这是我的查找功能的代码:

collection.find({"addr": Number(json.addr), 
                 "Time": {$gte:new Date(json.startDate), 
                 $lte:new Date(json.endDate)}},
                 proj,
                 function (err, docs) 
                 {
                   if( err || !docs) console.log("No data found");
                   else 
                   {
                     var tempname=json.type+".csv";
                     var stream=fs.createWriteStream("pages/"+tempname);
                     stream.on('error', function(e){console.error(e);});

                     docs.each(function(err2, doc) 
                     {
                       if (!doc) 
                       {
                         console.log("done");
                         stream.end();
                         res.writeHead(200, {"Content-Type": "application/json"});
                         res.write(JSON.stringify({fname:tempname}));
                         res.end();
                         return;
                       }
                       stream.write(doc.Time+","+doc[json.type]+"\n");
                     });
                   }
                });
4

1 回答 1

0

stream.write()当缓冲区已满时返回 false,因此您需要检查这一点。

此外,请参阅[使用 Node.js 编写大文件]了解更多信息。

于 2013-05-20T19:02:26.723 回答