如何将Celery Worker的INFO级别日志修改为DEBUG级别？

问题描述 #

运行Celery Worker时，以下两类INFO级日志输出过多，希望将其调整为DEBUG级别：

INFO:celery.worker.job:Task XXXX succeeded in XXX: None

INFO:celery.worker.strategy:Received task:

可行解决方案 #

1. 启动Worker时直接指定日志器级别 #

启动Worker时，通过参数精准控制指定模块的日志级别：

celery -A your_app_name worker -l INFO --loglevel=celery.worker.job:DEBUG --loglevel=celery.worker.strategy:DEBUG

这种方式直接生效，适合快速测试。

2. 在celery.py中配置日志器 #

在项目的celery.py文件中，通过自定义日志钩子修改目标日志器级别：

from celery import Celery
import logging

app = Celery('your_app_name')
app.config_from_object('your_config_module')  # 按需加载项目配置

def setup_custom_logging():
    # 获取目标日志器并调整级别
    job_logger = logging.getLogger('celery.worker.job')
    strategy_logger = logging.getLogger('celery.worker.strategy')
    job_logger.setLevel(logging.DEBUG)
    strategy_logger.setLevel(logging.DEBUG)

# 注册日志配置钩子
app.setup_logging = setup_custom_logging

确保该配置在Celery app初始化后、Worker启动前加载。

3. 通过Celery配置项全局调整 #

在Celery配置文件（如Django的settings.py）中添加日志器配置：

CELERY_LOGGING = {
    'version': 1,
    'disable_existing_loggers': False,
    'loggers': {
        'celery.worker.job': {
            'level': 'DEBUG',
            'handlers': ['console'],
            'propagate': False,
        },
        'celery.worker.strategy': {
            'level': 'DEBUG',
            'handlers': ['console'],
            'propagate': False,
        },
    },
    'handlers': {
        'console': {
            'class': 'logging.StreamHandler',
            'formatter': 'celery',
        },
    },
    'formatters': {
        'celery': {
            'format': '%(levelname)s:%(name)s:%(message)s',
        },
    },
}

随后确保Celery加载此配置。

4. 排查日志配置冲突 #

若以上方法无效，检查以下情况：

• 是否有其他日志配置（如Django的LOGGING）覆盖了Celery设置
• 启动命令中是否有--loglevel=INFO这类全局参数强制限制级别
• 日志处理器（handler）本身的级别是否设为INFO，需同步调整handler级别以输出DEBUG内容

内容的提问来源于stack exchange，提问作者galyoss