Lightweight asyncio compatible utilities for consuming broker messages
aio-message-handler A simple asyncio compatible consumer for handling amqp messages. Installation pip install aio-message-handler Usage example Simple consumer: import asyncio from aio_message_handler.consumer import Consumer async def main(): consumer = Consumer(“amqp://guest:[email protected]/”) @consumer.message_handler(exchange=”myexchange”, binding_key=”key”) async def handler(msg): print(‘received:’, msg.body) msg.ack() await consumer.start() asyncio.run(main())
Read more