節點異步方法未檢測到迭代器的結果

我正試圖學習如何在我的節點js REST API中使用異步方法。節點異步方法未檢測到迭代器的結果

目標

我查詢數據庫，以使每一個範圍鍵...和循環。我檢查是否有任何結果與我當前的日期/時間戳相匹配，如果有，我對匹配鍵進行HGETALL查詢。我想將HGETALL的結果作爲json數據發送給我的REST API的使用者。

問題

我的代碼正確查詢後爲HGETALL數據庫的初始密鑰組......然後。但是，當我嘗試發回結果時，網頁上當前沒有顯示任何內容。

下面的代碼：

var id_rule = function (redis_key, doneCallBack) { 
    console.log('iterator called with key:' + redis_key); 
    //if this is the default rule, skip it 
    if (redis_key.indexOf('00:00_00:00') == -1){ 
     //time match 
     var rule_times = parse_time_from_key(redis_key); 
     var current = getCurrentUTC(); // returns something like [ 1158, 'mon' ]   
     if ((current[0] >= rule_times[0] && current[0] <= rule_times[1]) && (rule_times[2].indexOf((current[1].substring(0,1))) != -1)) { 
      var widgetkey = redis_key.split("widget:");    
      redis.hgetall("widget:" + widgetkey[1], function (err, data) { 
       if (err) { 
        console.log("hgetall method fails: " + err); 
        return doneCallBack(err, false); 
       } 
       if (data) { 
        console.log('bingo: ' + widgetkey[1] + "returned a match"); 
        console.log(data); 
        return doneCallBack(false, data); 
       } else { 
        return doneCallBack(false, false); 
       }          
      }); 
     } else { 
      return doneCallBack(false, false); 
     } 
    }; 
} 

router.get('/:widgetnum', function(req, res, next) { 
    //validate widgetnum format 
    var widgetnum = req.params.widgetnum; 
    if (!valid_e164(widgetnum)) { 
     var retval = {"res":false, "msg":"malformed widget"}; 
     res.send(JSON.stringify(retval)); 
    } 
    console.log('scanning db for: widget:' + widgetnum + "*"); 
    redis.send_command("SCAN", [0, "MATCH", "widget:" + widgetnum + "*", "COUNT","1000"], function (err, reply) { 
     if (err) { 
      res.send(JSON.stringify({"res":false,"msg":"no matching widget records found"})); 
     } 
     if (reply) {      
      if (reply[1].length == 2) { 
       //queryfordefault rule 
       async.map(reply[1], queryhgetall_default_rule, function(err, results) { 
        console.log('inside here!'); 
        res.send(JSON.stringify(results)); 
       }); 
      } else { 
       async.map(reply[1], id_rule, function (err, iteration_results) { 

        if (err) { 
         res.send(JSON.stringify("false")); 
        } 
        if (iteration_results) {      
         res.send(JSON.stringify(iteration_results)); 
        }      
       }); 
      } 
     } 
    }); 

});

37行是我把我的第一次查詢傳送至Redis的數據庫，並返回結果的數組。

第49-56行是異步方法，它爲結果集中的每個結果調用我的迭代器方法...一次。

第18行是我試圖將數據從迭代器返回到異步方法。

問題

很明顯，我弄亂的東西了我要回我的數據，因此這將是我的第一個問題的方式 - 你可以看到我在做什麼錯。
一旦我找到了我要找的東西，我該如何停止通過回覆[1]（第49行）進行迭代？

來源

2016-10-03 Happydevdays

郵報queryhgetall_default_rule和id_rule也代碼。但是首先將所有這些都分解到不同的模塊中，並在沒有HTTP請求的情況下自行測試。
參見http://caolan.github.io/async/docs.html#.some。

還應考慮承諾，Promise.any和await（需要巴貝爾）只是一個for循環做一個在時刻。這些是需要一些時間學習的有用的主題。

來源

2016-10-04 01:41:11

節點異步方法未檢測到迭代器的結果

回答

相關問題