Jak usunąć zablokowanych / czerstwych pracowników Resque?

W konsoli:

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

W przeciwnym razie możesz spróbować sfałszować je jako zrobione, aby je usunąć, z:

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

EDIT

Wiele osób głosowało za tą odpowiedzią i uważam, że ważne jest, aby ludzie spróbowali rozwiązania hagope, które usuwa pracowników z kolejki, podczas gdy powyższy kod usuwa kolejki. Jeśli chętnie je podrabiasz, to spoko.

Prawdopodobnie masz zainstalowany Resque gem, więc możesz otworzyć konsolę i pobrać aktualnych pracowników

Resque.workers

Zwraca listę pracowników

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

Wybierz pracownika i prune_dead_workers, na przykład pierwszy

Resque.workers.first.prune_dead_workers

Dodając do odpowiedzi hagope, chciałem być w stanie tylko wyrejestrować pracowników, którzy pracowali przez pewien czas. Poniższy kod spowoduje wyrejestrowanie tylko pracowników pracujących przez ponad 300 sekund (5 minut).

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

Mam na bieżąco zbiór zadań związanych z Resque, do których również dodałem to: https://gist.github.com/ewherrmann/8809350

Uruchom to polecenie gdziekolwiek uruchomiłeś polecenie do uruchomienia serwera

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

Powinieneś zobaczyć coś takiego:

92102 resque: Processing ProcessNumbers since 1253142769

Zanotuj PID (ID procesu) w moim przykładzie jest to 92102

Następnie możesz zamknąć proces na 1 z 2 sposobów.

• Gracefully use QUIT 92102

• / align = "left" / TERM 92102

* nie jestem pewien składni to albo QUIT 92102 albo QUIT -92102

Daj znać, jeśli masz jakieś kłopoty.

Właśnie zrobiłem:

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

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

... gdzie n jest indeksem zerowym niechcianego pracownika.

MiaĹ 'em podobny problem, Ĺźe Redis zapisaĺ' DB na dysku zawierajÄ ... cym nieprawidĺ ' owe (nie pracujÄ ... ce) workery. Po każdym uruchomieniu Redis/resque pojawiali się.

Napraw to używając:

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

Oto jak można je usunąć z Redis przez nazwę hosta. Zdarza mi się to, gdy wyłączam serwer, a pracownicy nie opuszczają go z wdziękiem.

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

Natknąłem się na ten problem i zacząłem ścieżkę wdrażania wielu sugestii tutaj. Jednak odkryłem, że główną przyczyną powstania tego problemu było to, że byłem za pomocą gem redis-RB 3.3.0. Przejście na redis-rb 3.2.2 uniemożliwiło tym pracownikom utknięcie w pierwszej kolejności.

Rozpoczął pracę nad https://github.com/shaiguitar/resque_stuck_queue / Ostatnio. Nie jest to rozwiązanie, jak naprawić zablokowanych pracowników, ale rozwiązuje problem resque wiszące / utknięcie, więc pomyślałem, że może to być pomocne dla ludzi w tym wątku. Z README:

" jeśli resque nie uruchomi zadań w określonym czasie, uruchomi wstępnie zdefiniowaną obsługę wybraną przez Ciebie. Możesz użyć tego, aby wysłać e-mail, Pager obowiązek, dodać więcej pracowników resque, restart resque, wysłać Ci txt...cokolwiek ci pasuje."

Zostały wykorzystane w produkcji i działa całkiem dobrze dla mnie do tej pory.

Ja też tu utknąłem / czerstwych pracowników resque, a może powinienem powiedzieć "praca", ponieważ pracownik nadal tam jest i działa dobrze, to rozwidlony proces się utknął.

Wybrałem brutalne rozwiązanie zabijania rozwidlonego procesu "przetwarzanie", ponieważ ponad 5min, za pomocą skryptu bash, potem worker po prostu odtwarza następny w kolejce i wszystko idzie dalej

Spójrz na mój skrypt tutaj: https://gist.github.com/jobwat/5712437

Usunąłem ich z redis-cli. Na szczęście redistogo.com umożliwia dostęp ze środowisk spoza heroku. Zdobądź identyfikator martwego pracownika z listy. Mój był

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

Uruchom tę komendę bezpośrednio w redis.

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

Możesz monitorować redis db, aby zobaczyć, co robi za kulisami.

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"

Druga ostatnia linia usuwa pracownika.

Jeśli używasz nowszych wersji Resque, musisz użyć następującego polecenia, ponieważ wewnętrzne interfejsy API uległy zmianie...

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

To pozwala uniknąć problemu, o ile masz wersję resque nowszą niż 1.26.0:

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

Należy pamiętać, że nie pozwala to zakończyć aktualnie wykonywanego zadania.

Możesz również użyć poniższego polecenia, aby zatrzymać wszystkie rescue worker

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

Odniesienie z tego linku