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())