RabbitMQ

RabbitMQHandler publishes log entries to a RabbitMQ queue using pika. Connections are established lazily on first write.

Installation

No additional dependencies required. This integration uses Python's standard library.

Usage

from logly import logger
from logly.integrations.rabbitmq import RabbitMQHandler

handler = RabbitMQHandler(
    "amqp://guest:guest@localhost:5672/",
    queue="app-logs",
)
logger.add(handler, level="WARNING")

Constructor Args

Argument	Type	Default	Description
url	str	amqp://guest:guest@localhost:5672/	RabbitMQ connection URL
queue	str	logly-logs	Queue name to publish messages to
exchange	str	""	Exchange name (empty string for default exchange)
routing_key	str | None	None	Routing key (defaults to queue name)
durable	bool	True	Whether the queue/exchange should survive restarts
timeout	float	5.0	Connection timeout in seconds

Tips

• Use durable=True (default) so log messages survive RabbitMQ restarts.
• Use a dedicated exchange and routing key for log routing in complex topologies.

Full Example

from logly import logger
from logly.integrations.rabbitmq import RabbitMQHandler

handler = RabbitMQHandler(
    url="amqp://user:pass@rabbit-host:5672/",
    queue="production-logs",
    exchange="logs",
    routing_key="app.logs",
    durable=True,
    timeout=10.0,
)
logger.add(handler, level="WARNING")

logger.warning("Queue depth high", queue="orders", depth=5000)
logger.error("Consumer lag detected", consumer="worker-3")