2

我正在尝试了解如何使用发条执行自定义代码。这是lib/clock.rbHeroku 在其 devcenter 文档中使用的示例文件。

require File.expand_path('../../config/boot',        __FILE__)
require File.expand_path('../../config/environment', __FILE__)
require 'clockwork'

include Clockwork

every(4.minutes, 'Queueing interval job') { Delayed::Job.enqueue IntervalJob.new }
every(1.day, 'Queueing scheduled job', :at => '14:17') { Delayed::Job.enqueue ScheduledJob.new }

什么是 IntervalJob 和 ScheduledJob？这些文件应该放在哪里？我想运行我自己的可以访问我的数据库记录的自定义作业。

编辑

这是我的/lib/clock.rb

require 'clockwork'
require './config/boot'
require './config/environment'

module Clockwork

  handler do |job|
    puts "Running #{job}"
  end

  every(2.minutes, 'Filtering Streams') { Delayed::Job.enqueue FilterJob.new}
end

这是我的/lib/filter_job.rb

  class FilterJob
    def perform
      @streams = Stream.all

      @streams.each do |stream|
      # manipulating stream properties
      end
    end
   end

我得到错误：

uninitialized constant Clockwork::FilterJob (NameError)
/app/lib/clock.rb:11:in `block in <module:Clockwork>'
4

2 回答 2

5

您需要执行以下操作：

首先安装发条宝石。

在您的 lib 文件夹中创建一个 clock.rb

require 'clockwork'
require './config/boot'
require './config/environment'

module Clockwork

  handler do |job|
    puts "Running #{job}"
  end

  every(1.day, 'Creating Cycle', :at => '22:00') { Delayed::Job.enqueue CyclePlannerJob.new}
end

在示例中，您提供的 IntervalJob 和 ScheduledJob 是延迟作业。发条在指定的时间触发它们。我正在调用 CyclePlannerJob，这就是我的文件的样子。lib/cycle_planner_job.rb

class CyclePlannerJob
  def perform
    CyclePlanner.all.each do |planner|
      if Time.now.in_time_zone("Eastern Time (US & Canada)").to_date.send("#{planner.start_day.downcase}?")
        planner.create_cycle
      end
    end
  end
end

在我的示例中，每天晚上 10 点，我正在运行 CyclePlanner 作业，该作业运行我设置的延迟作业。类似于 Heroku 示例。请记住，要使用它，您需要在仪表板中的 Heroku 应用程序上设置时钟工作和延迟工作。你的 Procfile 也应该是这样的。

worker:  bundle exec rake jobs:work
clock: bundle exec clockwork lib/clock.rb

如果您有任何问题，请告诉我，如果需要，我可以更详细地介绍。

于 2014-07-19T14:46:57.397 回答
1

看起来像名称空间问题。将您的 filter_job.rb 移动到模型目录并尝试。

于 2014-08-01T14:01:27.780 回答