2013-01-22 61 views
3

我正在努力使用Sidekiq以及God Gem。我希望能够使用$god start sidekiq手动启动sidekiq进程,但是无法启动该进程。如果我设置w.keepalive(在下面的代码中注释掉),我只能让它启动sidekiq进程。

我使用的发射神$ god -c "./config.god" -D --log-level info,其中让我下面的输出前景发射神:

I [2013-01-22 17:46:00] INFO: Started on drbunix:///tmp/god.17165.sock 
I [2013-01-22 17:46:00] INFO: sidekiq move 'unmonitored' to 'up' 
I [2013-01-22 17:46:00] INFO: sidekiq moved 'unmonitored' to 'up' 

使用$god start sidekiq我得到:

Sending 'start' command 

The following watches were affected: 
    sidekiq 

但我没有得到任何来自输出上帝,没有什么是写在sidekiq的日志,我可以清楚地看到没有sidekiq进程已经开始使用$ ps auxwww | grep sidekiq

# config.god 

PROJECT_ROOT = ENV['PROJECT_ROOT'] || File.dirname(__FILE__) # Dir containing this file 

# Sidekiq Process 

God.watch do |w| 
    w.name = "sidekiq" 
    w.group = "conversion" 
    w.dir = PROJECT_ROOT 
    w.interval = 20.seconds 
    w.start_grace = 10.seconds 
    w.restart_grace = 10.seconds 
    w.behavior(:clean_pid_file) 
    # w.keepalive 
    w.start = "bundle exec sidekiq -v -C#{File.join(PROJECT_ROOT, 'config.yml')}" 
    w.stop = "bundle exec sidekiqctl stop '/Users/me/.god/pids/sidekiq.pid' 5" 

    w.log = File.join(PROJECT_ROOT, 'log/god_sidekiq.log') 

end 

回答

0

试试这个:

# config.god 

PROJECT_ROOT = ENV['PROJECT_ROOT'] || File.dirname(__FILE__) # Dir containing this file 

# Sidekiq Process 
pid_file = '/Users/me/.god/pids/sidekiq.pid' 
God.watch do |w| 
    w.name = "sidekiq" 
    w.group = "conversion" 
    w.dir = PROJECT_ROOT 
    w.interval = 20.seconds 
    w.start_grace = 10.seconds 
    w.restart_grace = 10.seconds 
    w.pid_file = pid_file 
    w.behavior(:clean_pid_file) 

    w.start = "cd #{PROJECT_ROOT}; bundle exec sidekiq -v -C#{File.join(PROJECT_ROOT, 'config.yml')} -P #{pid_file}&" 
    w.stop = "cd #{PROJECT_ROOT}; bundle exec sidekiqctl stop #{pid_file} 5" 

    w.log = File.join(PROJECT_ROOT, 'log/god_sidekiq.log') 

    # 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 
    end 

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

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

    # lifecycle 
    w.lifecycle do |on| 
    on.condition(:flapping) do |c| 
     c.to_state = [:start, :restart] 
     c.times = 5 
     c.within = 5.minute 
     c.transition = :unmonitored 
     c.retry_in = 10.minutes 
     c.retry_times = 5 
     c.retry_within = 2.hours 
    end 
    end 
end