清除sidekiq队列

Question

我是这个永远奔跑的工人.

class Worker
  include Sidekiq::Worker
  sidekiq_options queue: "infinity", retry: true

  def perform(params)
    # ...
    self.class.perform_in(30.seconds, params)
  end
end

问题是我在启动时加载工人,就像这样. config/initializers/load_workers.rb

Rails.application.config.after_initialize do  
  if ENV["SIDEKIQ"] == "1"
    Worker.perform_async({})
  end
end

用这个来启动sidekiq SIDEKIQ=1 sidekiq --verbose --environment production -C config/sidekiq.yml.

这意味着老工人要停下来,既有目前正在运行的人,也有被重新安排的人.

我尝试在启动时运行它(在加载新工作之前),但这不起作用.

q = []
q += Sidekiq::RetrySet.new.select { |job| job.klass.match(/Worker/) }
q += Sidekiq::Queue.new("infinity").select { |job| job.klass.match(/Worker/) }
q += Sidekiq::ScheduledSet.new.select { |job| job.klass.match(/Worker/) }
q.each(&:delete)

在5-ish部署之后,队列中有大量重复的工作程序安排在稍后.那么,有没有办法清除一个队列中的每一个并阻止已经重新安排的作业？

我正在使用sidekiq 3.0.

Answer 1

删除队列,删除队列中的所有作业.

require 'sidekiq/api' # for the case of rails console

Sidekiq::Queue.new("infinity").clear
Sidekiq::RetrySet.new.clear
Sidekiq::ScheduledSet.new.clear

Answer 2

这对我有用:

Sidekiq::Queue.all.each(&:clear)
Sidekiq::RetrySet.new.clear
Sidekiq::ScheduledSet.new.clear
Sidekiq::DeadSet.new.clear

Answer 3

适用于大多数sidekiq版本:

Sidekiq::RetrySet.new.clear

Sidekiq::ScheduledSet.new.clear

清除统计数据(可选)

Sidekiq::Stats.new.reset