4

我需要执行一项工作，其中每次创建订单时都会将其分配给供应商，如果供应商不接受订单并在指定时间内更新状态，订单将自动拒绝，状态更新为拒绝。我面临的问题是，该作业进入延迟队列，如 resque Web 视图中所示，但在指定的延迟时间后没有移动到主队列延迟失效

这是我的工作。

  class AutoRejectionJob < ActiveJob::Base
    queue_as :auto_rejection_queue

   def perform(*args) 
    assignment_id = args[0]
    order_assignment = Estamps::Assignment.find(assignment_id)
    if order_assignment.status_id == 1 || order_assignment.status_id == nil
      order_assignment.status_id = 3
      order_assignment.save!
    end
   end
  end

在我的分配模型中：

class Estamps::Assignment < ActiveRecord::Base
 after_create :enqueue_check_status 

def enqueue_check_status #  
  AutoRejectionJob.set(wait: 2.minutes).perform_later(self.id)
end    
end

在这里，一旦创建了分配记录，状态通常在创建时保持为“已分配”。现在从创建之日起，如果用户在指定时间内没有更新状态，则作业必须自动将状态更新为“已拒绝”。

我也试过这个方法。

def enqueue_check_status 
  Resque.enqueue_at_with_queue('auto_rejection_queue', 2.minutes.from_now, 
   AutoRejectionJob, assignment_id: self.id)  
end

他们都将作业发送到 resque 延迟队列，但不将作业或将作业带到主队列执行。

自动拒绝作业在延迟作业列表中排队

此外，当我单击延迟作业的所有计划链接时，作业的时间戳显示没有列出要安排的作业

延迟列表中第一个作业的所有计划

我被这个问题困扰了将近两个星期。请帮忙！如果需要更多信息，请告诉我。与这个有一段艰难的时光。

4

1 回答 1

3

我已经解决了这个问题。

基本上让工人运行本身不足以处理延迟的工作。您必须运行一个特殊的 rake 任务：

$ PIDFILE=./resque-scheduler.pid BACKGROUND=yes \
    rake resque:scheduler

resque:scheduler rake 任务检查计划的作业和延迟的作业（默认每 5 秒）并将它们移动到您的工作人员处理。您可以在官方resque-scheduler gem 自述文件中阅读有关如何配置和设置 resque:scheduler rake 任务及其设置的更多信息。

就我而言，我使用capistrano-resque gem来部署和管理工作人员（当 capistrano 部署新版本时重新启动它们），方法是在 deploy.rb 文件中添加以下行：

after "deploy:restart", "resque:restart"

虽然这会加载我的工作人员（并按应有的方式重新启动它们），但您需要添加附加行（到 deploy.rb）：

after 'passenger:restart', 'resque:scheduler:restart'

让 capistrano 为您运行 resque:scheduler 任务。

在我这样做之后，一切都工作得非常完美（并且实际上追溯加载了应该已经处理但尚未处理的延迟作业）。

然而，如前所述，如果您确实遇到问题，请确保您的 rake resque:scheduler 任务可以访问环境变量 - 否则它将无法工作。

于 2017-08-09T01:25:18.960 回答