在NodeJS中处理多个顺序依赖的mongo查询结果的最佳方法

Question

高水平

我是JS和Node的新手.我正在开发一个应该返回状态值的API端点.要计算状态值,我需要进行两个连续的mongo查询,其中第二组查询依赖于第一个查询.第二组查询将为我提供第一个查询中找到的每个值的状态,我将根据某些逻辑选择一个.NodeJS中最好的方法是什么？

细节

这是我第一次尝试的部分内容.

function getItemStatus(key, value, callback) {
        MongoClient.connect(mongo_url, function(err, db) {
            if (err) { return console.dir(err); }
            db.collection('status', function(err, coll) {
                if (err) { return console.dir(err); }
                coll.distinct("_id.metric", function(err, metrics) {
                    if (err) { return console.dir(err); }
                    console.log('metrics : ', metrics);
                    _.foreach(metrics, function(metric) {
                        var query = {"_id": {
                            "$gte" : {key: key, value: value, created: new Date("1800-01-01T00:00:00"), metric : metric},
                            "$lte" : {key: key, value: value, created: new Date("2100-01-01T00:00:00"), metric : metric}}};
                        coll.find(query, {sort: {"_id.created": -1}, limit: 1})

我建立连接,使用不同的查询查询一组度量值.对于每个指标,我想要询问最新状态.理想情况下,我希望拥有整套状态,以便我可以编写一个函数来获取此集合并决定返回哪个状态.我的问题是将状态传递回"链上",以便我可以处理这组状态.

在同步的情况下,我只想写这样的东西

val metrics = getDistinctMetrics(key, value)
val statuses = metrics.map(getStatusForMetric)
val status = filterStatuses(statuses)

如何在JavaScript/NodeJS中完成此操作？

更新以突出显示第一个查询将在第二步中触发多个查询的事实,即对于第一个查询找到的每个结果一个查询.

Answer 1

在您的示例代码中，您在另一个网络调用中进行网络调用，这可能会导致回调地狱，从而导致查询行为不当，为了克服这个问题，您可以使用Promise。

这将帮助您避免回调地狱，并且您的查询也将得到解决。

示例代码：-

new Promise (function(resolve, reject){
      return db.collection.find(function).exec()
      .then(function(result_of_first_query){
            return db.collection.findOne(function).exec()   //in this yopu can user the result of first query
      }).then(function(result_of_second_query){
             resolve(result_of_second_query);
      })
})

您可以为每个添加更多查询.then