ruby - Reiniciando Sidekiq

sinatra restart

Question

¿Cuál es la forma correcta de reiniciar sidekiq. Parece que el código de mis trabajadores se almacena en caché cuando lo inicio, por lo que cada vez que hago un cambio en mis trabajadores, necesito reiniciarlo. Estoy haciendo esto con Ctrl / C, pero el proceso toma mucho tiempo para relajarme y regresar al indicador.

¿Hay una manera de forzar un reinicio con efecto inmediato?

Estoy usando la última versión con Sinatra corriendo a través de POW.

Answer 1

Sidekiq viene con el comando sidekiqctl, que puede detener el PID asociado con su proceso Sidekiq. Pasas el archivo PID y el número de segundos para esperar a que todos los hilos terminen.

Uso de la muestra:

sidekiqctl stop #{rails_root}/tmp/pids/sidekiq_website_crawler.pid 60

Aquí, 60 representa el número de segundos a esperar hasta que todos los subprocesos de Sidekiq hayan terminado de procesarse. Si pasan 60 segundos y no se hacen todos, se eliminan automáticamente.

También recomiendo usar la gema de Dios para monitorear, detener, iniciar y reiniciar Sidekiq.

Una vez que hagas eso, puedes usar bundle exec god stop para detener todos los hilos de sidekiq.

Aquí está mi archivo de Dios, como ejemplo:

rails_env = ENV[''RAILS_ENV''] || "development"
rails_root = ENV[''RAILS_ROOT''] || "/home/hwc218/BuzzSumo"
 God.watch do |w|
     w.dir      = "#{rails_root}"
     w.name     = "website_crawler"
     w.interval = 30.seconds
     w.env      = {"RAILS_ENV" => rails_env}
     w.interval = 30.seconds
     w.start = "bundle exec sidekiq -C #{rails_root}/config/sidekiq_website_crawler.yml"
     w.stop = "sidekiqctl stop #{rails_root}/tmp/pids/sidekiq_website_crawler.pid 60"
     w.keepalive


    # 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

    w.restart_if do |restart|
        restart.condition(:restart_file_touched) do |c|
          c.interval = 5.seconds
          c.restart_file = File.join(rails_root, ''tmp'', ''restart.txt'')
        end
    end
 end