Wie lösche ich festsitzende / abgestandene Resque-Mitarbeiter?

Wie Sie dem beigefügten Bild entnehmen können, habe ich ein paar Arbeiter, die festzustecken scheinen. Diese Prozesse sollten nicht länger als ein paar Sekunden dauern.

Ich bin nicht sicher, warum sie nicht gelöscht werden oder wie sie manuell entfernt werden können.

Ich bin auf Heroku und verwende Resque mit Redis-to-Go und HireFire, um Arbeiter automatisch zu skalieren.

Keine dieser Lösungen hat bei mir funktioniert, ich würde dies immer noch in redis-web sehen:

0 out of 10 Workers Working

Schließlich funktionierte dies für mich, um alle Arbeiter zu klären:

Resque.workers.each {|w| w.unregister_worker}

In Ihrer Konsole:

queue_name = "process_numbers"
Resque.redis.del "queue:#{queue_name}"

Andernfalls können Sie versuchen, sie zu fälschen, um sie zu entfernen, mit:

Resque::Worker.working.each {|w| w.done_working}

BEARBEITEN

Viele Leute haben diese Antwort positiv bewertet, und ich halte es für wichtig, dass die Leute die Lösung von hagope ausprobieren, mit der die Registrierung von Mitarbeitern aus einer Warteschlange aufgehoben wird, während der obige Code Warteschlangen löscht. Wenn Sie glücklich sind, sie zu fälschen, dann cool.

Wahrscheinlich haben Sie das Resque-Juwel installiert, sodass Sie die Konsole öffnen und aktuelle Mitarbeiter abrufen können

Resque.workers

Es gibt eine Liste der Arbeiter zurück

#=> [#<Worker infusion.local:40194-0:JAVA_DYNAMIC_QUEUES,index_migrator,converter,extractor>]

Wählen Sie den Arbeiter und prune_dead_workerszum Beispiel den ersten

Resque.workers.first.prune_dead_workers

Zusätzlich zur Antwort von Hagope wollte ich in der Lage sein, nur die Registrierung von Arbeitnehmern aufzuheben, die eine bestimmte Zeit lang gearbeitet hatten. Mit dem folgenden Code werden nur Mitarbeiter abgemeldet, die länger als 300 Sekunden (5 Minuten) arbeiten.

Resque.workers.each {|w| w.unregister_worker if w.processing['run_at'] && Time.now - w.processing['run_at'].to_time > 300}

Ich habe eine fortlaufende Sammlung von Rake-Aufgaben im Zusammenhang mit Resque, die ich auch hinzugefügt habe: https://gist.github.com/ewherrmann/8809350

Führen Sie diesen Befehl überall dort aus, wo Sie den Befehl zum Starten des Servers ausgeführt haben

$ ps -e -o pid,command | grep [r]esque

Sie sollten so etwas sehen:

92102 resque: Processing ProcessNumbers since 1253142769

Notieren Sie sich die PID (Prozess-ID) in meinem Beispiel 92102

Dann können Sie den Prozess auf zwei Arten beenden.

• Anmutig verwenden QUIT 92102

• Mit Gewalt verwenden TERM 92102

* Ich bin mir nicht sicher, welche Syntax es ist QUIT 92102oderQUIT -92102

Lassen Sie mich wissen, wenn Sie Probleme haben.

Ich habe gerade getan:

% rails c production
irb(main):001:0>Resque.workers

Habe die Liste der Arbeiter.

irb(main):002:0>Resque.remove_worker(Resque.workers[n].id)

... wobei n der auf Null basierende Index des unerwünschten Arbeiters ist.

Ich hatte ein ähnliches Problem, dass Redis die Datenbank auf einer Festplatte speicherte, die ungültige (nicht laufende) Worker enthielt. Jedes Mal, wenn Redis / resque gestartet wurde, erschienen sie.

Beheben Sie dies mit:

Resque::Worker.working.each {|w| w.done_working}
Resque.redis.save # Save the DB to disk without ANY workers

Stellen Sie sicher, dass Sie Redis und Ihre Resque-Mitarbeiter neu starten.

