Да, мониторил. Для мониторинга очередей Celery можно использовать несколько инструментов и подходов: - **Flower** – веб-интерфейс для мониторинга задач, очередей и воркеров. Пример запуска: ``` flower -A proj --port=5555 ``` - **Celery Events** – встроенный механизм для отслеживания событий: ``` from celery.events import EventReceiver def handle_event(event): print(f"Event: {event}") with EventReceiver(app.connection(), handlers={"*": handle_event}): print("Monitoring Celery events...") ``` - **Prometheus + Grafana** – через экспортер `celery-exporter` или кастомные метрики. - **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()) # Задачи в очереди ```