从 mongodb 游标流式传输到 node.js 中的 Express 响应

发布于07月16日

我在玩弄所有花哨的 node .js/mongodb/express平台，偶然发现了一个问题:

app.get('/tag/:tag', function(req, res){
  var tag=req.params.tag;
  console.log('got tag ' + tag + '.');
  catalog.byTag(tag,function(err,cursor) {
     if(err) {
       console.dir(err);
       res.end(err);
     } else {
       res.writeHead(200, { 'Content-Type': 'application/json'});

       //this crashes
       cursor.stream().pipe(res);

     }
  });
});

正如您可能猜到的，catalog.byTag(tag, callback)对Mongodb执行find()查询并返回游标

这会导致一个错误:

TypeError: first argument must be a string or Buffer

根据mongodb driver doc，

function(obj) {return JSON.stringify(obj);}

但这没有帮助.

有谁能告诉我如何正确地将内容流式传输到响应中吗？

或者，唯一的解决方案是使用"数据"和"结束"事件手动泵送数据的样板文件吗？

推荐答案

这里是其他答案的有效组合

app.get('/comments', (req, res) => {
  Comment.find()
    .cursor()
    .pipe(JSONStream.stringify())
    .pipe(res.type('json'))
})

http://mongoosejs.com/docs/api.html#query_Query-cursor

cursor()返回与Node streams3兼容的流，与不推荐使用的query.stream()接口相比，它更受欢迎.
管道到JSONStream.stringify()，以将文档合并到一个数组中，而不是单个对象
管道设置为res.type('json')，将HTTP Content-Type头设置为application/json，并再次返回自身(响应流).