1

我正在使用快递,并且想在有人发布到我的路线时创建工作。我希望响应包含 job.id。但是,作业 ID 仅填充在我的 queue.createFunction 的回调中,所以我不太确定如何返回作业 ID?我能想到的一种解决方案是在我的路线中发出一个发布请求来创建一个工作,因为他们的 api 返回一个 id 作为响应,但这似乎效率低下。

4

1 回答 1

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 })
        }
    })

})

希望能帮助到你!:)

于 2017-04-13T05:26:45.870 回答