0

resque と clockwork を一緒に使用してテストする簡単なタスクを実行しようとしています。

私のワーカー: 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='*'

1つのターミナルで

bundle exec clockwork lib/clock.rb

2番目の端末で動作します！これが役立つことを願っています。

于 2014-08-05T19:31:32.370 に答える