如何清除卡住/过时的 Resque 工作人员？

Question

正如您从附图中看到的，我有几个工人似乎被困住了。这些过程不应超过几秒钟。

我不确定为什么它们无法清除或如何手动删除它们。

我在 Heroku 上使用 Resque 与 Redis-to-Go 和 HireFire 来自动扩展工作人员。

Answer 1

这些解决方案都不适合我，我仍然会在 redis-web 中看到这个：

0 out of 10 Workers Working

最后，这对我清除所有工作人员有用：

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

Answer 2

在你的控制台中：

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

否则你可以尝试假装它们已完成删除它们，方法是：

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

编辑

很多人都赞成这个答案，我觉得人们尝试 hagope 的解决方案注销很重要工作人员离开队列，而上面的代码删除队列。如果你乐意伪造它们，那就酷了。

Answer 3

您可能已经安装了 resque gem，因此您可以打开控制台并获取当前的工作人员

Resque.workers

它返回工作人员列表，

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

选择工作人员和 prune_dead_workers ，例如第一个

Resque.workers.first.prune_dead_workers

Answer 4

添加到 hagope 的回答中，我希望能够只注销已经运行一定时间的工作人员。下面的代码只会注销运行时间超过 300 秒（5 分钟）的工作人员。

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

我正在收集与 Resque 相关的 Rake 任务，并将其添加到： https://gist.github.com/ewherrmann/ 8809350

Answer 5

无论您在何处运行启动服务器的命令，都可以运行此命令，

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

您应该会看到如下内容：

92102 resque: Processing ProcessNumbers since 1253142769

记下我示例中的 PID（进程 ID），它是 92102

然后您可以退出进程 1 of 2方式。

• 优雅地使用QUIT 92102

• 强制使用TERM 92102

* 我不确定它的语法是 QUIT 92102 或QUIT -92102

如果您遇到任何问题，请告诉我。

Answer 6

我刚刚做了：

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

得到了工人名单。

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

...其中 n 是不需要的工人的从零开始的索引。

Answer 7

我遇到了类似的问题，Redis 将数据库保存到包含无效（未运行）工作线程的磁盘。每次启动 Redis/resque 时，它​​们都会出现。

使用以下方法修复此问题：

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

确保重新启动 Redis 和 Resque 工作线程。

Answer 8

最近开始从事 https://github.com/shaiguitar/resque_stuck_queue/ 工作。这不是解决如何修复卡住的工作人员的解决方案，但它解决了 resque 挂起/被卡住的问题，所以我认为这对这个线程上的人可能会有所帮助。来自自述文件：

“如果 resque 在特定时间范围内没有运行作业，它将触发您选择的预定义处理程序。您可以使用它来发送电子邮件、寻呼机任务、添加更多 resque 工作人员、重新启动 resque、向您发送txt...任何适合你的。”

已在生产中使用，到目前为止对我来说效果很好。

Answer 9

以下是如何通过主机名从 Redis 中清除它们。当我停用服务器并且工作人员无法正常退出时，就会发生这种情况。

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

Answer 10

我遇到了这个问题，并开始实施这里的许多建议。但是，我发现造成此问题的根本原因是我 使用 gem redis-rb 3.3.0。降级到 redis-rb 3.2.2 从一开始就防止了这些工作人员陷入困境。

Answer 11

我直接从 redis-cli 中清除了它们。幸运的是 redistogo.com 允许从 heroku 之外的环境进行访问。
从列表中获取死亡工人 ID。我的是

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

直接在redis中运行这个命令。

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

您可以监视 redis 数据库以查看它在幕后执行的操作。

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"

倒数第二行删除该工作人员。

Answer 12

在 resque 2.0.0 中，这是一种似乎的方法，可以仅删除 resque 2.0.0 中实际上已死亡的工人：

Resque::Worker.all_workers_with_expired_heartbeats.each { |w| w.unregister_worker }

我不是正在发生的事情的专家，可能有更好的方法这样做或者那样做就会有问题。我也只是想弄清楚这个问题。

这似乎从 resque 工作人员列表中删除了比预期时间长得多的时间没有发送“心跳”的工作人员。

如果幻影工作处于“运行”状态，则将在“失败”作业队列中创建与幻影作业相对应的新条目。

Answer 13

我这里也有卡住/陈旧的 resque 工作人员，或者我应该说“工作”，因为工作人员实际上仍然在那里并且运行良好，这是卡住的分叉进程。

我选择了残酷的解决方案，即通过 bash 脚本终止分叉进程“处理”超过 5 分钟，然后工作进程只是在队列中生成下一个进程，一切都会继续进行，

请查看我的脚本：https://gist.github.com/jobwat/5712437

Answer 14

如果您使用的是较新版本的 Resque，则需要使用以下命令，因为内部 API 已更改...

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

Answer 15

只要您有比 1.26.0 更新的 resque 版本，这就可以避免该问题：

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

请记住，它不会让当前正在运行的作业完成。

Answer 16

如果你使用Docker，也可以使用这个命令：

是worker id。

docker stop <id>

docker start <id>