猫鼬查找结果和异步

Question

我正在编写一个NodeJS脚本，它将通过Heroku的调度程序每小时运行一次。我在咀嚼我拥有的Mongo实例（mongohq/compose），然后用这些结果做一些事情。我正在使用Mongoose.js和find（）命令。这将返回一组结果。有了这些结果，我需要执行额外的查询以及一些额外的异步处理（发送电子邮件等）。

长话短说，由于节点的异步性质，我需要等到所有处理完成后再致电process.exit()。如果我不提前停止脚本，并且整个结果集都没有处理。

问题是，在这一点上我有圣诞节电话的呼叫（5嵌套asnyc电话）。

通常情况下，我会用async.js库解决这个问题，但我遇到了一个问题，通过这么多的回调来看待这个问题。

如何在退出脚本之前确保完成整个过程？

下面是我的工作的代码（注：也使用下面lodash为_）：是什么使你的代码混淆的

Topic.find({ nextNotificationDate: {$lte: moment().utc()}}, function (err, topics) { 
    if (err) { 
     console.error(err); 
     finish(); 
    } else { 

     _.forEach(topics, function (topic, callback) { 

      User.findById(topic.user, function (err, user) { 
       if (err) { 
        // TODO: impl logging 
        console.error(err); 
       } else { 

        // Create a new moment object (not moment.js, an actual moment mongoose obj) 
        var m = new Moment({ name: moment().format("MMM Do YY"), topic: topic}); 
        m.save(function(err) { 
         if(err) { 
          // TODO: impl logging 
          console.error(err); 
         } else { 

          // Send an email via postmark 
          sendReminderTo(topic, user, m._id); 

          // Update the topic with next notification times. 
          // .. update some topic fields/etc 
          topic.save(function (err) { 
           if(err) { 
            console.error(err); 
           } else { 
            console.log("Topic updated."); 
           } 
          }) 
         } 
        }) 
       } 
      }); 
      console.log("User: " + topic.user); 
     }); 
    } 
}); 

Answer 1

部分是else语句的使用。如果您返回错误，则不需要else语句，并为每个回调保存4行缩进。这本身将使事情变得更加可读。

使用异步：

Topic.find({nextNotificationDate: {$lte: moment().utc()}}, function (err, topics) { 
    if (err) { 
     console.error(err); 
     return finish(err); 
    } 

    async.each(topics, function(topic, topicCallback) { 

     async.auto({ 

      user: function (callback) { 

       User.findById(topic.user, callback); 
      }, 

      moment: function(callback) { 

       var m = new Moment({name: moment().format("MMM Do YY"), topic: topic}); 
       m.save(callback); 
      }, 

      topic: ["moment", "user", function (callback, results) { 

       var m = results.moment; 
       var user = results.user; 

       sendReminderTo(topic, user, m._id); 
       topic.save(callback); 
      }] 

     }, function(err) { 
      if (err) { 
       return topicCallback(err); 
      } 

      console.log("Topic updated.") 
      return topicCallback(); 
     }); 
    }, function(err) { 
     if (err) { 
      console.error(err); 
      return finish(err); 
     } 

     return finish(); 
    }); 
});