2013-05-31 49 views
7

使用Kue,我該如何安排每週四執行一次工作? Kue自述文件提到我可以推遲Job,但是在特定時間重複執行Job的情況如何?如何使用Kue每週四安排一次工作?

我可以做我想要的一個cron工作,但我喜歡Kue的功能。

我想要的是在週四的任何時間處理一次作業,但只能處理一次。

回答

14

我有一個類似的問題,我基本上想出了以下內容。如果其他人有不同的解決方案,我希望看到其他一些想法。

var jobQueue = kue.createQueue(); 

// Define job processor 
jobQueue.process('thursday-jobs', function (job, done) { 

    var milisecondsTillThurs = // TODO: Get the time until next thursday. For this I used moment.js 

    // do this job again next Thursday 
    jobQueue.create('thursday-jobs').delay(milisecondsTillThurs).save(); 

    // For Example purpose this job waits then calls done 
    setTimeout(function() { 
     done(); 
    }, 10000); 


}); 

// Use some initialization code to check if the job exists yet, and create it otherwise 
kue.Job.rangeByType('thursday-jobs','delayed', 0, 10, '', function (err, jobs) { 
    if (err) {return handleErr(err);} 
    if (!jobs.length) { 
     jobQueue.create('thursday-jobs').save(); 
    } 
    // Start checking for delayed jobs. This defaults to checking every 5 seconds 
    jobQueue.promote(); 
}); 

Kue具有最小的文檔,但源有很好的註釋,易於閱讀

0

看看KUE調度。我敢肯定,你應該能夠做這樣的事情:

var kue = require('kue-scheduler'); 
var Queue = kue.createQueue(); 

//create a job instance 
var job = Queue 
      .createJob('every', data) 
      .attempts(3) 
      .backoff(backoff) 
      .priority('normal'); 

//schedule it to run every Thursday at 00:00:00 
var thursday = '0 0 0 * * 4'; 
Queue.every(thursday, job); 


//somewhere process your scheduled jobs 
Queue.process('every', function(job, done) { 
    ... 
    done(); 
}); 

KUE調度文檔:https://github.com/lykmapipo/kue-scheduler; 在他們的文檔鏈接到cron的東西:https://github.com/kelektiv/node-cron;