Skip to content

Instantly share code, notes, and snippets.

@toshsan
Forked from defunkt/resque.py
Last active December 27, 2015 18:38
Show Gist options
  • Save toshsan/6430841b8ce864405c9e to your computer and use it in GitHub Desktop.
Save toshsan/6430841b8ce864405c9e to your computer and use it in GitHub Desktop.
Resque client in Python (fixed)
from redis import Redis
import simplejson
class Resque(object):
"""Dirt simple Resque client in Python. Can be used to create jobs."""
redis_server = 'localhost:6379'
def __init__(self):
host, port = self.redis_server.split(':')
self.redis = Redis(host=host, port=int(port))
def push(self, queue, object):
key = "resque:queue:%s" % queue
self.redis.rpush(key, simplejson.dumps(object))
def pop(self, queue):
key = "resque:queue:%s" % queue
return simplejson.loads(self.redis.lpop(key))
queue = Resque()
queue.push('default', {'class':'ShellJob', 'args':['which', 'cat']})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment