我正在使用 mongoose 和 Kue 进行流量控制。我将从数据库中检索到的对象传递给 Kue。当作业得到处理时,该对象不再具有某些功能,例如 .save() 等。
jobs.process('process', 5, function(job, done) {
var url = job.data.url;
var objo = job.data.comp;
request({uri:url, json:true}, function(err, res, body) {
objo.meta = body;
// Here it throw an error that save is note defined
// TypeError: Object #<Object> has no method 'save'
objo.save(function(err) {
if (err)
throw err;
console.log('Saved data for ' + objo.title);
done();
});
});
});
var q = db.Entity.find({}).sort('_id', 1).limit(10);
q.execFind(function(err, docs) {
docs.forEach(function(objo) {
jobs.create('process', {
comp : objo,
url : 'http://example.com/' + encodeURIComponent(objo.permalink) + '.js'
}).save();
})
});
提前致谢