flower-new 0.8.0

功能

• 使用芹菜事件进行实时监控

  • Task progress and history
  • Ability to show task details (arguments, start time, runtime, and more)
  • Graphs and statistics

• 遥控器

  • View worker status and statistics
  • Shutdown and restart worker instances
  • Control worker pool size and autoscale settings
  • View and modify the queues a worker instance consumes from
  • View currently running tasks
  • View scheduled tasks (ETA/countdown)
  • View reserved and revoked tasks
  • Apply time and rate limits
  • Configuration viewer
  • Revoke or terminate tasks

• 经纪人监控

  • View statistics for all Celery queues
  • Queue length graphs

• http api

• 基本身份验证和Google OpenID身份验证

API

flower api允许通过restapi管理集群、调用任务和 通过websockets实时接收任务事件。

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

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

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

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

或终止执行任务：

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

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

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

有关详细信息，请签出API Reference和examples。

安装

要安装，只需：

$ pip install flower

用法

启动服务器并打开http://localhost:5555：

$ flower --port=5555

或从芹菜中推出：

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

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

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

文档

文档可在Read the Docs和IPython Notebook Viewer

屏幕截图

更多screenshots

获取帮助

请转到irc.freenode.net上的芹菜irc频道或 open an issue。

贡献

如果您想贡献，只需分叉the repository，提交 更改，运行测试（python-m tests）并发送一个pull请求。 一定要加入AUTHORS。