Регулярно чистить устаревшие работники Resque на Heroku?

У меня есть работники «Резек», которые обычно не должны занимать больше 1-5 минут, но часто эти рабочие «застревают» и простаивают, забивая рабочих и ничего не делая.Регулярно чистить устаревшие работники Resque на Heroku?

Так что я бы хотел регулярно проверять работников, которые работали дольше X и чистили их. Но мне нужно сделать это автоматически, поэтому мне не нужно лично входить и вручную очищать их (Resque.workers.each {|w| w.unregister_worker}) каждые несколько часов.

Это должно работать на Heroku.

источник

2013-06-13 Shpigford

Является ли время, когда работник начал надежный индикатор, что он застрял? Я предполагаю, что 1-5 минут - это продолжительность работы. Но если работа будет продолжаться, рабочий может бежать вечно и не «застревать». Да? Я спрашиваю, потому что у меня такая же проблема, и я хочу надежный способ снять блокировку. –

Поместите это в задачу грабли:

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

Используйте Heroku планировщик, вы можете установить его на минимум 10 минут, если что-люкс.

источник

2013-06-24 11:26:54

Это, кажется, только Resque 2, люди используют это в производстве сейчас? Мое впечатление от README заключалось в том, что вы еще не должны его использовать. – opsb

Похоже, что worker.started сообщит вам, когда работник был первоначально зарегистрирован - НЕ, как долго он работал над текущей работой. Так что это не правильный тест, чтобы сказать, застрял ли рабочий или нет. См. [Этот ответ] (http://stackoverflow.com/a/21560463/629636) для способа извлечения времени начала текущего задания. –

Для 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

из командной строки, rake clear:stale_workers

На Heroku, установить набор планировщик для запуска этой задачи Rake.

источник

2013-11-14 11:33:24 scarver2

Это работало для меня, чтобы удалить конкретных работников, выполняющих устаревшие задания. Вы можете добавить его к задаче грабли.

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

источник

2013-12-13 17:47:13 austen

Регулярно чистить устаревшие работники Resque на Heroku?

ответ

Смежные вопросы