pico-rabbitmq 0.1.0

RabbitMQ pub-sub for the Pico ecosystem: @consumer methods and @publisher clients over aio-pika.

pico-rabbitmq

RabbitMQ pub-sub for the pico ecosystem: @consumer methods and declarative @publisher clients over aio-pika. Covers what pico-celery does not: events, fan-out, topic routing.

Installation

pip install pico-rabbitmq

Quick start

rabbitmq:
  url: amqp://guest:[e-mail]/

Consume — a component method per queue, JSON body decoded for you:

from pico_ioc import component
from pico_rabbitmq import consumer

@component
class OrderProjections:
    @consumer("orders-projection", exchange="events", routing_key="orders.*")
    async def on_order_event(self, message: dict):
        ...

Publish — stubs, like a pico-httpx client:

from pico_rabbitmq import publisher, publish

@publisher
class OrderEvents:
    @publish(exchange="events", routing_key="orders.created")
    def order_created(self, message): ...

Semantics:

• Consumers and publishers run on a dedicated background loop — works in sync scripts, FastAPI apps and workers alike, no lifespan wiring.
• Each message resolves its component through the container (prototype scope = fresh instance per message).
• Ack on success; on exception the message is logged and rejected without requeue (configure a dead-letter exchange to keep failures).
• Sync publish stubs block until the broker confirms; async stubs await it.
• Queues and named exchanges are declared durable; the connection closes on container shutdown.

Documentation

Full documentation: https://dperezcabrera.github.io/pico-rabbitmq/

License

MIT