Skip to main content
Join the official 2020 Python Developers SurveyStart the survey!

Easy utilities for common RabbitMQ tasks

Project description


Coverage Status Build Status Documentation Status

Actually easy RabbitMQ utilities for common tasks. Hides the complexities of complete control packages like pika by wrapping common use cases in minimalistic wrappers.


You can install directly from Pypi:

pip install easyrabbit

or from git using pip:

pip install git+


Simple routing


RoutingReader provides a fully asynchronous way to read from an exchange via a queue bound with a routing key. It launches a subprocess to free the calling program from being responsible for its computational overhead; within its own process, it uses pika’s asynchronous connection, enabling the highest possible performance client. The API exposed mimics a simple queue, if, after all, what you really want is to use a RabbitMQ queue as if it were a Python queue.

with RoutingReader(url, exchange, queue_name, routing_key) as reader:
    for msg in reader:
        print("Received the following message: {}".format(msg))

If the reader is needed persistently, you can also launch and terminate it yourself:

reader = RoutingReader(url, exchange, queue_name, routing_key)
# Do things with the reader

Note that even though the reader is asynchronous, you don’t need to wait for it to be ready before using it. All calls hang on the process pipe that sends data from the client process to your parent code. If you want to make sure that the connection is fully established before using it, however, you can use wait_till_ready:

reader = RoutingReader(url, exchange, queue_name, routing_key)
except TimeoutError:
    raise RuntimeError("RabbitMQ reader took more than 5 seconds to launch")

While reader.get is blocking, a non-blocking equivalent is reader.get_nowait, or your code can explicitly check that a value is available first using not reader.empty(). Iterating over reader just repeatedly calls get, and hence is blocking and will only end when the reader is closed. Use reader.getall_nowait() to obtain all values currently in the queue.

All result objects are byte arrays.


The analogous utility for writing is RoutingWriter, which provides a nearly identical interface for writing messages to RabbitMQ

with RoutingWriter(url, exchange, routing_key) as writer:
    for msg in msgs:

RoutingWriter exposes much the same API as RoutingReader, except of course exposing put instead of get.

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for easyrabbit, version 0.0.3
Filename, size File type Python version Upload date Hashes
Filename, size easyrabbit-0.0.3-py3-none-any.whl (7.6 kB) File type Wheel Python version py3 Upload date Hashes View
Filename, size easyrabbit-0.0.3.tar.gz (5.2 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page