如何在Resque中重新运行Redis内错过执行的排队任务？

核心结论 #

可以通过修改Redis中调度任务的时间戳让Resque重新触发这些任务，但首先要解决「通过job_id定位任务存储位置」的问题——这是你当前的核心卡点。

1. 定位任务在Redis中的存储位置 #

Resque-Scheduler的延迟任务不会直接用job_id作为Redis键，而是存在以下两种类型的有序集合中：

• 全局延迟队列：前缀为resque:delayed:的有序集合（比如resque:delayed:1699999999这种按时间分片的键）
• 队列专属延迟队列：如果指定了队列，键格式为resque:delayed:queue:[你的队列名]:[时间分片]

用以下Redis命令排查：

1. 列出所有相关键：

   redis-cli KEYS "resque:delayed:*"
   

2. 遍历每个键，查看其中的任务数据和对应时间戳（score字段就是任务的执行Unix时间戳）：

   redis-cli ZRANGE [键名] 0 -1 WITHSCORES
   

3. 每个任务是JSON字符串，里面包含job_id字段，匹配你手里的job_id就能找到目标任务。

2. 修改时间戳重新触发任务 #

找到目标任务所在的有序集合键和对应的JSON字符串后，执行以下操作：

1. 删除旧的任务条目：

   redis-cli ZREM [有序集合键] "[任务JSON字符串]"
   

2. 用当前或近未来的Unix时间戳重新添加任务：

   redis-cli ZADD [有序集合键] $(date +%s) "[任务JSON字符串]"
   

   注：新时间戳必须≤当前时间，Resque-Scheduler会自动拾取并执行时间戳到期的任务。

3. 备选：直接重新入队（如果找不到原任务） #

如果实在定位不到Redis中的任务数据，可通过Resque API重新触发：

# 在Rails控制台或Ruby环境中执行
# 先找到任务（需指定队列名）
job = Resque::Job.find("your_queue_name", "your_job_id")
# 重新入队
job.enqueue if job

如果是调度任务，也可以直接重新调度：

Resque.enqueue_at(Time.now, YourJobClass, *job_args)

这种方式需要你能获取任务的类名和参数。

注意事项 #

• 修改Redis数据前必须备份，避免误操作导致任务丢失
• 不同版本的Resque/Resque-Scheduler可能有键结构差异，需结合实际版本调整
• 修改完成后，建议重启Resque-Scheduler进程，确保它能识别到更新后的任务

内容的提问来源于stack exchange，提问作者Mohammad Arif