跳转到主要内容

Celery Flower

项目描述

PyPI - Downloads Docker Pulls https://github.com/mher/flower/workflows/Build/badge.svg https://img.shields.io/pypi/v/flower.svg

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 查看散列值)

上传时间 Python 2 Python 3

支持者

AWSAWS 云计算和安全赞助商 DatadogDatadog 监控 FastlyFastly CDN GoogleGoogle 下载分析 MicrosoftMicrosoft PSF 赞助商 PingdomPingdom 监控 SentrySentry 错误记录 StatusPageStatusPage 状态页面