Sidekiq Cron

Усе і навіть більше є у wiki

Gemfile

gem 'sidekiq'
gem 'sidekiq-cron'
gem 'sidekiq-status'
gem 'sidekiq-failures'
gem 'sidekiq-scheduler'

gem 'sidekiq'

gem 'sidekiq-cron'

gem 'sidekiq-status'

gem 'sidekiq-failures'

gem 'sidekiq-scheduler'

Створюємо файл config/schedule.yml із описом черги, наприклад

export_to_segment:
  cron: "*/1 * * * *"
  class: "ExportToSegment"
  queue: export_to_segment

export_to_segment:

cron: "*/1 * * * *"

class: "ExportToSegment"

queue: export_to_segment

Описуємо чергув config/sidekiq.yml

---
:verbose: false
:concurrency: 10

# Set timeout to 8 on Heroku, longer if you manage your own systems.
:timeout: 8

# Sidekiq will run this file through ERB when reading it so you can
# even put in dynamic logic, like a host-specific queue.
# http://www.mikeperham.com/2013/11/13/advanced-sidekiq-host-specific-queues/
:queues:
  - default
  - paperclip
  - export_to_segmant

# you can override concurrency based on environment
production:
  :concurrency: 25
staging:
  :concurrency: 15

---

:verbose: false

:concurrency: 10

# Set timeout to 8 on Heroku, longer if you manage your own systems.

:timeout: 8

# Sidekiq will run this file through ERB when reading it so you can

# even put in dynamic logic, like a host-specific queue.

# http://www.mikeperham.com/2013/11/13/advanced-sidekiq-host-specific-queues/

:queues:

- default

- paperclip

- export_to_segmant

# you can override concurrency based on environment

production:

:concurrency: 25

staging:

:concurrency: 15

У воркері задаємо чергу, наприклад

class ExportToSegment
  include Sidekiq::Worker
  include Sidekiq::Status::Worker
  sidekiq_options queue: :mail
  sidekiq_options retry: false

  def perform
  ...
  end
end

class ExportToSegment

include Sidekiq::Worker

include Sidekiq::Status::Worker

sidekiq_options queue: :mail

sidekiq_options retry: false

def perform

...

end

Редагуємо config/initilalizers/sidekiq.rb до такого вигляду

require 'sidekiq'
require 'sidekiq-status'

schedule_file = 'config/schedule.yml'

if File.exists?(schedule_file) && Sidekiq.server?
  Sidekiq::Cron::Job.load_from_hash YAML.load_file(schedule_file)
end

Sidekiq.configure_client do |config|
  # accepts :expiration (optional)
  Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes
end

Sidekiq.configure_server do |config|
  # accepts :expiration (optional)
  Sidekiq::Status.configure_server_middleware config, expiration: 30.minutes

  # accepts :expiration (optional)
  Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes
end

require 'sidekiq'

require 'sidekiq-status'

schedule_file = 'config/schedule.yml'

if File.exists?(schedule_file) && Sidekiq.server?

Sidekiq::Cron::Job.load_from_hash YAML.load_file(schedule_file)

end

Sidekiq.configure_client do |config|

# accepts :expiration (optional)

Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes

end

Sidekiq.configure_server do |config|

# accepts :expiration (optional)

Sidekiq::Status.configure_server_middleware config, expiration: 30.minutes

# accepts :expiration (optional)

Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes

end

Якщо sidekiq запускається через Procfile (наприклад коли використовується Heroku) не забудьте передати назву черги(якщо задані інші), наприклад

web: bundle exec thin start -p $PORT -C config/thin.yml
worker: bundle exec sidekiq -q default -q paperclip -q export_to_segment
log: tail -f log/development.log

web: bundle exec thin start -p $PORT -C config/thin.yml

worker: bundle exec sidekiq -q default -q paperclip -q export_to_segment

log: tail -f log/development.log

Веб-Розробка

WebDevelop

Sidekiq Cron