西芹花

celery-flower的Python项目详细描述


https://img.shields.io/pypi/v/celery-flower.svghttps://travis-ci.org/jat001/flower.svg?branch=master

flower是一个基于web的工具,用于监视和管理芹菜集群。

功能

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

    • 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

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

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

有关详细信息,请签出API Referenceexamples

安装

PYPI版本:

$ pip install flower

开发版本:

$ pip install https://github.com/jat001/flower/zipball/master

用法

启动服务器并打开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//

或者使用unix套接字文件运行:

$ flower --unix_socket=/tmp/flower.sock

许可证

Flower根据BSD 3条款许可证获得许可。查看许可文件 在顶级分发目录中获取完整的许可证文本。

获取帮助

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

贡献

如果您想贡献,只需分叉the repository,提交 更改,运行测试(tox)并发送拉取请求。 一定要加入CONTRIBUTORS

如果您有兴趣维护项目,请联系。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
如何用java表示这个数学函数的算法   Java/Stream帮助:仅使用streams将嵌套的映射列表转换为映射   使用Selenium连接到数据库时发生java未知主机异常   java如何了解jvm内存使用:“堆内存”和“堆外内存”   java Oracle BI报告导入模板   java如何使用Spring将xml转换为bean?   java线程。join()以保证执行顺序   java从THINGSPEAK到ANDROID应用程序获取JSON数据   使用Java的stanford库中的异常   java正确使用来自其他类文件的方法   如果集合中的元素类型为接口类型,如何填充集合?(爪哇)   记录java。util。记录器创建的文件超过了应有的数量   类Java对象uniq值   尝试调用无法应用于()的方法时出现java错误