Rails 帮助从 rake 文件创建delayed_job

Question

如何从 rake 文件创建延迟作业。我应该如何将其移动到控制器中并创建一个每隔 15 分钟运行一次任务的elasto_job。

以下是我的 rake 文件的示例：

namespace :reklamer do

    task :runall => [:iqmedier, :euroads, :mikkelsen] do
      # This will run after all those tasks have run
    end

      task :iqmedier => :environment do
              require 'Mechanize'
              agent = WWW::Mechanize.new
              agent.get("http://www.iqmedier.dk")
      end
      task :euroads => :environment do
            require 'Mechanize'
            require 'pp'
            agent = Mechanize.new { |agent|
      end

      task :mikkelsen => :environment do
            require 'Mechanize'
            agent = Mechanize.new
            agent.get("http://affilate.mikkelsenmedia.dk/partnersystem/mylogins.php")
       end
    end

我应该将什么更改为延迟作业（https://github.com/collectiveidea/delayed_job）？

Answer 1

DelayedJob 本身不会对您有帮助，因为它是基于一次性工作的。您仍然需要定期运行的东西来创造这些工作。

假设：

1. 你在 Heroku 上并且只能获得 1 小时的 cron，
2. 你需要每 15 分钟运行一次作业

你可以做这样的事情......

为你的作业创建一个类：

class MechanizeJob < Struct.new(:url)
  def perform
    agent = Mechanize.new
    agent.get(url)
  end
end

从你的 Rakefile 安排作业：

task :schedulejobs => :environment do
  urls = ["http://...", "http://...", "http://..."]
  urls.each do |url|
    # 1 is the job priority
    Delayed::Job.enqueue MechanizeJob.new(url), 1, Time.now
    Delayed::Job.enqueue MechanizeJob.new(url), 1, 15.minutes.from_now
    Delayed::Job.enqueue MechanizeJob.new(url), 1, 30.minutes.from_now
    Delayed::Job.enqueue MechanizeJob.new(url), 1, 45.minutes.from_now
  end
end

这将每 15 分钟针对每个 url 运行一个作业。

Answer 2

建议您看一下 SimpleWorker，这是一个用于 Ruby 应用程序的基于云的后台处理/工作队列。它专为卸载任务、运行计划作业以及横向扩展以同时处理许多并行作业而设计。它简单、经济且可扩展。

（披露，我为公司工作。）

您创建您的工作人员（在应用程序/工作人员中），然后在您的控制器和其他地方将它们排队以立即运行或安排它们稍后运行或定期运行，只需几行代码。这是一个基本示例。

  worker = ReportWorker.new
  worker.user_id = @current_user.id
  worker.schedule(:start_at => 1.hours.since, :run_every => 900)

  #Or to run once right away
  #worker.queue

ReportWorker 类将包含为当前用户创建报告并根据需要发送或发布报告的逻辑。