2012-03-11 28 views
3

使用上帝(godrb.com)我试图编写一个配置文件来启动新流程,而不管现有流程在部署应用程序时的状态如何。现有流程需要长时间运行才能完成当前任务,但新流程应立即使用新部署的代码立即开始。上帝 - 在现有流程仍在停止的情况下启动新流程

我现在已经设置了停止300秒的超时,但在启动新过程之前等待整个300秒。

God.watch do |w| 
    w.name = "sidekiq" 
    w.interval = 30.seconds 
    w.start = "bash -lc 'cd /path/to/current && ./bin/sidekiq -P /path/to/shared/pids/sidekiq.pid'" 
    w.stop = "bash -lc 'kill -USR1 `cat /path/to/shared/pids/sidekiq.pid`'" 
    w.stop_timeout = 300.seconds 
    w.pid_file = "/path/to/shared/pids/sidekiq.pid" 
    w.behavior(:clean_pid_file) 
end 

在这种情况下,kill -USR1告诉sidekiq完成处理任何当前作业,但不采取工作了。

我想保留现有工人的300秒超时,但一旦运行kill命令就启动新的进程。

+0

你看着独角兽如何做到这一点?这使得独角兽有责任培养新员工,让新员工杀死旧员工。 – d11wtq 2012-03-12 00:13:06

+0

是的,但该功能是Unicorn的一部分。我试图完成类似于任何通用过程的东西。 – bensie 2012-03-12 00:46:55

回答

0

我认为你必须定义一些转换。

这是我god.rb

# I'm using Rails 
rails_env = ENV['RAILS_ENV'] || 'development' 
rails_root = '/path/to/current' 
pid_file = "#{rails_root}/tmp/pids/sidekiq.pid" 

God.watch do |w| 
    w.dir = rails_root 
    w.name = "sidekiq" 
    w.interval = 30.seconds 
    w.env = {'RAILS_ENV' => rails_env, 'BUNDLE_GEMFILE' => "#{rails_root}/Gemfile"} 
    w.uid = 'deployer' 
    w.gid = 'staff' 

    w.start = "cd #{rails_root}; bundle exec sidekiq -e #{rails_env} -C#{rails_root}/config/sidekiq.yml -i #{i} -P #{pid_file}&" 
    w.stop = "cd #{rails_root}; bundle exec sidekiqctl stop #{pid_file} 10" 
    w.restart = "#{w.stop} && #{w.start}" 
    w.start_grace = 15.seconds 
    w.restart_grace = 15.seconds 
    w.pid_file = pid_file 
    w.log = "#{rails_root}/log/sidekiq.log" 

    # clean pid files before start if necessary 
    w.behavior(:clean_pid_file) 

    # 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 
相关问题