Celery Flower
项目描述
Flower是一个开源的Web应用程序,用于监控和管理Celery集群。它提供有关Celery工作者和任务状态的实时信息。
特性
- 使用Celery事件进行实时监控
查看任务进度和历史记录
查看任务详情(参数、开始时间、运行时间等)
- 远程控制
查看工作者状态和统计信息
关闭和重启工作者实例
控制工作者池大小和自动缩放设置
查看和修改工作者实例所消费的队列
查看正在运行的任务
查看计划中的任务(预计时间/倒计时)
查看预留和撤回的任务
应用时间和速率限制
撤回或终止任务
- 代理监控
查看所有Celery队列的统计信息
HTTP基本认证、Google、Github、Gitlab和Okta OAuth
Prometheus集成
API
安装
使用pip安装flower很简单
$ pip install flower
可以从Github安装开发版本
$ pip install https://github.com/mher/flower/zipball/master#egg=flower
用法
要运行Flower,您需要提供代理URL
$ celery --broker=amqp://guest:guest@localhost:5672// flower
或使用celery应用程序的配置
$ celery -A tasks.app flower
默认情况下,flower在端口5555上运行,可以使用port选项进行修改
$ celery -A tasks.app flower --port=5001
您还可以使用docker镜像运行Flower
$ docker run -v examples:/data -p 5555:5555 mher/flower celery --app=tasks.app flower
在此示例中,Flower正在使用examples/tasks.py文件中定义的tasks.app
API
Flower API可以通过HTTP REST API管理集群。
例如,您可以通过以下方式重启工作池:
$ 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
更多详细信息请参阅 API参考
文档
文档可在Read the Docs找到
许可证
Flower遵循BSD 3-Clause许可证。有关完整的许可证文本,请参阅许可证文件。
项目详情
下载文件
下载适用于您平台的自定义文件。如果您不确定选择哪个,请了解更多关于安装包的信息。
源分发
flower-2.0.1.tar.gz (3.2 MB 查看散列值)
构建分发
flower-2.0.1-py2.py3-none-any.whl (383.6 kB 查看散列值)
关闭
flower-2.0.1.tar.gz的散列值
算法 | 散列值 | |
---|---|---|
SHA256 | 5ab717b979530770c16afb48b50d2a98d23c3e9fe39851dcf6bc4d01845a02a0 |
|
MD5 | 8d2d5ee71d191804b9125565f7d947a2 |
|
BLAKE2b-256 | 09a1357f1b5d8946deafdcfdd604f51baae9de10aafa2908d0b7322597155f92 |
关闭
flower-2.0.1-py2.py3-none-any.whl的散列值
算法 | 散列值 | |
---|---|---|
SHA256 | 9db2c621eeefbc844c8dd88be64aef61e84e2deb29b271e02ab2b5b9f01068e2 |
|
MD5 | 2fbd679052b323958483e5f96766c740 |
|
BLAKE2b-256 | a6ffee2f67c0ff146ec98b5df1df637b2bc2d17beeb05df9f427a67bd7a7d79c |