有一个简单的方法来打开从节点中的Mongo可读stream吗?
使用MySQL 很容易从数据库中打开一个可读的stream。 我们所需要做的是:
function getTableStream() { connection.query('SELECT * FROM someTable WHERE field = value').stream(); }
之后,我们可以做这样的事情:
getTableStream.on('data', function(data) { console.log(data); });
这是快速的。 事实上,我用了85千行这样的东西,并且能够在不到一分钟的时间内在控制台上列出所有的数据。
我想知道:是否有可能对MongoDB做同样的事情? 我们可以从mongo打开可读stream,并通过stream式传输从那里获取数据吗?
如果可能的话,Mongo怎么样?
调用本地驱动程序光标的.stream()
以获取可读stream:
var stream = collection.find().stream(); stream.on('data', function(doc) { console.log(doc); }); stream.on('error', function(err) { console.log(err); }); stream.on('end', function() { console.log('All done!'); });