-
Notifications
You must be signed in to change notification settings - Fork 124
Using Sidekiq with Hyrax
Sidekiq relies on the Redis key-value store, so Redis must be installed and running on your system in order for background workers to pick up jobs.
First we need to install Sidekiq. To do this, we'll add the gem to our Gemfile
gem 'sidekiq'
Install the gem: bundle install
ActiveJob support a series of adapters, the default being :async
. In order to configure ActiveJob to use the Sidekiq adapter, we need to update config/application.rb
in our application and insert the following to set the adapter:
class Application < Rails::Application
# ...
config.active_job.queue_adapter = :sidekiq
# ...
end
As an alternative, you may set individual environments to use different adapters. For example, to configure your development environment to use the :inline
adapter and production to use :sidekiq
(though note that the :inline
adapter will cause all background jobs to be executed in the foreground, which will greatly slow down your development instance)
config/environments/development.rb
config.active_job.queue_adapter = :inline
config/environments/production.rb
config.active_job.queue_adapter = :sidekiq
Hyrax uses a specific queue for handling ingest work. In many of the job classes in app/jobs
you will see the queue declaration as:
class CreateWorkJob < ActiveJob::Base
queue_as CurationConcerns.config.ingest_queue_name
CurationConcerns.config.ingest_queue_name
will default to :default
unless otherwise specified. If you want to change the queue name for ingest, you can set the queue name to the value of your choice in config/initializers/curation_concerns.rb
by uncommenting the following line and setting to your choice:
# ActiveJob queue to handle ingest-like jobs
config.ingest_queue_name = :ingest
Sidekiq allows you to manage queues and their priorities using a YAML configuration file.
Create one in your app as: config/sidekiq.yml
The YAML file supplies a list of queues and their priorities. There are also advanced options that you can explore further to customize for the needs of your application. Your initial file may look like the following:
---
:queues:
- default
- ingest
By default Sidekiq will look for Redis on the localhost system at port 6379
. This will 'just work' in a development context if Redis is already running. However, you will likely want to configure Sidekiq to look for Redis in different locations depending on the environment. To do so, you will need a Redis configuration file, and a Sidekiq configuration file. Sidekiq's Redis guide can be referenced for further detail.
-
Create
config/redis.yml
-- Populate it with the Redis information for each environment. Here is a sample which assumesREDIS_HOST
andREDIS_PORT
will be available to the application environment, and has localhost fallbacks for development and test environments:development: host: <%= ENV.fetch('REDIS_HOST', localhost) %> port: <%= ENV.fetch('REDIS_PORT', 6379) %> test: host: <%= ENV.fetch('REDIS_HOST', localhost) %> port: <%= ENV.fetch('REDIS_PORT', 6379) %> production: host: <%= ENV.fetch('REDIS_HOST') %> port: <%= ENV.fetch('REDIS_PORT') %>
-
Create
config/initializers/sidekiq.rb
-- Populate with references to yourconfig/redis.yml
file we just made.config = YAML.load(ERB.new(IO.read(Rails.root + 'config' + 'redis.yml')).result)[Rails.env].with_indifferent_access redis_conn = { url: "redis://#{config[:host]}:#{config[:port]}/" } Sidekiq.configure_server do |s| s.redis = redis_conn end Sidekiq.configure_client do |s| s.redis = redis_conn end
Sidekiq comes with a built-in web application that you can mount to monitor the state of your message queue. To setup this application, first mount the application in config/routes.rb
:
require 'sidekiq/web'
mount Sidekiq::Web => '/sidekiq'
For production applications you will likely want to secure access to this queue interface. There are various ways to do this depending on the scope of your application. Please see the authentication section of the Sidekiq wiki for options. Since Hyrax uses Devise, the examples given will be available for you to integrate.
The most direct way to start Sidekiq is by opening a separate terminal window or tab, ensuring that you are in your project directory, and starting the service (note that this may require bundle exec
depending on how you use Ruby):
sidekiq
or if you did as minimal setup as possible, you may need
sidekiq -q ingest -q default -q event
For production applications, there are a few ways to deploy and manage sidekiq. If you are using Capistrano, you can consider the following options:
Please see the Sidekiq wiki troubleshooting page which covers a wide variety of tips and solutions for issues that might arise. Beyond that, there is the Sidekiq Google Group, the Hydra Tech Google Group as well as the Hydra #dev Slack channel.