【问题标题】:Mongoose Stream JSON DataMongoose 流 JSON 数据
【发布时间】:2018-03-07 08:54:37
【问题描述】:
您好,我有以下代码
var mq = DeviceData.find().lean().cursor();
mq.on('data', function(data) {
//code to write to a stream
}).on('end', function() {
//code to write to a stream
});
我应该在评论区放什么?我想我应该创建一个 wrtie 流。这个想法是向客户端发送数据流。
【问题讨论】:
标签:
node.js
express
mongoose
stream
【解决方案1】:
其实你可以直接使用pipe方法如下
var mq = DeviceData.find().lean().cursor().pipe(yourWritableStream);
或来自我的食谱
DeviceData.find({})
.lean()
.cursor()
.pipe(new Writable({
objectMode: true,
write(data, encoding, next) {
// do something with your data
// call next
}))
.on('finish', () => {
// you can do something when the stream ends
})