ruby sidekiq-scheduler を試す
概要
Sidekiq のキューイングを cron のように定期的に実行できるのが sidekiq-scheduler です
今回はインストールから簡単な動作確認までやってみました
環境
- macOS 13.4
- redis 7.0.11
- Ruby 3.2.2
- sidekiq-scheculer 5.0.3
インストール
gem 'sidekiq-scheduler'
- bundle config path vendor
- bundle install
サンプルコード (ワーカー)
エンキューはスケジューラが実行するため必要なのはワーカーになります
ワーカーは普通の sidekiq のように perform を実装するだけです
require 'sidekiq-scheduler'
class HelloWorld
include Sidekiq::Worker
def perform
puts 'Hello world'
end
end
スケジュール設定 (yaml ファイル)
この設定ファイルを元にスケジューラがエンキューします
sidekiq-scheduler の cron 設定は秒単位まで指定できます
:scheduler:
:schedule:
hello_world:
cron: '0 * * * * *'
class: HelloWorld
スケジューラ起動
あとはワーカーとともにスケジューラを起動するだけです
- bundle exec sidekiq -r ./worker.rb
動作確認
ワーカーのログに毎分 0 秒のときに以下のようなログが出力されれば OK です
2023-06-12T01:28:09.357Z pid=87946 tid=1x4e INFO: Running in ruby 3.2.2 (2023-03-30 revision e51014f9c0) [arm64-darwin22]
2023-06-12T01:28:09.357Z pid=87946 tid=1x4e INFO: See LICENSE and the LGPL-3.0 for licensing details.
2023-06-12T01:28:09.357Z pid=87946 tid=1x4e INFO: Upgrade to Sidekiq Pro for more features and support: https://sidekiq.org
2023-06-12T01:28:09.357Z pid=87946 tid=1x4e INFO: Sidekiq 7.1.1 connecting to Redis with options {:size=>10, :pool_name=>"internal", :url=>nil}
2023-06-12T01:28:09.359Z pid=87946 tid=1x4e INFO: Sidekiq 7.1.1 connecting to Redis with options {:size=>5, :pool_name=>"default", :url=>nil}
2023-06-12T01:28:09.360Z pid=87946 tid=1x4e INFO: Loading Schedule
2023-06-12T01:28:09.360Z pid=87946 tid=1x4e INFO: Scheduling hello_world {"cron"=>"0 * * * * *", "class"=>"HelloWorld", "queue"=>"default"}
2023-06-12T01:28:09.527Z pid=87946 tid=1x4e INFO: Schedules Loaded
2023-06-12T01:28:09.527Z pid=87946 tid=1x4e INFO: Starting processing, hit Ctrl-C to stop
2023-06-12T01:29:00.036Z pid=87946 tid=1wwa INFO: queueing HelloWorld (hello_world)
2023-06-12T01:29:00.037Z pid=87946 tid=1wwu class=HelloWorld jid=a2522a3f2f3de9a7c706f1f9 INFO: start
Hello world
2023-06-12T01:29:00.038Z pid=87946 tid=1wwu class=HelloWorld jid=a2522a3f2f3de9a7c706f1f9 elapsed=0.001 INFO: done
ちょっと応用: スケジューラの登録を動的に行う
yaml ファイルでスケジュールを管理するのは大変なので ruby から動的に登録することも可能です
require 'sidekiq-scheduler'
Sidekiq.set_schedule('hello', { 'every' => ['1m'], 'class' => 'HelloWorld' })
これを起動することでスケジューラを登録できます
- bundle exec ruby job_create.rb
redis を確認するとスケジューラが登録されています
redis-cli keys '*'
1) "schedules_changed"
2) "schedules"
redis-cli hgetall 'schedules'
1) "hello"
2) "{\"every\":[\"1m\"],\"class\":\"HelloWorker\"}"
また設定ファイルでは dynamic というオプションを true にします
:scheduler:
:dynamic: true
あとはワーカーを起動して毎分実行されることを確認しましょう
- bundle exec sidekiq -r ./worker.rb
ワーカーがスケジューラを認識しない場合はサイド job_create.rb を実行してみてください
同一スケジューラ名の場合は新規で追加はせずスケジューラが更新されるだけになります
またスケジューラの変更はワーカーは動的に行ってくれます
最後に
とりあえず動かすところまでやってみました
スケジュールの設定が yaml ファイルなのが特徴的なところかなと思います
また秒単位まで指定できるので細かい時間指定も可能かなと思います
参考サイト
https://github.com/sidekiq-scheduler/sidekiq-scheduler
