aiorabbit 0.1.0a1

Project Goals

• To create a simple, robust RabbitMQ client library for AsyncIO development in Python 3

• To make use of new features and capabilities in Python 3.7+

• To abstract away the AMQP channel and use it only as a protocol coordination mechanism inside the client

• To provide built-in support for multiple brokers and automatic reconnection

Example Use

The following demonstrates an example of the intended behavior for the library:

import time
import uuid

import aiorabbit

RABBITMQ_URL = 'amqps://guest:guest@localhost:5672/%2f'


async def main():
    client = await aiorabbit.connect(RABBITMQ_URL)
    await client.confirm_select()

    response = await client.publish(
        'exchange', 'routing-key', 'message-body', app_id='example',
        message_id=str(uuid.uuid4()), timestamp=int(time.time()),
        mandatory=True)

    if not response.ok:
        print('Publishing failure: {!r} {!r}'.format(
            response.error, response.message))

if __name__ == '__main__':
    asyncio.run(main())

Documentation

http://aiorabbit.readthedocs.org

License

BSD

Python Versions Supported

3.7+