Rails: Wie Sidekiq :: Debounce zu meiner Middleware-Kette hinzufügen

Question

Ich verwende Sidekiq debounce, um die Anzahl der Jobs in einem Zeitrahmen Rate zu begrenzen. Hier ist mein Job:

class CalculateAllEventRankingsForUser 
    include Sidekiq::Worker 
    sidekiq_options debounce: true 

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

end 

Wo ich den Job nennen:

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

Und mein sidekiq initializer:

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 

Das Problem ist, dass alle meine sidekiq Arbeitsplätze noch verarbeitet werden, sogar wenn ich innerhalb des Zeitfensters von 20 Sekunden feuere. Meine Absicht ist, dass nur ein Job alle 20 Sekunden (maximal) ausgelöst wird.

Aus der Dokumentation:

hinzufügen Sidekiq :: Debounce auf Ihre Client-Middleware-Kette, und dann sidekiq_options debounce hinzufügen: getreu dem Arbeiter Sie Entprellen wollen.

Verwenden Sie #perform_in anstelle von #perform_async, um den Zeitrahmen festzulegen.

Hauptsache ich bin mir nicht sicher, wie Sidekiq :: Debounce zu meiner Middleware-Kette hinzuzufügen. Ich bin mir nicht sicher, ob ich das richtig mache.

Irgendwelche Ideen zur Lösung?

Answer 1

sidekiq-debounce arbeitet mit sidekiq 4.2. Der Grund, warum dies nicht der Fall war, ist wahrscheinlich auf die Art und Weise zurückzuführen, in der Client-Middleware in dem von Ihnen freigegebenen Code konfiguriert wurde.

Dies sollte funktionieren:

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