KUE 可以执行外部流程吗？答案

【问题标题】：Can KUE execute external processes?KUE 可以执行外部流程吗？
【发布时间】：2014-10-21 06:03:13
【问题描述】：

是否可以在 KUE https://github.com/LearnBoost/kue 中将脚本作为作业排队和执行？

像/usr/bin/myScript.sh -a 10 -b 20 -c 30这样的脚本
我看到的所有示例都假设作业被定义为 Node.js 函数。

如果可以的话，如何定义作业名称、脚本路径和脚本参数？

对于相同的任务，有没有比 KUE 更好的替代方案。
最好具有 UI 和小内存占用。 :)

【问题讨论】：

您是否考虑过从您的 Kue 队列调用的节点应用程序中执行外部进程？例如：编写一个节点脚本，其中包含对您的外部脚本的调用，并让 Kue 调用您的节点脚本。

标签： node.js process kue

【解决方案1】：

首先，编写一个节点工作者来使用 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 );
});

记得在save 之前添加complete、failed 和failed attempt 的事件处理程序。

【讨论】：