与流星工作收集

Question

我使用meteor-job-collection（https://github.com/vsivsi/meteor-job-collection）启动作业;但是，我无法创造一份工作。

我有一个方法定义为

Meteor.methods({ 
    insertItems: function (dataArray) { 
    check(dataArray, [ Object ]); 

    dataArray.forEach(function (element) { 
     [...] 
    }); 
    } 
}); 

但该方法是非常内存有较高要求，所以我想将其包装工作中。我如何开始这项工作？

我已经试过

var job = new Job(Jobs, 'insertItems', data).priority('normal').retry(
    { 
    retries: 5, 
    wait: 15 * 60 * 1000 
    } 
).delay(60 * 60 * 1000).save(); 

，但我得到的

Jobs = JobCollection('jobQueue'); 

if (Meteor.isServer) { 
    Jobs.allow({ 
    admin: function (userId, method, params) { 
     return true; 
    }, 
    }); 
} 

Answer 1

多的东西从你的代码所缺少

Error invoking Method 'jobQueue_jobSave': Internal server error [500] 

我的工作集合定义的错误。

1 - 确保您提交任何作业之前启动作业服务器。呼叫startJobServer（）在服务器上的jobCollection。

Jobs = JobCollection('jobQueue'); 

if (Meteor.isServer) { 
    Jobs.allow({ 
    admin: function (userId, method, params) { 
     return true; 
    }, 
    }); 
    Jobs.startJobServer(); 
} 

2 - 您需要执行作业的处理。一份工作只不过是一个附有数据的标签，计划在某个时间点运行。处理程序实现作业逻辑。在你的情况，你会需要的东西是这样的：在您的服务器控制台

var workers = Job.processJobs('jobQueue', 'insertItems', 
    function (job, cb) { 
    insertData = job.data; 
    // do anything with the job data here. 
    // when done, call job.done() or job.fail() 

    job.done(); // when done successfully 
    job.fail("with reason or error"); //when failing 

    // Be sure to invoke the callback 
    // when work on this job has finished 
    cb(); 
    } 
);