rabbitmq-clients 0.1.10

High level interfaces for work with RabbitMQ.

Stack:

• Python 3.11+
  
• aio-pika 9.4.1+
  

Installation

pip install rabbitmq-clients

Usage

Run rabbitMQ on your computer.

Producer

import asyncio
import json

from rabbitmq_clients import RabbitProducer

if __name__ == "__main__":
    producer = RabbitProducer(
        host='localhost',
        login='test',
        password='test',
        queue_name='test_queue',
        exchange_name='',
        routing_key='',
    )
    data = {"result": True}
    asyncio.run(producer.publish(json.dumps(data)))

Consume multiply queues (recommended)

import asyncio

from rabbitmq_clients import RabbitConsumer, QueueDTO
from rabbitmq_clients.core.types import JSON


async def show_decoded_result(result: JSON):
    print(result)


async def show_encoded_result(result: JSON):
    print(result.body)


if __name__ == "__main__":
    consumer = RabbitConsumer(
        host='localhost',
        login='test',
        password='test',
        queue_name='decoded_result',
    )
    first_queue = QueueDTO(
        name='test_queue',
        callback=show_decoded_result,
    )
    second_queue = QueueDTO(
        name='encoded_result',
        callback=show_encoded_result,
        auto_decode=False,
    )
    consumer.add_queue(first_queue)
    consumer.add_queue(second_queue)

    try:
        asyncio.run(consumer.consume_all())
    except KeyboardInterrupt:
        pass