0

我正在尝试运行一个简单的任务来测试同时使用 resque 和发条。

我的工人：app/workers/logger_helper.rb

class LoggerHelper
  @queue = :log_queue

  def self.before_perform
    Rails.logger = Logger.new(File.open(Rails.root.join('log', 'resque.log')))
    Rails.logger.level = Logger::DEBUG
  end

  def self.perform
    time = Time.now
    Rails.logger.info("testing #{time}")
  end
end

我的clock.rb文件 lib/clock.rb

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

  module Clockwork

  handler do |job|
    Resque.enqueue(job)
  end

  every(10.seconds, 'loggerhelper') {LoggerHelper}
end

耙文件：

require File.expand_path('../config/application', __FILE__)
Rails.application.load_tasks
require 'resque/tasks'
task(:default).clear
task default: [:spec]

task "resque:setup" => :environment do
  QUEUE = '*'
end

首先我运行 resque:setup 其次我运行clockwork lib/clockwork.rb

我在终端中得到以下输出

INFO -- : Triggering 'loggerhelper'
INFO -- : Triggering 'loggerhelper'
...

但是没有任何东西写入日志。

我尝试了多种方法，但没有看到任何输出。

我确实跑了

every(10.seconds, 'loggerhelper') {LoggerHelper.perform}

在clock.rb 文件中它确实有效，但我认为您不应该直接调用deliver。此外，我不确定它是真的从队列中跑出来还是只是简单地执行。

4

1 回答 1

0

首先应该将记录器配置为：

Rails.logger = Logger.new(Rails.root.join('log', 'rescue.log'))

我还简化了我的 clock.rb 文件，尽管我认为它可以像原来一样工作：

require File.expand_path('../../config/boot',        __FILE__)
require File.expand_path('../../config/environment', __FILE__)
require 'clockwork'
module Clockwork
  every(5.seconds, 'Running Logger Helper') {Resque.enqueue(LoggerHelper)}

end

接下来，我使用以下内容创建了一个 Proc 文件：

web: bundle exec unicorn -p $PORT -c ./config/unicorn.rb
resque-web: bundle exec resque-web --foreground
resque: env TERM_CHILD=1 bundle exec rake resque:work QUEUE='*'
clock: bundle exec clockwork lib/clock.rb

如果我跑

 env TERM_CHILD=1 bundle exec rake resque:work QUEUE='*'

在一个终端，然后

bundle exec clockwork lib/clock.rb

在第二个终端它工作！我希望这会有所帮助。

于 2014-08-05T19:31:32.370 回答