2017-04-12 37 views
1

我使用快遞,並且希望在有人張貼到我的路線時隨時創建工作。我想要包含job.id的響應。但是,作業ID只填充在我的queue.createFunction的回調中,所以我不太確定如何返回作業ID?我能想到的一個解決方案是在我的路線中發佈一個post請求來創建一個工作,因爲他們的api返回一個id作爲響應,但這似乎效率低下。如何在Kue中返回jobID?

回答

0

不是100%,如果這個回答你的問題,但我用下面來之前,POST請求創建一個作業:

const queue = kue.createQueue({ 
    redis: { 
    port: conf.redis_port, 
    host: conf.redis_host, 
    }, 
}) 

app.post('endpoint', function(req, res, next) { 
    let job = queue.create('some_action', req.data) 

    // ... add job listeners etc. 

    job.save(function(err) { 
     if (err) { 
      return res.send({ error: err }) 
     } else { 
      return res.send({ id: job.id }) 
     } 
    }) 

}) 

希望它能幫助! :)