node.js - 有条件尝试使用nodejs Kue

我在一个Web搜寻器应用程序中使用kue。如果错误符合特定条件，我想为某些失败的作业设置attempts。例如，如果错误是由套接字挂起引起的，则作业将以1分钟的间隔重试3次。

我的代码如下所示，但不起作用

var kue = require('kue');
var queue = kue.createQueue();
queue.process('grab', function (job, done){
    //doCrawlingJob is async call and returns promise
    doCrawlingJob(job).then(function(result){
       done();
    }.catch(function(err){
        if (err.message.indexOf("socket hang up") >= 0) {
            job.attempts(3).backoff({delay:60*1000});
            job.save(function(){
               done(err);
            });
        } else {
            done(err);
        }
    );
});
//...
var job = queue.create('grab', data).removeOnComplete(true).save();

最佳答案

这可能无法回答您的问题，但是我注意到您在代码片段中存在一些格式错误。尝试像这样添加一些括号:

queue.process('grab', function (job, done){
    //doCrawlingJob is async call and returns promise
    doCrawlingJob(job).then(function(result){
       done();
    }).catch(function(err){
        if (err.message.indexOf("socket hang up") >= 0) {
            job.attempts(3).backoff({delay:60*1000});
            job.save(function(){
               done(err);
            });
        } else {
            done(err);
        }
    });
});

关于node.js - 有条件尝试使用nodejs Kue，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/30496111/