如何使用回调等待两个查询异步节点

Question

我正在使用sync模块瀑布方法进行节点中的SQL查询。我将如何使用回调将两组数据发送到下一个功能。就像将qryupdatecheck和qrycheckdbl传递到下一个功能一样。

如何正确完成。

async.waterfall([
    function (callback) {
        var requestUpdateCheck = new sql.Request([config]);
        requestUpdateCheck.query("Some qryUpdateCheck", function (err, qryUpdateCheck) {
            console.log('qryUpdateCheck', qryUpdateCheck);    
        });
        var requestCheckDbl = new sql.Request([config]);
        requestCheckDbl.query("Some qryRequestCheckDbl", function (err, recordset) {
            console.log('qryCheckDbl', qryCheckDbl);    
        });
        callback(null, qryUpdateCheck, qryCheckDbl);
    },
    function (qryUpdateCheck, qryCheckDbl, callback) {
        console.log('hi from second from qryUpdateCheck', qryUpdateCheck);
        console.log('hi from second from qryCheckDbl', qryCheckDbl);
        if ((qryUpdateCheck.length == 1) && (qryCheckDbl.length == 0)) {
            var requestUpdateLocID = new sql.Request([config]);
            requestUpdateLocID.query("Last qryUodateLocID", function (err, recordset) {
                console.log('qryUpdateLocID', recordset);
                callback(null, recordset);
            });
        } else if ((qryUpdateCheck.length == 0) && (qryCheckDbl.length == 0)) {
            var requestUpdateLocID = new sql.Request([config]);
            requestUpdateLocID.query("Insert qry", function (err, recordset) {
                console.log('qryUpdateLocID', recordset);
                callback(null, recordset);
            });
        }
    }
], function (err, result) {
  // result now equals 'done'
  console.log('done', result);
});

Answer 1

我发现Async.auto对这种情况更好。您将其传递给具有一组函数的对象，对于每个函数，您可以将其他功能名称作为依赖项传递。然后，它将运行任何可以并行的任务，同时确保依赖关系的功能等到所有任务都被调用后全部满足。它有点像魔术。

var request = new sql.Request([config]);
async.auto({
  // this runs in parallel because it has no dependencies
  requestUpdateCheck: function(callback) {
    request.query("Some qryUpdateCheck", callback);
  },
  // this also runs in parallel because it has no dependencies
  requestCheckDbl: function(callback) {
    request.query("Some qryRequestCheckDbl", callback);
  },
  // this waits for the first two functions and then executes
  requestUpdateLocID: ['requestUpdateCheck', 'requestCheckDbl', function(results, callback) {
    console.log('Results from requestUpdateCheck and requestCheckDbl', JSON.stringify(results, null, 2));
    var qryUpdateCheck = results.requestUpdateCheck;
    var qryCheckDbl = results.requestCheckDbl;
    if ((qryUpdateCheck.length == 1) && (qryCheckDbl.length == 0)) {
      request.query("Last qryUodateLocID", function (err, recordset) {
        console.log('qryUpdateLocID', recordset);
        callback(err, recordset);
      });
    } else if ((qryUpdateCheck.length == 0) && (qryCheckDbl.length == 0)) {
      request.query("Insert qry", function (err, recordset) {
        console.log('qryUpdateLocID', recordset);
        callback(err, recordset);
      });
    }
  }]
}, function(err, results) {
  console.log('done:', err || results);
});

results将包含来自所有完成功能的数据。

这是一个非常简单的示例案例，有些人可能会争论承诺。所有这些都更适合。就个人而言，当事情变得更加复杂时，我发现async.auto确实有帮助。因此，为了保持一致性，我将其用于大多数异步控制流，发现它处理大多数情况。

Answer 2

您可以进行嵌套并行调用。这是使用setTimeout的伪示例：

async.waterfall([
    function(callback) {
        async.parallel({
            requestUpdateCheck: function(callback) {
                setTimeout(function() {
                    callback(null, 'UpdateCheck')
                }, 500)
            },
            requestCheckDbl: function(callback) {
                setTimeout(function() {
                    callback(null, 'CheckDbl')
                }, 500)
            }
        }, function(err, result) {
            // here the parallel op is done
            callback(err, result);
        }) 
    },
    function(result, callback) {
        console.log('hi from second from qryUpdateCheck', result.qryUpdateCheck);
        console.log('hi from second from qryCheckDbl', result.qryCheckDbl);
        callback(null, result);
    }
], function(err, result) {
    // result now equals 'done'
    console.log('done', result);
});