まず、Kue ジョブを使用するノード ワーカーを記述します。例:worker.js
次に、kue コードを追加します。
var kue = require('kue')
, queue = kue.createQueue();
そして、目的のコードにリスナーを追加します。
queue.process('MYEXTERNALJOB', function(job, done){
runJob(job.data, done);
});
試してくださいchild_process.exec
:
function runJob(data, done){
//You can use the job's data object to pass your external script parameters
var a = data.a;
var b = data.b;
var c = data.c;
var yourCode = '/usr/bin/myScript.sh -a ' + a + ' -b ' + b + ' -c ' + c
var exec = require('child_process').exec,
child;
child = exec(yourCode,
function (error, stdout, stderr) {
console.log('stdout: ' + stdout);
console.log('stderr: ' + stderr);
if (error !== null) {
console.log('exec error: ' + error);
done(error); //callback with error for your publisher code
}else{
done(null, stdout); // callback with the results, which you can potentially use on your publisher code
}
});
}
}
次に、Kue ジョブをポーリングできるようにワーカーを実行することを忘れないでください。
$ node worker.js
MYEXTERNALJOB
メインコードでジョブを作成するだけです
var kue = require('kue')
, queue = kue.createQueue();
var job = queue.create('MYEXTERNALJOB', {
a: 10
, b: 20
, c: 30
}).save( function(err){
if( !err ) console.log( job.id );
});
complete
、failed
および のfailed attempt
前にイベント ハンドラを追加することを忘れないでくださいsave
。