我一直在寻找如何将MongoDB查询结果流式传输到nodejs客户端的示例。到目前为止,我发现的所有解决方案似乎都是立即读取查询结果,然后将结果发送回服务器。
相反,我(显然)想为查询方法提供一个回调,并在结果集的下一个块可用时让MongoDB调用它。
我一直在看猫鼬-我是否应该使用其他驱动程序?
一月
在Mongoose中进行流式处理的版本为2.4.0,该版本在发布此问题三个月后出现:
Model.where('created').gte(twoWeeksAgo).stream().pipe(writeStream);
可以在其文档页面上找到更详细的示例。