javascript - MongoDb forEach 异步回调

Question

我正在使用 Request npm 模块从 API 中提取数据并将其插入到我的 Mongo 数据库中的字段中。阿富汗是数据库中的第一个国家，是唯一填充数据的文档。其他所有国家都被跳过。 以下代码控制台依次记录“开始”和“结束”，然后记录国家/地区名称。我知道这是 javascript 异步特性的结果，但我不确定它如何影响这段代码。 控制台日志不应该:

begin
country
end
etc...

这里是代码:

MongoClient.connect(url, function(err, db)  {
  db.collection('countries').find().forEach( function(myDoc) {
    console.log('beginning');
    var code = myDoc.country.iso2;
    var options = {
      url: 'https://api.tugroup.com/v1/travelsafe/countries/' + code,
      headers: {
        ['X-Auth-API-Key']: '*******',
        ['Content-Type']: 'application/x-www-form-urlencoded'
      }
    }
    var callback = function(error, response, body)  {
      console.log(myDoc.country.name);
      if (!error && response.statusCode == 200) {
        var info = JSON.parse(body);
        db.collection('countries').updateOne(
            { 'country.name' : myDoc.country.name },
            { $set: {
            'safety.hasAdvisoryWarning' : info.hasAdvisoryWarning,
            'safety.hasRegionalAdvisory' : info.hasRegionalAdvisory,
            'safety.advisories' : info.advisories,
            'safety.advisoryState' : info.advisoryState,
            'safety.advisoryText' : info.advisoryText,
            'safety.lawAndCulture' : info.lawAndCulture,
            'safety.security' : info.safety}
        },
        function(err, result)  {
          console.log(err);
          db.close();
        });
      }
    }
    request(options, callback);
    console.log('end');
  });
});

控制台日志:

begin
end
begin 
end
etc...
Algeria
American Samoa
Andorra
etc...

Answer 1

只更新第一个的问题是因为你在updateOne的回调中关闭了数据库连接(db.close)所以第一次更新后是完成后，您与 mongoDB 的以下连接已关闭。

如果你的日志输出应该是这样的

beginning  
$country  
end  

然后您必须将日志记录移动到请求的回调中或按顺序发出请求。