Мониторил ли очереди Celery

Да, мониторил. Для мониторинга очередей Celery можно использовать несколько инструментов и подходов:

1. Flower – веб-интерфейс для мониторинга задач, очередей и воркеров.
   Пример запуска:

   bash

   Копировать

   flower -A proj --port=5555

2. Celery Events – встроенный механизм для отслеживания событий:

   python

   Копировать

   from celery.events import EventReceiver
   def handle_event(event):
       print(f"Event: {event}")
   with EventReceiver(app.connection(), handlers={"*": handle_event}):
       print("Monitoring Celery events...")

3. Prometheus + Grafana – через экспортер celery-exporter или кастомные метрики.

4. RabbitMQ/Redis Management – если используете эти брокеры, их встроенные инструменты (например, RabbitMQ Management Plugin) показывают состояние очередей.

Ключевые метрики для мониторинга:

• Длина очереди (queue_length).
• Время выполнения задач.
• Количество активных/завершенных/упавших задач.
• Статус воркеров (онлайн/оффлайн).

Пример проверки очереди через Celery API:

from proj.celery import app
inspector = app.control.inspect()
print(inspector.active())  # Активные задачи
print(inspector.reserved())  # Задачи в очереди