davidcastagnetoa rabbitmq_broker
RabbitMQ es un message broker AMQP con soporte nativo de prioridades, dead-letter queues y routing avanzado. Alternativa a Redis broker cuando se necesitan garantías de entrega más estrictas.
When to use
Usar como alternativa al Redis broker en el worker_pool_agent si se necesitan prioridades nativas de mensaje, dead-letter queues o routing basado en topic exchange.
Instructions
- Desplegar:
docker run -d rabbitmq:3-management. - Configurar en Celery:
broker_url = 'amqp://user:pass@rabbitmq:5672//'. - Configurar exchanges y queues con prioridad:
task_queues = [ Queue('realtime', Exchange('realtime'), routing_key='realtime', queue_arguments={'x-max-priority': 10}), ] - Configurar DLQ:
queue_arguments={'x-dead-letter-exchange': 'dlx'}. - Habilitar management plugin para dashboard en puerto 15672.
- Configurar HA policy:
rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'. - Monitorizar con Prometheus plugin:
rabbitmq-plugins enable rabbitmq_prometheus.
Notes
- RabbitMQ consume más recursos que Redis broker (~200MB RAM base).
- Las prioridades nativas de RabbitMQ son superiores a múltiples colas de Redis.
- Usar Redis broker para V1 por simplicidad; migrar a RabbitMQ si se necesitan DLQ avanzadas.