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

如果我使用自定义队列名称定义如下所示的工作人员

  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

我像这样调用工人：

  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\"}"

雷迪斯 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 并且是新手。所以如果我有一些我误解或不知道的概念，请多多包涵。

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

谢谢，吉涅什

4

2 回答 2

17

此外，请注意，您可以通过使用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。

于 2013-11-03T09:56:53.623 回答
8

您可以在 sidekiq.yml 配置文件中添加队列名称和权重：

:queues:
- [bulk_mails, 7]
- [default, 5]

-C config/sidekiq.yml使用该选项启动 sidekiq 。现在您可以在您的工作人员中引用队列名称：

sidekiq_options :queue => :bulk_mails
于 2013-04-25T13:55:41.347 回答