
先日の記事でもちょろっと紹介しましたが、RSSリーダーを開発した際にフィード更新ジョブを定期的に発行するためにclockworkというgemを使用しました。
RSSリーダーの記事更新のバックグラウンドジョブ概要 - ぴよログ
単独で使う
まずはRuby単独で使う方法です。ローカルマシンで定期的にスクリプトを動かしたいときなどに使えます(そんなときあるか!?)。
まずgemを導入します。普通にgem installでいけます。
1$ gem install clockwork
次にコンフィグファイル的なものを書きます。例えばclock.rbというような名前で作るとします。
1require 'clockwork'
2
3module Clockwork
4
5 def one_minute
6 p "minutely job"
7 end
8
9 def one_hour
10 p "hourly job"
11 end
12
13
14 handler do |job|
15 self.send(job.to_sym)
16 end
17
18 every(1.minute, 'one_minute')
19 every(1.hour, 'one_hour')
20end
最後の2行で1分ごとのジョブと1時間ごとのジョブを設定しています。そしてhandlerに処理記述します。この例ではジョブ名と同じメソッドを定義しておいて、sendによってそちらを呼ぶようにしています。
フォアグラウンド実行
フォアグラウンド実行を行うときは次のように実行します。
1
2$ clockwork clock.rb
3I, [2014-02-16T11:11:17.128897 #97926] INFO -- : Starting clock for 2 events: [ one_minute one_hour ]
4I, [2014-02-16T11:11:17.129034 #97926] INFO -- : Triggering 'one_minute'
5"minutely job"
6I, [2014-02-16T11:11:17.129107 #97926] INFO -- : Triggering 'one_hour'
7"hourly job"
8I, [2014-02-16T11:12:17.182378 #97926] INFO -- : Triggering 'one_minute'
9"minutely job"
10I, [2014-02-16T11:13:17.231925 #97926] INFO -- : Triggering 'one_minute'
11"minutely job"
実行すると同時に1時間毎のジョブと1分ごとのジョブが実行され、それ以降は指定した間隔でジョブが動いていきます。
atオプションを使うことでcronのように◯時XX分に実行する、というような指定も可能です。
1
2every(1.hour, 'hourly', :at => '**:30')
バックグラウンド実行(デーモン)
定期実行という機能の特性を考えるとバックグラウンドで実行したいケースがほとんどだと思います。そのためにはclockworkと一緒についてくるclockworkdを使います。
1$ clockworkd -c clock.rb start --log
-cはコンフィグファイルを指定というようなニュアンスだと思われます。clock.rbファイルを指定してstartすればバックグラウンドで起動します。--logオプションを付けることにより、フォアグラウンド実行のとき標準出力されていたログがファイルに出るようになります。
Railsと使う
アプリケーションと一緒に使うことでより実用的になります。Railsの場合はclockworkをrequireしたあとでRailsの環境をrequireすることでRailsのコードを使えるようになります。
Railsの環境を読み込むにはconfig/bootとconfig/environmentをrequireします。requireする際のパスに注意して書く必要があるのですが、clockworkのコンフィグファイルがbootなどと同じくconfigにある場合は、
1
2require File.expand_path('../boot', __FILE__)
3require File.expand_path('../environment', __FILE__)
などと書きます。
これをやっておくことでRailsのモデルなどにアクセスできるようになって、より実用的な使い方をできるようになりますね。
1
2require 'clockwork'
3
4require File.expand_path('../boot', __FILE__)
5require File.expand_path('../environment', __FILE__)
6
7module Clockwork
8
9 handler do |job|
10 p "#{job}: user count => #{User.count}"
11 end
12
13 every(1.minute, 'minute')
14end