Running a function in background requires only few steps with Kuyruk. This tutorial assumes that you have a running RabbitMQ server on localhost with default configuration.
Following files and commands are in example directory for convenience.
Kuyruk is available on PyPI. You can install it via pip.
$ pip install kuyruk
# tasks.py from kuyruk import Kuyruk kuyruk = Kuyruk() @kuyruk.task def echo(message): print message
You can specify some options when defining task. See
task() for details.
Sending the Task to RabbitMQ¶
When you call the
Task object, Kuyruk will serialize the task
as JSON and will send it to a queue on RabbitMQ instead of running it.
import tasks tasks.echo("Hello, World!")
Running a Worker¶
Run the following command to process tasks in default queue.
$ kuyruk --app tasks.kuyruk worker