ruby-on-rails - 任何示例如何在 rails 中使用延迟作业进行大规模更新

Question

试图了解 Rails 中的 delay_job，我想更新我画廊中已经过期的所有 PIN

class UpdatePinJob < ApplicationJob
 queue_as :default

 def perform(gallery)
   gallery.where('DATE(expired_pin) > ?', Date.today).update_all('pin = ?', 'new_pin_here')
 end

end

这是使用这份工作的正确方法吗？以及如何在我的 Controller 中调用它？
我希望我的问题是有道理的，为什么我在这种情况下使用队列，因为我在想如果我的画廊有数千个，并且我想更新所有内容，那我想使用 delay_job 可能有助于扩展它:)
如果我的问题有问题对不起，我在这里试图理解

Answer 1

你走在正确的 rails 上。我建议按照此处的说明进行操作:ActiveJobsBasics

要在您的 Controller 中调用它，您应该这样做:

# Enqueue a job to be performed as soon as the queuing system is free.
UpdatePinJob.perform_later(gallery)
# Enqueue a job to be performed 1 week from now.
UpdatePinJob.set(wait: 1.week).perform_later(gallery)

您应该注意的一件重要事情是实际执行作业。根据 ActiveJob:

For enqueuing and executing jobs in production you need to set up a queuing backend, that is to say you need to decide for a 3rd-party queuing library that Rails should use. Rails itself only provides an in-process queuing system, which only keeps the jobs in RAM. If the process crashes or the machine is reset, then all outstanding jobs are lost with the default async backend. This may be fine for smaller apps or non-critical jobs, but most production apps will need to pick a persistent backend.

我会和 Sidekiq一起去

不要忘记这样做:

# config/application.rb
module YourApp
  class Application < Rails::Application
    ...
    config.active_job.queue_adapter = :sidekiq
    ...
  end
end

编辑:如果您对如何安排感兴趣，这取决于您使用的技术。
如果您使用 Heroku 进行部署，则可以使用 Heroku Scheduler .如果您在 Digital Ocean 中进行部署，则可以使用 Cron Jobs。