mongoexport 带参数 + node.js + 子进程

Question

我正在尝试使用来自 mongodb 的 node.js 导出 csv。为此，我从以下代码开始：

app.get('/export', function(req, res) {
 var spawn = require('child_process').spawn,
 ls = spawn('mongoexport');
res.sendfile('/home/database.csv'); 
});

这很好用。然后为了使它更有用，我尝试使用参数在下面使用 mongoexport 进行编码：

 app.get('/export', function(req, res) {
 var spawn = require('child_process').spawn,
 ls = spawn('mongoexport --db lms --collection databases --fields firstname,lastname,email,daytimePhone,addressOne,city,state,postalCode,areaOfStudy,currentEducationLevel,company --csv --out /home/database.csv');
res.sendfile('/home/database.csv') 

});

这会引发异常：

events.js:72
        throw er; // Unhandled 'error' event
              ^
Error: spawn ENOENT
    at errnoException (child_process.js:980:11)
    at Process.ChildProcess._handle.onexit (child_process.js:771:34)

然后我尝试只使用一个参数，但它给出了相同的错误:(

我也试过这个，看看参数是否以这种方式工作，但同样的错误：

spawn('mongoexport',['--csv']);

Answer 1

spawn 的语法是：

spawn(<command>, [array of arguments]);

例如，使用-l /home 选项执行ls 命令将如下所示：

ls = spawn('ls', ['-l', '/home'];

所以您的spawn('mongoexport',['--csv']); 正朝着正确的方向前进，但mongoexport --csv 无效。这就是为什么你会出错。 mongoexport 需要的不仅仅是--csv。就像上面所做的一样，例如，您需要指定数据库名称（-d "lms"）、集合名称（-c "databases"）、字段名称（--fields firstname,lastname）等。

在你的情况下，它应该是这样的：

 var spawn = require('child_process').spawn;
 app.get('/export', function(req, res) {
     var mongoExport = spawn('mongoexport', [ 
         '--db', 'lms', '--collection', 'databases', 
         '--fields',
         'firstname,lastname,email,daytimePhone,addressOne,city,state,postalCode,areaOfStudy,currentEducationLevel,company',   
         '--csv'
     ]);

     res.set('Content-Type', 'text/plain');
     mongoExport.stdout.on('data', function (data) {
         if (data) {
             // You can change or add something else here to the
             // reponse if you like before returning it.  Count
             // number of entries returned by mongoexport for example
             res.send(data.toString());
         } else {
             res.send('mongoexport returns no data');
         }
     });
}

Answer 2

您的代码存在竞争条件，/home/database.csv 可能会被多个（几乎）同时进入的/export 请求截断/覆盖。

使用 Ben 提供的代码，我会将 mongoexport 的输出直接通过管道传输到响应对象，因此不需要使用临时文件：

app.get('/export', function(req, res) {
  // Set correct content-type
  res.set('Content-Type', 'text/csv');
  // Export collection and pipe to `res`
  spawn('mongoexport', [ 
    '--db', 'lms', '--collection', 'databases', 
    '--fields', 'firstname,lastname,email,daytimePhone,addressOne,city,state,postalCode,areaOfStudy,currentEducationLevel,company', 
    '--csv'
  ]).stdout.pipe(res);
});

我个人会使用 MongoDB 驱动程序和 csv 直接从 Node 生成 CSV。