Regularnie usuwać nieświeżych pracowników Resque na Heroku?

Question

Mam pracowników Resque, które zazwyczaj nie powinny trwać dłużej niż około 1-5 minut, ale często ci pracownicy zostaną "zablokowani" i idą bezczynnie, zapychając pracowników i nie robiąc nic.

Chciałbym więc regularnie sprawdzać pracowników, którzy pracowali dłużej niż X i oczyścić je. Ale muszę to zrobić automatycznie, więc nie muszę osobiście wchodzić i ręcznie je kasować (Resque.workers.each {|w| w.unregister_worker}) co kilka godzin.

To musi działać na Heroku.

Answer 1

Włóż to do zadania natarcia:

allocated_time = 60 * 60 # 1 hour 
Resque::WorkerRegistry.working.each do |worker| 
    if (worker.started <=> Time.now - allocated_time) < 1 
    worker.unregister 
    end 
end 

Zastosowanie Heroku scheduler, można ustawić ją na minimum 10 minut, jeśli, że apartamenty.

Answer 2

Dla Resque v1,

# lib/tasks/clear_stale_workers.rake 
namespace :clear do 
    desc 'Clearing stuck workers ...' 
    task :stale_workers => :environment do 
    Resque.workers.each do |w| 
     w.unregister_worker unless w.started > 1.hour.ago 
    end 
    end 
end 

Z linii poleceń, rake clear:stale_workers

Na Heroku ustaw zestawie harmonogramu uruchamiania tego zadania Rake.

Answer 3

To działało dla mnie, aby usunąć konkretnych pracowników, którzy wykonują nieaktualne prace. Możesz dodać go do zadania rake.

Resque::Worker.working.each{|w| w.done_working }