flower-new 0.8.0

功能

• 使用Celery事件进行实时监控

  • 任务进度和历史记录

  • 显示任务详情（参数、开始时间、运行时间等）的能力

  • 图表和统计数据

• 远程控制

  • 查看工作进程的状态和统计数据

  • 关闭和重启工作进程实例

  • 控制工作进程池大小和自动扩展设置

  • 查看和修改工作进程实例所消费的队列

  • 查看当前运行的任务

  • 查看计划中的任务（预计到达时间/倒计时）

  • 查看预留和撤销的任务

  • 应用时间和速率限制

  • 配置查看器

  • 撤销或终止任务

• 代理监控

  • 查看所有Celery队列的统计数据

  • 队列长度图表

• HTTP API

• 基本认证和Google OpenID认证

API

Flower API可以通过REST API管理集群，通过WebSocket实时调用任务并接收任务事件。

例如，您可以通过以下方式重启工作进程池：

$ curl -X POST https://:5555/api/worker/pool/restart/myworker

或者通过以下方式调用任务：

$ curl -X POST -d '{"args":[1,2]}' https://:5555/api/task/async-apply/tasks.add

或者通过以下方式终止正在执行的任务：

$ curl -X POST -d 'terminate=True' https://:5555/api/task/revoke/8a4da87b-e12b-4547-b89a-e92e4d1f8efd

或者实时接收任务完成事件

var ws = new WebSocket('ws://:5555/api/task/events/task-succeeded/');
ws.onmessage = function (event) {
    console.log(event.data);
}

更多信息请参阅 API参考 和 示例。

安装

要安装，请简单执行以下操作：

$ pip install flower

使用方法

启动服务器并打开 https://:5555

$ flower --port=5555

或者从 celery 启动

$ celery flower -A proj --address=127.0.0.1 --port=5555

代理 URL 和其他配置选项可以通过标准 Celery 选项传递

$ celery flower -A proj --broker=amqp://guest:guest@localhost:5672//

文档

文档可在 Read the Docs 和 IPython Notebook Viewer 查阅

屏幕截图

更多 截图

获取帮助

请前往 irc.freenode.net 上的 #celery IRC 频道或 提交问题。

贡献

如果您想贡献，只需fork 仓库，提交您的更改，运行测试 (python -m tests) 并发送拉取请求。请确保您已在 AUTHORS 中添加自己。