如何销毁由 resque 工作人员排队的工作？

Question

我在 Rails-3 项目上使用 Resque 来处理计划每 5 分钟运行一次的作业。我最近做了一些事情，使这些工作岗位的创造如滚雪球般增长，目前该堆栈已达到 1000 多个工作岗位。我修复了导致许多作业排队的问题，现在我遇到的问题是由错误创建的作业仍然存在，因此测试某些内容变得很困难，因为一个作业被添加到具有 1000 多个作业的队列中。 我似乎无法停止这些工作。我尝试使用flushall命令从redis-cli中删除队列，但它不起作用。我错过了什么吗？因为我似乎找不到摆脱这些工作的方法。

Answer 1

根据上述答案，如果您需要清除所有队列，可以使用以下命令：

Resque.queues.each{|q| Resque.redis.del "queue:#{q}" }

Answer 2

如果您弹出 Rails 控制台，则可以运行以下代码来清除队列：

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

Answer 3

Resque 已经有一个方法可以做到这一点 - 尝试 Resque.remove_queue(queue_name) （请参阅文档 这里）。它在内部执行 Resque.redis.del()，但它也执行其他清理工作，并且通过使用 api 方法（而不是假设 resque 如何工作），您将更加面向未来。

Answer 4

更新了用于清理的 rake 任务（根据最新的 redis 命令更改）：https://gist.github.com/1228863

Answer 5

现在是这样的：

Resque.remove_queue("...")

Answer 6

使用 Resque API 比删除 Resque 的 Redis 上的所有内容更安全、更可靠。 Resque 在内部做了一些清洁工作。

如果要删除所有队列和关联的排队作业：

Resque.queues.each {|queue| Resque.remove_queue(queue)}

下次作业排队时将重新创建队列。

文档

Answer 7

进入redis控制台：

redis-cli

列出数据库：

127.0.0.1:6379> KEYS *
 1) "resque:schedules_changed"
 2) "resque:workers"
 3) "resque:queue:your_overloaded_queue"

“resque：queue：your_overloaded_queue” - 您需要的数据库。

然后运行：

DEL resque:queue:your_overloaded_queue

或者，如果您想删除队列中的指定作业，则使用 LRANGE 命令：

127.0.0.1:6379> LRANGE resque:queue:your_overloaded_queue 0 2
1) "{\"class\":\"AppClass\",\"args\":[]}"
2) "{\"class\":\"AppClass\",\"args\":[]}"
3) "{\"class\":\"AppClass\",\"args\":[]}"

然后将一个值复制/粘贴到 LREM 命令：

127.0.0.1:6379> LREM resque:queue:your_overloaded_queue 5 "{\"class\":\"AppClass\",\"args\":[]}"
(integer) 5

其中 5 - 数量要删除的元素。