Ограничьте количество рабочих в очереди в Sidekiq

Я пытался ограничить количество воркеров в очереди, используя гем sidekiq-limit_fetch, и Sidekiq, кажется, «видит» наложенные ограничения в журнале, но когда я наблюдаю за рабочими, ограничения игнорируются.

Вот часть лога, где Sidekiq видит лимиты:

2013-04-02T05:47:19Z 748 TID-11ilcw DEBUG: {:queues=>
    ["recommendvariations",
     "recommendvariations",
     "recommendvariations",
     "recommendphenotypes",
     "recommendphenotypes",
     "recommendphenotypes",
     "preparse",
     "preparse",
     "preparse",
     "parse",
     "parse",
     "parse",
     "zipgenotyping",
     "zipgenotyping",
     "zipfulldata",
     "deletegenotype",
     "fitbit",
     "frequency",
     "genomegov",
     "mailnewgenotype",
     "mendeley_details",
     "mendeley",
     "pgp",
     "plos_details",
     "plos",
     "snpedia",
     "fixphenotypes"],
   :concurrency=>5,
   :require=>".",
   :environment=>"production",
   :timeout=>8,
   :profile=>false,
   :verbose=>true,
   :pidfile=>"/tmp/sidekiq.pid",
   :logfile=>"./log/sidekiq.log",
   :limits=>
    {"recommendvariations"=>1,
     "recommendphenotypes"=>1,
     "preparse"=>2,
     "parse"=>2,
     "zipgenotyping"=>1,
     "zipfulldata"=>1,
     "fitbit"=>3,
     "frequency"=>10,
     "genomegov"=>1,
     "mailnewgenotype"=>1,
     "mendeley_details"=>1,
     "mendeley"=>1,
     "pgp"=>1,
     "plos_details"=>1,
     "plos"=>1,
     "snpedia"=>1,
     "fixphenotypes"=>1},
   :strict=>false,
   :config_file=>"config/sidekiq.yml",
   :tag=>"snpr"}

и вот sidekiq.yml. Судя по веб-интерфейсу sidekiq, ограничения игнорируются - прямо сейчас у меня есть 2 воркера в очереди "recommendvariations", но должно быть 1.

Запускаю рабочие над bundle exec sidekiq -e production -C config/sidekiq.yml.

Кто-нибудь еще сталкивался с этим?


ruby ruby-on-rails sidekiq
person Philipp    schedule 02.04.2013    source источник

Ответы (1)


arrow_upward
4
arrow_downward

Вы пытались установить ограничение в файле инициализатора sidekiq.rb?

Как это:

Sidekiq::Queue['recommend'].limit = 1

Это сработало для меня.

person Jirico    schedule 15.05.2013
comment
Это сработало, но поскольку у меня также была установлена ​​старая версия сборщика (1.0.21), обновление, которое это исправило - person Philipp; 24.05.2013
comment
Можем ли мы сделать это для конкретной очереди? - person aks; 15.09.2016