0

私は現在、神を使って6つのresqueワーカープロセスを開始しています。Resqueショーは、それらが開始されて機能しており、すべてが機能していることを示しています。時折、ワーカープロセスが認識されなくなり、既知のresqueワーカープロセスでなくなることがあります。私が探しているのは、そのプロセスを再開するか、resque-webに再度認識させる方法です。奇妙なことに、それはまだバックグラウンドで実行されており、タスクをフォークしてそれらを処理し、resque-webで数が減少しているのを見ることができますが、ワーカーが実行されていることを示していません。私は彼らのstale.godスクリプトを調べましたが、プロセスがresque-webの認識から外れた後もジョブを取得し続けるように見えるため、それは機能しません。これが私の設定です：

#resque-production.god

6.times do |num|
  God.watch do |w|
    w.name = "resque-#{num}"
    w.group = "resque"
    w.interval = 30.seconds
    w.env = { 'RAILS_ENV' => 'production' }
    w.dir = File.expand_path(File.join(File.dirname(__FILE__)))
    w.start = "bundle exec rake environment RAILS_ENV=production resque:workers:start"
    w.start_grace = 10.seconds
    w.log = "/var/www/loadmax/shared/log/resque-worker.log"

    # restart if memory gets too high
    w.transition(:up, :restart) do |on|
      on.condition(:memory_usage) do |c|
        c.above = 200.megabytes
        c.times = 2
      end
    end

    # determine the state on startup
    w.transition(:init, { true => :up, false => :start }) do |on|
      on.condition(:process_running) do |c|
        c.running = true
      end
    end

    # determine when process has finished starting
    w.transition([:start, :restart], :up) do |on|
      on.condition(:process_running) do |c|
        c.running = true
        c.interval = 5.seconds
      end

      # failsafe
      on.condition(:tries) do |c|
        c.times = 5
        c.transition = :start
        c.interval = 5.seconds
      end
    end

    # start if process is not running
    w.transition(:up, :start) do |on|
      on.condition(:process_running) do |c|
        c.running = false
      end
    end
  end
end

次のファイルは、1つのredisサーバーに接続して優先順位を設定するために使用されます。

#resque.rake 
require 'resque/tasks'
Dir.glob("#{Rails.root}/app/workers/*.rb") do |rb|
  require rb
end
task "resque:setup" => :environment do
  resque_config = YAML.load_file(Rails.root.join("config","resque.yml"))
  ENV['QUEUE'] = resque_config["priority"].map{ |x| "#{x}" }.join(",") if ENV['QUEUE'].nil?
end
task "resque:workers:start" => :environment do
  threads = []
  q = [1,2]
  resque_config = YAML.load_file(Rails.root.join("config","resque.yml"))
  threads << Thread.new(q){ |qs|
    %x[bundle exec rake environment RAILS_ENV=#{Rails.env} resque:work QUEUE=#{resque_config["priority"].map{ |x| "#{x}" }.join(",")} ]
  }
  threads.each {|aThread| aThread.join }
end

私はこれに対する解決策をずっと探していましたが、ゾンビプロセス、古いプロセス、および既存のプロセスは解決策ではないようです。私はgod -c /path/to/god開始するために使用しています。

他に何か提供する必要がある場合、またはもっと明確にする必要がある場合はお知らせください。すべての助けをありがとう！

4

1 に答える 1

0

私はワーカーと同じボックスにredisを置くことになり、それ以来、それらは適切に機能しています。

于 2013-06-04T13:52:05.117 に答える