Hier erfahren Sie, wie Sie sie anhand des Hostnamens aus Redis entfernen können. Dies passiert mir, wenn ich einen Server außer Betrieb nehme und die Mitarbeiter nicht ordnungsgemäß beendet werden.

Resque.workers.each { |w| w.unregister_worker if w.id.start_with?(hostname) }

Ich bin auf dieses Problem gestoßen und habe mich auf den Weg gemacht, viele der Vorschläge hier umzusetzen. Ich entdeckte jedoch, dass die Hauptursache für dieses Problem darin bestand, dass ich den Edelstein redis-rb 3.3.0 verwendete . Ein Downgrade auf redis-rb 3.2.2 verhinderte, dass diese Arbeiter überhaupt stecken blieben.

Begann vor kurzem mit der Arbeit an https://github.com/shaiguitar/resque_stuck_queue/ . Es ist keine Lösung, um festsitzende Arbeiter zu reparieren, aber es befasst sich mit dem Problem des Aufhängens / Feststeckens von Resque. Ich dachte, es könnte für Leute in diesem Thread hilfreich sein. Aus der README:

"Wenn resque keine Jobs innerhalb eines bestimmten Zeitraums ausführt, wird ein vordefinierter Handler Ihrer Wahl ausgelöst. Sie können damit eine E-Mail senden, Pager-Aufgaben ausführen, weitere Resque-Mitarbeiter hinzufügen, resque neu starten und Ihnen einen Text senden. ..was immer dir passt."

Wurde in der Produktion verwendet und funktioniert bisher ziemlich gut für mich.

Ich hatte auch hier festgefahrene Arbeiter, oder sollte ich 'Jobs' sagen, weil der Arbeiter tatsächlich noch da ist und gut läuft, ist es der gegabelte Prozess, der feststeckt.

Ich entschied mich für die brutale Lösung, den gegabelten Prozess "Processing" seit mehr als 5 Minuten über ein Bash-Skript zu beenden, dann spawnte der Worker einfach den nächsten in der Warteschlange und alles geht weiter

Schauen Sie sich mein Skript hier an: https://gist.github.com/jobwat/5712437

Ich habe sie direkt aus Redis-Cli entfernt. Glücklicherweise ermöglicht redistogo.com den Zugriff von Umgebungen außerhalb von Heroku. Holen Sie sich die ID des toten Arbeiters aus der Liste. Meins war

55ba6f3b-9287-4f81-987a-4e8ae7f51210:2

Führen Sie diesen Befehl direkt in redis aus.

del "resque:worker:55ba6f3b-9287-4f81-987a-4e8ae7f51210:2:*"

Sie können redis db überwachen, um zu sehen, was es hinter den Kulissen tut.

redis xxx.redistogo.com> MONITOR
OK
1380274567.540613 "MONITOR"
1380274568.345198 "incrby" "resque:stat:processed" "1"
1380274568.346898 "incrby" "resque:stat:processed:c65c8e2b-555a-4a57-aaa6-477b27d6452d:2:*" "1"
1380274568.346920 "del" "resque:worker:c65c8e2b-555a-4a57-aaa6-477b27d6452d:2:*"
1380274568.348803 "smembers" "resque:queues"

Die vorletzte Zeile löscht den Arbeiter.

Wenn Sie neuere Versionen von Resque verwenden, müssen Sie den folgenden Befehl verwenden, da sich die internen APIs geändert haben ...

Resque::WorkerRegistry.working.each {|work| Resque::WorkerRegistry.remove(work.id)}

Dies vermeidet das Problem, solange Sie eine neuere Version als 1.26.0 haben:

resque: env QUEUE=foo TERM_CHILD=1 bundle exec rake resque:work

Beachten Sie, dass der aktuell ausgeführte Job nicht beendet wird.

Sie können auch den folgenden Befehl verwenden, um alle rescueWorker zu stoppen

sudo kill -9  `ps aux | grep resque | grep -v grep | cut -c 10-16`

Referenz von diesem Link