Django Celery 日志记录最佳实践

我正在尝试让 Celery 日志记录与Django。我已经设置了日志记录settings.py转到控制台（这工作正常，因为我正在托管Heroku）。在每个模块的顶部，我有：

import logging
logger = logging.getLogger(__name__)

在我的tasks.py 中，我有：

from celery.utils.log import get_task_logger
logger = get_task_logger(__name__)

这对于记录来自任务的调用效果很好，我得到如下输出：

2012-11-13T18:05:38+00:00 app[worker.1]: [2012-11-13 18:05:38,527: INFO/PoolWorker-2] Syc feed is starting

但是，如果该任务然后调用另一个模块中的方法，例如Aqueryset方法，我得到重复的日志条目，例如

2012-11-13T18:00:51+00:00 app[worker.1]: [INFO] utils.generic_importers.ftp_processor process(): File xxx.csv already imported. Not downloaded
2012-11-13T18:00:51+00:00 app[worker.1]: [2012-11-13 18:00:51,736: INFO/PoolWorker-6] File xxx.csv already imported. Not downloaded

我想我可以用

CELERY_HIJACK_ROOT_LOGGER = False

只需使用Django但是当我尝试它时这不起作用，即使我确实让它工作，我也会失去"PoolWorker-6"我确实想要一点。 （顺便说一句，我不知道如何让任务名称显示在 Celery 的日志条目中，因为the docs http://docs.celeryproject.org/en/master/configuration.html?highlight=celeryd_task_log_format#std:setting-CELERYD_TASK_LOG_FORMAT似乎表明它应该）。

我怀疑我在这里遗漏了一些简单的东西。

当您的记录器在“另一个模块”的开头初始化时，它会链接到另一个记录器。它处理您的消息。它可以是根记录器，或者通常我在 Django 项目中看到的 - 具有名称的记录器''.

最好的方法是覆盖您的日志记录配置：

LOGGING = {
    'version': 1,
    'disable_existing_loggers': True,
    'formatters': {
        'simple': {
            'format': '%(levelname)s %(message)s',
             'datefmt': '%y %b %d, %H:%M:%S',
            },
        },
    'handlers': {
        'console': {
            'level': 'DEBUG',
            'class': 'logging.StreamHandler',
            'formatter': 'simple'
        },
        'celery': {
            'level': 'DEBUG',
            'class': 'logging.handlers.RotatingFileHandler',
            'filename': 'celery.log',
            'formatter': 'simple',
            'maxBytes': 1024 * 1024 * 100,  # 100 mb
        },
    },
    'loggers': {
        'celery': {
            'handlers': ['celery', 'console'],
            'level': 'DEBUG',
        },
    }
}

from logging.config import dictConfig
dictConfig(LOGGING)

在这种情况下，我想它应该像你想象的那样工作。

附： Python2.7+中添加了dictConfig。