通过url和httpRequest解析云代码循环

Question

我只是想在我的“alerts”对象中做一个简单的循环，它包含一个url和一个单词。 对于每个警报，我都会执行一个httpRequest来检查该单词是否出现在响应html代码中。我是的，我把状态变为真实。

我也希望每一次更新“updatedTo”一栏，即使我没有找到在响应HTML代码的话，但我不知道为什么...

我写了这个云代码，但它不起作用，或者它有时只有当我只有带有单词的项目时才起作用。

Parse.Cloud.job("updateStatus", function(request, status) { 
    Parse.Cloud.useMasterKey(); 
    var counter = 0; 
    var AlertItem = Parse.Object.extend("Alert"); 
    var query = new Parse.Query(AlertItem); 
    query.each(function(alert) { 
      var alertTitle = alert.get("title"); 
      var alertUrl = alert.get("url"); 
      var alertStatus = alert.get("status"); 
      var alertWords = alert.get("research"); 
      console.log("Alert : " + alertTitle + " - Check if : " + alertWords + " is on : " + alertUrl) 

      promise = promise.then(function() { 
        return Parse.Cloud.httpRequest({ 
         url: alertUrl, 
         headers: { 
          'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_10) AppleWebKit/600.1.25 (KHTML, like Gecko) Version/8.0 Safari/600.1.25' 
         }, 
        }).then(function(httpResponse) { 
          console.log("We succeded to access to the website"); 
          var htmlCode = httpResponse.text; 
          if (htmlCode.indexOf(alertWords) >= 0) { 
           if (alertStatus == false) { 
            alert.set("status", true); 
            console.log("new status:true"); 
            return alert.save(); 
           } 
          } else { 
           alert.set("status", false); 
           console.log("new status:false"); 
           //I do this to updated the "updatedTo" field, but it doesn't work 
           return alert.save(); 
          } 
          // You need to return a Promise here if non of the above condition meet. 
         }, 
         function(error) { 
          console.error('Request failed with response code ' + httpResponse.headers.Location); 
          // You need to return a rejected promise here. 
         } 
        }); 
      }); 
     return promise; 
    }).then(function() { 
    status.success('Status updated'); 
    // Set the job's success status 
}, function(error) { 
    // Set the job's error status 
    status.error("Uh oh, something went wrong."); 
}); 
}); 

Answer 1

因此，任何帮助，这是很难的，但我完成找到另一篇文章是谁靠近我需要的，我适应它，我成功使用它是什么，它的伟大工程与承诺:)：

var _ = require('underscore.js') 

Parse.Cloud.job("updateStatus", function(request, response) { 

var alerts = Parse.Object.extend("Alert"); 
var query = new Parse.Query(alerts); 
query.equalTo("status", false); 

query.find().then(function(alerts) { 

    var promise = Parse.Promise.as(); 

    _.each(alerts, function(alert) { 

     var alertUrl = alert.get("url"); 
     ... 

     promise = promise.then(function() { 
      return Parse.Cloud.httpRequest({ 
       url: alertUrl 
       }).then(function(httpResponse) { 
        ... 
       }, 
       function(error) { 
        ... 
       }); 
      }); 
    }); 

    return promise; 

}).then(function() { 
    response.success("All status updated with success !"); 
}, 
function (error) { 
    response.error("Error: " + error.code + " " + error.message); 
}); 
}); 

Answer 2

来自文档的query.each（callback，options）。

迭代查询的每个结果，为每个结果调用回调。如果回调返回一个承诺，迭代将不会继续，直到履行承诺。如果回调返回一个被拒绝的承诺，那么迭代将停止并出现该错误。这些项目以未指定的顺序处理。查询可能没有任何排序顺序，可能不会使用限制或跳过。

Parse.Cloud.job("updateStatus", function(request, status) { 
    Parse.Cloud.useMasterKey(); 
    var counter = 0; 
    var AlertItem = Parse.Object.extend("Alert"); 
    var query = new Parse.Query(AlertItem); 
    query.each(function(alert) { 
     var alertTitle = alert.get("title"); 
     var alertUrl = alert.get("url"); 
     var alertStatus = alert.get("status"); 
     var alertWords = alert.get("research"); 
     console.log("Alert : " + alertTitle + " - Check if : " + alertWords + " is on : " + alertUrl) 


     return Parse.Cloud.httpRequest({ 
      url: alertUrl, 
      headers: { 
       'user-agent': 'A user classic agent' 
      }, 
      success: function(httpResponse) { 
       console.log("We succeded to access to the website"); 
       var htmlCode = httpResponse.text; 
       if (htmlCode.indexOf(alertWords) >= 0) { 
        if (alertStatus == false) { 
         alert.set("status", true); 
         console.log("new status:true"); 
         return alert.save(); 
        } 
       } else { 
        alert.set("status", false); 
        console.log("new status:false"); 
        //I do this to updated the "updatedTo" field, but it doesn't work 
        return alert.save(); 
       } 
       // You need to return a Promise here if non of the above condition meet. 
      }, 
      error: function(httpResponse) { 
       console.error('Request failed with response code ' + httpResponse.headers.Location); 
       // You need to return a rejected promise here. 
      } 
     }); 
    }).then(function() { 
     status.success('Status updated'); 
     // Set the job's success status 
    }, function(error) { 
     // Set the job's error status 
     status.error("Uh oh, something went wrong."); 
    }); 
});