Rails: Как добавить Sidekiq :: Дебют в цепочку промежуточного программного обеспечения

Question

Я использую Sidekiq debounce, чтобы оценить ограничение количества заданий в таймфрейме. Вот моя работа:

class CalculateAllEventRankingsForUser 
    include Sidekiq::Worker 
    sidekiq_options debounce: true 

    def perform(user_id) 
    puts "recalculating all events for user" 
    ## do some work 
    end 

end 

Где я называю работу:

CalculateAllEventRankingsForUser.perform_in(20.seconds, self.id) 

И мой sidekiq инициализатор:

Sidekiq.configure_server do |config| 
    config.client_middleware do |chain| 
    chain.add Sidekiq::Debounce 
    end 
    config.server_middleware do |chain| 
    chain.add Sidekiq::Debounce 
    end 
end 

Вопрос заключается в том, что все мои sidekiq работы все еще обрабатывается, даже если я стреляю несколькими в течение 20 секунд. Мое намерение заключается в том, чтобы увольнять только одну работу каждые 20 секунд (максимум).

Из документов:

Добавить Sidekiq :: DEBOUNCE к вашему клиенту промежуточного слоя цепи, а затем добавить sidekiq_options дребезга: правда работника, который вы хотите дребезг.

Используйте #perform_in вместо #perform_async, чтобы установить таймфрейм.

Главное, что я не уверен в том, как добавить Sidekiq :: Debounce к моей цепочке промежуточного программного обеспечения. Не уверен, что я делаю это правильно.

Любые идеи о том, как разрешить это?

Answer 1

sidekiq-debounce работает с sidekiq 4.2. Причина, по которой это не произошло, скорее всего вызвана тем, как клиентское промежуточное программное обеспечение было настроено в коде, который вы использовали.

Это должно работать:

Sidekiq.configure_server do |config| 
    config.server_middleware do |chain| 
    chain.add Sidekiq::Debounce 
    end 
end 

Sidekiq.configure_client do |config| 
    config.client_middleware do |chain| 
    chain.add Sidekiq::Debounce 
    end 
end