Jak usunąć wszystkie prace z Sidekiqa?

Używam sidekiq do zadań w tle w aplikacji Rails. Teraz liczba miejsc pracy rośnie, więc chcę usunąć wszystkie zadania. Wypróbowałem następujące polecenie w konsoli

Sidekiq::Queue.new.clear

ale dawał następujący błąd.

NameError: uninitialized constant Sidekiq::Queue 

Jak usunąć wszystkie zadania z sidekiqa?

Zgodnie z tym wydaniem na Github: https://github.com/mperham/sidekiq/issues/1732 musisz teraz

require 'sidekiq/api'

Możesz zrobić to, co mówi w sprawie 1077 lub jak opisano na tym blogu na noobsippets

Obaj sugerują wykonanie następujących czynności i można to zrobić na konsoli szynowej:

Sidekiq.redis { |conn| conn.flushdb }

Wyczyść polecenia Sidekiq Jobs:

require 'sidekiq/api'

# Clear retry set

Sidekiq::RetrySet.new.clear

# Clear scheduled jobs 

Sidekiq::ScheduledSet.new.clear

# Clear 'Dead' jobs statistics

Sidekiq::DeadSet.new.clear

# Clear 'Processed' and 'Failed' jobs statistics

Sidekiq::Stats.new.reset

# Clear specific queue

stats = Sidekiq::Stats.new
stats.queues
# => {"main_queue"=>25, "my_custom_queue"=>1}

queue = Sidekiq::Queue.new('my_custom_queue')
queue.count
queue.clear

Od ostatniego Sidekiqa, po prostu wysadź to w powietrze:

require 'sidekiq/api'

q = Sidekiq::Queue.new
q.💣

Tak, polecenie wyczyszczenia wszystkiego jest dosłownie emoji bomby. Działa również dla Sidekiq::RetrySet.

Lub jeśli nie jesteś zabawny, możesz użyć q.clear

redis-cli flushdb

Możesz także użyć redis-cli flushall

Użyj prowadnicy Rails w jednej linii

rails runner 'Sidekiq.redis { |conn| conn.flushdb }'

Wszystkie zadania Sidekiq są zapisywane w „Redis”.

Za pomocą tego polecenia można wyczyścić „Redis”

redis-cli flushall

Możesz użyć tego do usunięcia wszystkich zadań

require 'sidekiq/api'

Sidekiq::Queue.all.each(&:clear)

Jeśli chcesz usunąć zadania z określonych kolejek, spróbuj:

queue = Sidekiq::Queue.new("default")
queue.each do |job|
  job.klass # => 'TestWorker'
  job.args # => ['easy']
  job.delete if job.jid == 'abcdef1234567890' || job.klass == 'TestWorker'
end

Przeczytaj wszystko o sidekiq i ważnych poleceniach konsoli - https://medium.com/@shashwat12june/all-you-need-to-know-about-sidekiq-a4b770a71f8f

require 'sidekiq/api'

Sidekiq::Queue.all.each(&:clear)

Zdałem sobie sprawę, że Sidekiq.redis { |conn| conn.flushdb }usuwa wszystkie klucze z bazy danych redis. Istnieje bezpieczniejszy sposób na wyczyszczenie wszystkich kolejek sidekiq za pomocą redis-cli:

redis-cli keys "*queue:*" | xargs redis-cli del

To samo można osiągnąć dzięki Sidekiq API (patrz odpowiedź Ravi Prakash Singh )