Czy w Sidekiq są komendy konsolowe, które sprawdzają, co znajduje się w kolejce i czyściły kolejkę?

Istnieje ergonomiczne APIdo przeglądania i zarządzania kolejkami .

Domyślnie nie jest wymagane.

require 'sidekiq/api'

Oto fragment:

# get a handle to the default queue
default_queue = Sidekiq::Queue.new 

# get a handle to the mailer queue
mailer_queue = Sidekiq::Queue.new("mailer") 

# How many jobs are in the default queue?
default_queue.size # => 1001

# How many jobs are in the mailer queue?
mailer_queue.size # => 50

#Deletes all Jobs in a Queue, by removing the queue.    
default_queue.clear

Możesz również uzyskać statystyki zbiorcze.

stats = Sidekiq::Stats.new

# Get the number of jobs that have been processed.
stats.processed # => 100

# Get the number of jobs that have failed.    
stats.failed # => 3

# Get the queues with name and number enqueued.
stats.queues # => { "default" => 1001, "email" => 50 }

#Gets the number of jobs enqueued in all queues (does NOT include retries and scheduled jobs).
stats.enqueued # => 1051 

Jeśli jest jakaś zaplanowana praca. Możesz usunąć wszystkie zadania używając następującego polecenia:

Sidekiq::ScheduledSet.new.clear

Jeśli są kolejki do usunięcia wszystkich zadań, możesz użyć następującego polecenia:

  Sidekiq::Queue.new.clear

Zadania Retries można również usunąć za pomocą następującego polecenia:

Sidekiq::RetrySet.new.clear

Więcej informacji znajduje się pod poniższym linkiem, możesz dokonać zakupu: https://github.com/mperham/sidekiq/wiki/API

Istnieje API umożliwiające dostęp do informacji w czasie rzeczywistym o pracownikach, kolejkach i zadaniach.
Odwiedź tutaj https://github.com/mperham/sidekiq/wiki/API

Obejściem problemu jest użycie modułu testowego (wymaga "sidekiq / testing") i opróżnienie workera (MyWorker.drenażu).

A jeśli chcesz wyczyścić kolejkę powtórek sidekiq, to jest to: Sidekiq::RetrySet.new.clear

$ redis-cli
> select 0 # (or whichever namespace Sidekiq is using)
> keys * # (just to get an idea of what you're working with)
> smembers queues
> lrange queue:queue_name 0 -1 # (queue_name must be your relevant queue)
> lrem queue:queue_name -1 "payload"

W domyślnej kolejce wisiały 'workers' i mogłem je zobaczyć przez interfejs WWW. Ale nie były dostępne z konsoli, jeśli użyłem Sidekiq:: Queue.nowy.rozmiar

irb(main):002:0> Sidekiq::Queue.new.size
2014-03-04T14:37:43Z 17256 TID-oujb9c974 INFO: Sidekiq client with redis options {:namespace=>"sidekiq_staging"}
=> 0

Używając redis-cli udało mi się je znaleźć

redis 127.0.0.1:6379> keys *
    1) "sidekiq_staging:worker:ip-xxx-xxx-xxx-xxx:7635c39a29d7b255b564970bea51c026-69853672483440:default"
    2) "sidekiq_staging:worker:ip-xxx-xxx-xxx-xxx:0cf585f5e93e1850eee1ae4613a08e45-70328697677500:default:started"
    3) "sidekiq_staging:worker:ip-xxx-xxx-xxx-xxx:7635c39a29d7b255b564970bea51c026-69853672320140:default:started"
    ...

Rozwiązaniem było:

irb(main):003:0>  Sidekiq.redis { |r| r.del "workers", 0, -1 }
=> 1

Również w Sidekiq v3 jest komenda

Sidekiq::Workers.new.prune

Ale z jakiegoś powodu nie zadziałało dla mnie tego dnia

Zadanie prowizji dla wyczyszczenia wszystkich kolejek sidekiq:

namespace :sidekiq do
  desc 'Clear sidekiq queue'
  task clear: :environment do
    require 'sidekiq/api'
    Sidekiq::Queue.all.each(&:clear)
  end
end

Użycie:

rake sidekiq:clear