redique is an implementation of a high-performance Async RPC/Task Queue system built on top of Redis datastructure store and JSON marshalling protocol.
You normally want to use redique when you need to publish tasks to a set of workers to process asynchronously and retrieve the result using a task_id, or when you want to distribute workload over multiple workers easily without going through the hassle of understanding how message buses work.
You need to install the package first using pip
pip install redique
Then you need to create a backend class that contains the actual logic you want implement over the transport
class Calculator(object): def add(self, x, y): return x + y def raiseError(self): raise Exception("An Error Happened!")
Then you need to create a queue consumer on your worker side:
import redique calculator = Calculator() queue = redique.RediQue("calculator") queue.consume_loop(calculator)
The last statement will block forever consuming tasks as they arrive.
On the publisher machine you need to execute tasks remotely
import redique queue = redique.RediQue("calculator") task_id = queue.push_task("add", 1, 2) print queue.get_task_state(task_id) print queue.wait_task_result(task_id)
Another way to do that is to call execute_task that blocks till the result is returned
import redique queue = redique.RediQue("calculator") print queue.execute_task("add", 1, 2)