☰

Sidekiqキューをクリアする 質問する

tag-icon • tag-icon ruby-on-rails sidekiq
Sidekiqキューをクリアする 質問する

永遠に稼働し続ける労働者がいます。

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 回ほどデプロイすると、後で実行するようにスケジュールされたキューに重複したワーカーが多数存在します。1 つのキュー内のすべてをクリアし、すでに実行中のジョブが再スケジュールされるのを防ぐ方法はあるでしょうか?

私はsidekiq 3.0を使用しています。

ベストアンサー1

キューを削除して、キュー内のすべてのジョブを削除します。

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

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

おすすめ記事