Neustart Sidekiq

Was ist der richtige Weg, um zu starten sidekiq. Es scheint zu cache my Arbeitnehmer code, wenn ich ihn starten, also jedes mal, wenn ich eine änderung vornehmen, um meine Arbeiter, die ich brauchen, um es neu zu starten. Ich mache das mit Strg/C, aber der Prozess dauert eine lange Zeit, um abschalten und mich zurückbringen, um die Eingabeaufforderung.

Ist es ein Weg, um einen Neustart zu erzwingen, mit sofortiger Wirkung?

Ich verwende die neuste version mit Sinatra, laufen über POW.

InformationsquelleAutor der Frage Undistraction | 2013-01-15

  1. 14

    Sidekiq kommt mit dem Befehl sidekiqctl, die aufhören kann die PID im Zusammenhang mit Ihrer Sidekiq-Prozess. Sie passieren in der PID-Datei und die Anzahl der Sekunden zu warten, bis alle threads fertig stellen.

    Beispiel Für Die Nutzung:

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

    Hier, 60 steht für die Anzahl der Sekunden zu warten, bis alle Sidekiq threads fertig sind Verarbeitung. Wenn 60 Sekunden vergehen, und alle sind nicht gemacht, Sie getötet werden, automatisch.

    Ich auch empfehlen, den Gott gem überwachen, stoppen, starten und Neustarten Sidekiq.

    Sobald Sie das tun, können Sie mit bundle exec Gott Sie stop, um alle sidekiq threads.

    Hier ist mein Gott-Datei, als Beispiel:

    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

    InformationsquelleAutor der Antwort Henley Chiu

Schreibe einen Kommentar