Для работы с более сложными приложениями и большим объёмом Celery-задач вам пригодится эффективный инструмент мониторинга, который позволит отслеживать состояние и производительность, — Flower.
Flower — веб-интерфейс и инструмент мониторинга Celery, который позволяет пользователю удобно контролировать асинхронные задачи, выполняемые в фоновом режиме. Он сообщает детализированную информацию о текущих задачах, их состоянии, времени выполнения, ошибках и других метриках производительности.
Возможности Flower:
- Визуализация задач
Flower позволяет в реальном времени отслеживать запущенные, выполняющиеся и завершившиеся задачи. Это особенно удобно, когда необходимо понять, какие задачи активны, и проанализировать время их выполнения. - Статистика и метрики
Flower предоставляет подробную статистику о задачах, такую как количество успешных и неуспешных задач, среднее время их выполнения, их статусы и многое другое. Это позволяет идентифицировать узкие места в производительности системы и принять соответствующие меры. - Мониторинг рабочих узлов
Flower позволяет отслеживать состояние и нагрузку на рабочие узлы. Вы можете видеть, сколько задач выполнил каждый рабочий узел, идентифицировать проблемы с насыщенностью и балансировкой нагрузки. - Управление задачами
Через веб-интерфейс Flower вы можете приостанавливать, возобновлять и отменять выполнение задач. Это может быть полезно, если необходимо вмешаться в обработку задачи, например при обнаружении ошибок или неожиданном поведении. - Аутентификация и авторизация Flower поддерживает настройку аутентификации и авторизации. Это позволяет предоставить доступ к мониторингу задач только авторизованным пользователям.
Давайте интегрируем Flower в разработанное ранее приложение по обработке изображений.
Установите Flower с помощью pip:
pip install flower==2.0.1Запустите Flower:
celery -A app.celery flowerПосле этого вы можете получить доступ к Flower по адресу http://localhost:5555 в вашем браузере. Больше всего нас будет интересовать вкладка Tasks, так как пока мы работаем с одним воркером и одним брокером.
Во вкладке Tasks вы можете найти список задач с подробной информацией.
При клике на UUID появится подробное описание задачи.
Reference
📂 Task Queue | Последнее изменение: 17.03.2024 12:09