wmbitfarm/leek

镜像概述

Leek是一款针对Celery任务队列的实时监控与管理工具，通过连接到现有Celery broker，提供实时仪表盘、任务探索、worker监控及任务级控制功能，无需代码变更、代理或插件，仅需一个Docker容器即可运行。

核心功能

• 实时仪表盘：显示任务数量、按状态分类的吞吐量堆叠图、worker状态
• 任务探索：通过WebSocket实时更新任务状态，支持搜索、筛选、排序所有任务
• 任务详情：查看任务参数、结果、异常回溯、状态时间线，支持撤销/终止任务
• 任务类型统计：按类型展示数量、失败率、平均及p95运行时间、近期任务
• Worker监控：在线/离线状态、心跳跟踪、批量ping所有worker
• 实时事件流：可过滤的Celery事件实时feed
• Broker无关性：支持Redis、RabbitMQ、SQS等所有Celery兼容的broker

使用场景

• 监控Celery任务队列运行状态，及时发现任务失败或延迟
• 管理任务生命周期，处理异常任务
• 分析任务类型性能指标，优化执行效率
• 跟踪worker健康状态

配置说明

快速启动

bash
docker run -d \
  -e CELERY_BROKER_URL=redis://your-redis-host:6379/0 \
  -p 8585:8585 \
  wmbitfarm/leek

打开http://localhost:8585%E5%8D%B3%E5%8F%AF%E8%AE%BF%E9%97%AE%E3%80%82
注意：Celery worker需启用事件（celery -A app worker -E 或设置 worker_send_task_events = True）。

数据持久化

挂载卷保留任务历史：

bash
docker run -d \
  -e CELERY_BROKER_URL=redis://redis:6379/0 \
  -p 8585:8585 \
  -v leek-data:/app \
  wmbitfarm/leek

工作原理

Leek利用Celery内置事件协议，创建独立应用实例连接broker，监听任务生命周期事件和worker心跳，事件持久化到SQLite（或PostgreSQL）并通过WebSocket流式传输到浏览器，与应用代码零耦合。

链接

• 源码：https://github.com/wmbitfarm/leek
• 许可证：MIT