Giới hạn số lượng công nhân trên mỗi hàng đợi ở Sidekiq

Question

Tôi đã cố gắng giới hạn số lượng công nhân trên mỗi hàng đợi bằng cách sử dụng đá quý sidekiq-limit_fetch và Sidekiq dường như "thấy" các giới hạn áp đặt trong nhật ký nhưng khi tôi xem công nhân giới hạn được bỏ qua.

Đây là phần từ nhật ký nơi Sidekiq thấy các giới hạn:

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

và here's the sidekiq.yml. Đánh giá từ giao diện web của sidekiq các giới hạn được bỏ qua - ngay bây giờ, tôi nhận được 2 công nhân trên "recommendvariations" -queue nhưng phải là 1.

Tôi bắt đầu công nhân trên bundle exec sidekiq -e production -C config/sidekiq.yml.

Có ai khác từng gặp phải điều này không?

Answer 1

Bạn đã cố đặt giới hạn trong tệp trình khởi tạo sidekiq.rb chưa?

Như thế này:

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

Nó làm việc cho tôi.