ruby-on-rails-3.2 - 使用 "custom"队列名称的 Sidekiq 工作器被分配给 "default"队列

Question

Rails 3.2.9
Ruby 1.9.3dev (2011-09-23 revision 33323) [i686-linux]
sidekiq  2.10.1

如果我使用自定义队列名称定义如下所示的 worker

  class BulkEmailWorker
    include Sidekiq::Worker
    # https://github.com/mperham/sidekiq/wiki/Advanced-Options
    sidekiq_options(queue: :bulk_mails, backtrace: true)

    # https://github.com/mperham/sidekiq/wiki/Best-Practices
    # Section: Make your jobs small and simple
    def perform
      # https://github.com/mperham/sidekiq/wiki/Delayed-Extensions
      scheduled_mails = MailTemplate.with_schedule
      scheduled_mails.each do |mail_template|
        BulkMailer.delay.general_mail(mail_template.id)
      end
    end
  end

我像这样调用 worker :

  BulkEmailWorker.perform_async

它不起作用(换句话说，它不发送电子邮件)。

检查 redis 中的数据，我发现以下内容:

  redis 127.0.0.1:6379> keys *
  1) "myapp:stat:processed:2013-04-24"
  2) "myapp:queue:default"
  3) "myapp:stat:processed"
  4) "myapp:queues"

  redis 127.0.0.1:6379> lrange myapp:queue:default -100 100

   1) "{\"retry\":true,\"queue\":\"default\",\"timeout\":30,\"class\":\"Sidekiq::Extensions::DelayedMailer\",\"args\":[\"---\\n- !ruby/class 'BulkMailer'\\n- :general_mail\\n- - 1\\n\"],\"jid\":\"e46693944febf7ae26ec67a0\"}"

Redis 127.0.0.1:6379>

从上面可以看出，工作人员被分配到队列“默认”，我猜因此工作人员无法处理。

对于上述场景，我使用以下命令启动了 sidekiq:

  bundle exec sidekiq -e dev_mysql -C config/sidekiq.yml -q bulk_mails

但是，当我从我的工作人员中删除以下内容时

    sidekiq_options(queue: :bulk_mails, backtrace: true)

并使用以下命令启动 sidekiq:

  bundle exec sidekiq -e dev_mysql -C config/sidekiq.yml

它有效(换句话说，它成功发送了电子邮件)。

/config/sidekiq.yml

# https://github.com/mperham/sidekiq/wiki/Logging
# http://stackoverflow.com/questions/15260634/sidekiq-configuration-for-multiple-environments
---
  :verbose: true
  :pidfile: ./tmp/pids/sidekiq.pid
  :logfile: ./log/sidekiq.log
  :concurrency:  25

我刚刚开始使用 Sidekiq 并且是新手。所以如果我有一些我误解或不知道的概念，请多多包涵。

我需要摆脱提到的问题，以便我的工作人员被分配到所需的队列并成功处理。

谢谢，
吉涅什

Answer 1

另外，请注意，您可以使用 Sidekiq::Client.push 将作业推送到您想要的队列中。而不是 perform_async :

Sidekiq::Client.push({
  'class' => BulkEmailWorker,
  'queue' => 'bulk_mails',
  'args'  => [ 1, 2 ]
})

请注意键( class 、 queue 、 args ) 必须是字符串，而不是符号，否则你会得到 ArgumentError: Message must include a class and set of arguments .

当您需要使用变量名(bulk_mails.1、bulk_mails.2 等)将作业推送到队列上时，这尤其有用，因此您可以轻松地 控制并发感谢 sidekiq-limit_fetch，在某些队列中一次只允许一项作业.