如何在特定队列中推送工作并使用sidekiq限制人数? [英] How to push job in specific queue and limit number workers with sidekiq?

问题描述

我知道我们可以做到:

sidekiq_options queue: "Foo"

但是在这种情况下，只有一个队列"Foo"被分配给了Worker.

But in this case it's the Worker which is assigned to only one queue: "Foo".

我需要在特定队列中分配一个Job(而不是Worker). 使用Resque很容易:

I need to assign a Job (and not a Worker) in specific queue. With Resque it's easy:

Resque.enqueue_to(queue_name, my_job)

此外，对于并发问题，我需要将每个队列上的Worker数量限制为1.

Further, for concurrency problem, i need to limit the number of Worker on each queue at 1.

我该怎么做?

推荐答案

您可以使用 https://github .com/brainopia/sidekiq-limit_fetch

然后:

Sidekiq::Client.push({
    'class' => GuidePdfWorker,
    'queue' => queue_name,
    'args'  => [my_job]
})
Sidekiq::Queue[queue_name].limit = 1

但是您必须在config/sidekiq.yml中声明您的queue_name

But you have to declare your queue_name in the config/sidekiq.yml

这篇关于如何在特定队列中推送工作并使用sidekiq限制人数?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！