Resque (pronounced like "rescue") is a Redis-backed library for creating background jobs, placing those jobs on multiple queues, and processing them later.
This branch is the master branch, which contains work towards Resque 2.0. If you're currently using Resque, you'll want to check out the 1-x-stable branch, and particularly its README, which is more accurate for the code you're running in production.
Also, this README is written first, so lots of things in here may not work the exact way that they say they might here. Yay 2.0!
You can't always do work right away. Sometimes, you need to do it later. Resque is a really simple way to manage a pile of work that your application needs to do: 1.5 million installs can't be wrong!
To define some work, make a job. Jobs need a work
method:
class ImageConversionJob
def work
# convert some kind of image here
end
end
Next, we need to procrastinate! Let's put your job on the queue:
resque = Resque.new
resque << ImageConversionJob.new
Neat! This unit of work will be stored in Redis. We can spin up a worker to grab some work off of the queue and do the work:
bin/resque work
This process polls Redis, grabs any jobs that need to be done, and then does them. 🤘
To install Resque, add the gem to your Gemfile:
gem "resque", "~> 2.0.0.pre.1", github: "resque/resque"
Then run bundle
. If you're not using Bundler, just gem install resque
.
Resque is used by a large number of people, across a diverse set of codebases. There is no official requirement other than Ruby 1.9.3 or newer. We of course recommend Ruby 2.0.0, but test against many Rubies, as you can see from our .travis.yml.
We would love to support non-MRI Rubies, but they may have bugs. We would love some contributions to clear up failures on these Rubies, but they are set to allow failure in our CI.
We officially support Rails 2.3.x and newer, though we recommend that you're on Rails 3.2 or 4.
Resque uses SemVer, and takes it seriously. If you find an interface regression, please file an issue so that we can address it.
If you have previously used Resque 1.23, the transition to 2.0 shouldn't be too painful: we've tried to upgrade interfaces but leave semantics largely in place. Check out UPGRADING.md for detailed examples of what needs to be done.
What deserves to be a background job? Anything that's not always super fast. There are tons of stuff that an application does that falls under the 'not always fast' category:
- Warming caches
- Counting disk usage
- Building tarballs
- Firing off web hooks
- Creating events in the db and pre-caching them
- Building graphs
- Deleting users
And it's not always web stuff, either. A command-line client application that does web scraping and crawling is a great use of jobs, too.
Jobs are persisted in Redis via JSON serialization. Basically, the job looks like this:
{
"class": "Email",
"vars": {
"to": "[email protected]",
"from": "[email protected]"
}
}
When Resque fetches this job from Redis, it will do something like this:
json = fetch_json_from_redis
job = json["class"].constantize.new
json["vars"].each {|k, v| job.instance_variable_set("@#{k}", v) }
job.work
Ta da! Simple.
When jobs fail, the failure is stored in Redis, too, so you can check them out and possibly re-queue them.
You can start up a worker with
$ bin/resque work
This will basically loop over and over, polling for jobs and doing the work.
You can have workers work on a specific queue with the --queue
option:
$ bin/resque work --queues=high,low
$ bin/resque work --queue=high
This starts two workers working on the high
queue, one of which also polls
the low
queue.
You can control the length of the poll with interval
:
$ bin/resque work --interval=1
Now workers will check for a new job every second. The default is 5.
Resque workers respond to a few different signals:
QUIT - Wait for child to finish processing then exit
TERM / INT - Immediately kill child then exit
USR1 - Immediately kill child but don't exit
USR2 - Don't start to process any new jobs
CONT - Start to process new jobs again after a USR2
You can configure Resque via a YAML .resque
file in the root of your project:
queues: 'high,med,low'
require: 'some_context.rb'
pid_file: 'tmp/pids/resque.pid'
interval: 1
daemon: true
timeout: 5
graceful_term: false
Then pass the configuration to the resque CLI: bin/resque work -c='./.resque'
.
You can also configure Resque via Resque.configure
:
Resque.configure do |config|
# Set the redis connection. Takes any of:
# String - a redis url string (e.g., 'redis://host:port')
# String - 'hostname:port[:db][/namespace]'
# Redis - a redis connection that will be namespaced :resque
# Redis::Namespace - a namespaced redis connection that will be used as-is
# Redis::Distributed - a distributed redis connection that will be used as-is
# Hash - a redis connection hash (e.g. {:host => 'localhost', :port => 6379, :db => 0})
config.redis = 'localhost:6379:alpha/high'
end
Coming soon.
Please see CONTRIBUTING.md.
You can write your Resque workers in other languages, too:
If there's anything at all that you need or want to know, please email either the mailing list or Steve Klabnik and we'll get you sorted.