Ruby on Rails Sidekiq:如何改变一个预定的作业开始时间？

Question

我最近开始使用Sidekiq，并注意到它有一个很棒的功能，我一直在寻找很长时间：

UserMailer.delay_until(5.days.from_now).find_more_friends_email

基本上，我可以在将来安排一项工作，这样我就不需要我的应用程序连续轮询有开始时间的新事件。

这很有魅力，但我该如何改变工作的开始时间呢？通常，一些预定的活动的开始时间会发生变化。我如何在sidekiq中复制这个？

我知道我可以删除作业并创建新作业，但是否可以只修改开始时间？

编辑：

我基于Oto Brglez的想法构建，以下是记录的代码：

module TaskStuff
  class TaskSetter
    include Sidekiq::Worker
    sidekiq_options retry: false

    def perform(task_id)
      task = Task.find(task_id)
      # Get the worker that's performing this job
      if worker = AppHelpers.find_worker(jid)
        # If the worker matches the "at" timestamp then this is the right one and we should execute it
        if worker.last["payload"]["at"].to_s.match(/(\d*\.\d{0,3})\d*/)[1] == task.start.to_f.to_s.match(/(\d*\.\d{0,3})\d*/)[1]
          task.execute
        else
          custom_logger.debug("This worker is the wrong one. Skipping...")
        end
      else
        custom_logger.error("We couldn't find the worker")
      end
    end
  end
end


module AppHelpers

  [...]

  def self.find_worker(jid)
    Sidekiq::Workers.new.select {|e| e.last["payload"]["jid"] == jid}.first
  end

  [...]

end

> task = Task.create(start: 5.hours.from_now)
> TaskStuff::TastSetter.perform_at(task.start, task.id)

现在如果我这么做

> task.update_attributes(start: 4.hours.from_now)
> TaskStuff::TastSetter.perform_at(task.start, task.id)

该任务将在4小时内执行，另一个作业（将在5小时内执行）将在到达时间时被忽略并删除。

最初，我尝试使用< code>Time.now而不是< code > worker . last[" payload "][" at "]，但这可能非常不准确，因为计划的作业不会总是按时执行。有一个15秒的检查间隔，如果所有的工人都在其他地方忙碌，工作可能会进一步延迟。

我必须使用Regexp来匹配开始时间，因为在读取task.start时，我可能会得到一个具有不同小数位数的浮点数，并且if条件不会通过。这样，我将两个值都设置为3十进制。

我发现获得作业的“at”属性的唯一方法是通过工人获得它。如果我询问Redis或使用Mike的< code > Sidekiq::scheduled set . new ,我将不会得到当前的作业，因为它已经从Redis中取出。

编辑2：

对于任何感兴趣的人，我采用了类似但不同的方法。基本上，我没有比较Task的开始时间，而是在模型和Sidekiq调用中添加了一个额外的字段，称为start_token。如果使用与对象相同的令牌调用了Sidekiq作业，那么它是有效的，否则丢弃并跳过该作业。每次模型更改start_time时，令牌都会更新。

Answer 1

您还可以使用job.reschedule（）方法做一件事，另一种方法是删除您的第一个计划作业，然后用新时间再次添加。

代码:

  bugs = @user.bugs
  queue = Sidekiq::ScheduledSet.new
  queue.each do |job|
    job.delete if bugs.ids.include? job.args.first
  end

这将删除所有匹配用户错误id的作业

Answer 2

我不认为编辑/更新工作是一种方式。每次事情发生变化时，我通常都会创造一份新工作。然后在作业本身中检查执行特定任务的时间是否正确…如果时间正确，继续执行任务，否则只需跳过。。。

Answer 3

这可能没有回答这个问题，但这个问题首先在谷歌上出现，因为“sidkiq增加已安排工作的时间”。

Sidekiq 在 SortedEntry 作业上有此方法（重新调度）。

找到工作：

job = Sidekiq::ScheduledSet.new.find_job(job_id)

重新安排工作：

job.reschedule(Time.now + 2.hours)