mher/flower
Flower
Flower is a monitoring and administration tool for Celery task queues. It provides a real-time web dashboard and a REST API to monitor distributed task clusters, manage worker instances, and observe message broker health.
The project distinguishes itself by offering centralized control over the task lifecycle, allowing users to trigger, revoke, or terminate tasks and apply execution rate limits. It also includes a Prometheus metrics exporter to surface internal performance and status data for external monitoring and alerting systems.
The tool covers a broad range of observability and management capabilities, including queue volume tracking, worker pool size orchestration, and task execution history. Access to these administrative interfaces is secured through identity-based access control and third-party identity provider integrations.
Features
- Web Dashboards - Ships a real-time web dashboard for monitoring and managing distributed task clusters and workers.
- Distributed Worker Orchestration - Offers orchestration controls for worker status, pool sizes, and the ability to restart or shut down instances.
- Task Queue Management - Provides a real-time web dashboard for the monitoring and management of distributed Celery task queues.
- Worker Node Management - Provides centralized control over remote worker operations and their associated tasks through a web interface.
- Worker Pool Management - Allows adjusting worker pool sizes and managing the lifecycle of distributed task processes.
- RESTful API Interfaces - Provides a RESTful interface that translates HTTP requests into control commands for remote worker instances.
- REST Administrative APIs - Exposes a programmatic REST API for triggering tasks and managing cluster settings.
- Distributed Task Queues - Monitors message broker health and queue statistics to ensure efficient task delivery.
- Control Interfaces - Enables the ability to revoke, terminate, or trigger tasks and apply execution rate limits.
- Task Execution Monitoring - Monitors the lifecycle of distributed tasks, including their start, stop, execution history, and runtimes.
- Cluster Administration - Provides centralized web and API-based administration for distributed Celery task clusters.
- Cluster Health Monitoring - Provides a dashboard for querying the real-time health and operational status of distributed Celery worker clusters.
- Cluster Management Tools - Provides a REST API for automating administrative tasks and managing the distributed cluster state.
- Task Monitoring - Tracks real-time status, execution history, and performance of distributed tasks in a Celery cluster.
- Message Broker Monitoring - Directly queries the message broker to provide real-time statistics on queue depth and message volume.
- Administrative Panels - Ships a centralized administrative panel to control worker status, pool sizes and task lifecycles.
- State Tracking - Updates internal task and worker status by listening to real-time event messages from the broker.
- Performance Metrics Exporters - Exports internal execution data to external systems to track task runtimes and cluster health.
- Prometheus Exporters - Exposes internal performance data in a scrapable format compatible with Prometheus monitoring systems.
- Task Queues - Web-based monitoring for task clusters.
- Admin Panels - Real-time monitoring and management for task queues.
