Thường xuyên thanh tẩy công nhân khôi phục cũ trên Heroku?

Question

Tôi có nhân viên Resque thường không mất nhiều thời gian hơn khoảng 1-5 phút để chạy, nhưng thường những công nhân đó sẽ bị "kẹt" và không hoạt động, làm tắc nghẽn công nhân và không làm gì cả.

Vì vậy, tôi muốn thường xuyên kiểm tra các công nhân đã chạy lâu hơn X và thanh lọc chúng. Nhưng tôi cần phải làm điều này tự động, vì vậy tôi không phải đích thân đi vào và tự xóa chúng (Resque.workers.each {|w| w.unregister_worker}) vài giờ một lần.

Điều này cần phải hoạt động trên Heroku.

Answer 1

Đặt này thành một nhiệm vụ rake:

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

Sử dụng Heroku lên lịch, bạn có thể đặt nó ở mức tối thiểu là 10 phút nếu đó dãy phòng.

Answer 2

Đối 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 

Từ dòng lệnh, rake clear:stale_workers

On Heroku, thiết lập các bộ scheduler để chạy nhiệm vụ Rake này.

Answer 3

Điều này đã giúp tôi xóa những công nhân cụ thể đang chạy công việc cũ. Bạn có thể thêm nó vào một công việc cào.

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