Celery Logger

celery-logger是一个Python库，用于记录celery事件，例如接收到的任务、失败/成功的任务和重试的任务，以及任务参数。

功能

• 简单灵活的任务日志
• 多种部署选项（Docker、虚拟机）
• 集成可能性：例如ELK堆栈和AWS cloudwatch

它是如何工作的？

Celery-logger连接到您的消息代理（如redis、rabbitMQ或SQS）并在文件或stdout上记录任务。

这样，您可以轻松地拥有多个celery工作进程，并在一个地方查看日志。

示例项目

我们提供了一个示例项目，您可以试用并了解它的工作方式。

入门

# navigate to the sample-project folder
$ cd sample-project
# Build and start the containers:
$ docker-compose up

查询日志

请确保您在sample-project文件夹中

调用一些任务

$ docker-compose exec celeryd python call_tasks.py

Tasks have been called!
Run `docker-compose logs -f celery-logger` to see the logger in action.

查看所有事件

$ docker-compose logs celery-logger 

搜索失败的任务

$ docker-compose logs celery-logger | grep task-failed

搜索特定任务

$ docker-compose logs celery-logger | grep "app.add"

搜索特定任务和参数

$ docker-compose logs celery-logger | grep "app.add" | grep "(6, 1)"

搜索任务ID

$   docker-compose logs celery-logger | grep 20925a8c-03f7-4bd7-b3dd-24e2bc9e26e2

安装

使用包管理器pip安装celery-logger。

pip install celerylogger

使用方法

可执行文件将在路径中以 celery-logger 的形式提供

# Display the help text
$ celery-logger -h
# Start logging from a redis broker
$ celery-logger --celery-broker redis://redis:6379/0

作者

• 塞尔吉奥·奥利维拉 - 初始工作 - Seocam
• 蒂亚戈·费雷拉 - 改进、文档和当前维护者 - thiagoferreiraw
• 安德烈·吉罗尔 - 打包和分发 - Girol