Node.js在执行功能之前需要等待循环完成

debugcn 发表于 Dev

耶鲁·纽曼（Yale Newman）

好的。所以我对Node来说是非常陌生的。我的想法现在正在回调地狱中旋转。我已经阅读了许多类似的问题，但似乎无法使其正常运行。

从本质上讲，我正在通过服务器日志正则表达式解析我将用于运行某些sql查询的特定字符串。我已经将其用于不需要循环的较小规模的工作。

我需要等待所有ppsid都通过_cssPPSID运行，这会生成一个字典对象和我的查询过滤器，然后在查询本身中使用该过滤器运行查询，然后与该字典进行匹配以将结果与已解析的数据配对从服务器日志中。

截至目前，此代码已运行，但在第一次迭代后停止。我想我缺少回调或简单的东西，以便脚本可以回到循环中。

var ppsDict = new Object();
var ppsList = new Array();

var getURL = function(stdout) {
    console.log('Creating ppsid url key value pairs');
    var url_reg = /http\S+/g;
    var ppsid_reg = /PPS_ID\=[0-9]+/g;
    var ppsid = stdout.toString().match(ppsid_reg);
    var url = stdout.toString().match(url_reg);
    ppsDict[ppsid[0]] = url[0];
    ppsList.push(ppsid[0]);
    console.log(ppsDict);
  };


var getPPSID = function(stdout, prodServer, searchResultProcessed) {
    console.log("Collecting PPSID's");
    var ppsid_reg = /PPS_ID\=[0-9]+/g;
    var selector_reg = /selector\s\S+/g;
    var ppsid = stdout.toString().match(ppsid_reg);
    var selector = stdout.toString().match(selector_reg);
    async.eachSeries(ppsid, function (ppsSelector, next) {
      var urlQ = new urlQuery(prodServer, searchResultProcessed,  ppsSelector);
      _cssPPSID(urlQ, function(err, result) {
         if(err) {
          console.log(err);
        }
        next();
      }) 
    }, function (err) {
        console.log('iterating done');
        //queryProd(ppsList,ppsDict);
    });
}


function urlQuery(prodServer, searchResultProcessed, ppsSelector) {
  this.cssPPSID = "ssh " + prodServer + " 'sudo cat  /mint/logs/topologies/'" + searchResultProcessed + " | grep " + ppsSelector  + " | grep \"Downloading\"";
}

var _cssPPSID = (urlQ) => {
  child_process.exec(urlQ.cssPPSID, ["-m"], (err, stdout, stderr) => {
    if (stdout === 0) {
      console.log('PPS_ID and CSS error combination not found');
      return;
    } else if (err) {
     console.error(err, stderr);
      return;
    }
    getURL(stdout);
  });
};

埃萨·托沃拉（Esa Toivola）

您async.eachSeries将无法使用，因为函数_cssPPSID不会将回调作为第二个参数，因此next()永远不会调用。

尝试像这样重写它：

var _cssPPSID = (urlQ, callback) => { 
  child_process.exec(urlQ.cssPPSID, ["-m"], (err, stdout, stderr) => {
    if (err) {
      return callback(err);
    }        
    if (stdout === 0) {
      return callback(new Error('PPS_ID and CSS error combination not found');
    }
    // do stuff here
    callback(null); // null indicates no error has happened
  });
};

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。