celery task 生效设置.

gen_logger.py

import logging
import logging.config


def configure_logger(name, log_path):
    logging.config.dictConfig({
        'version': 1,
        'formatters': {
            'default': {'format': '%(asctime)s - %(levelname)s - %(message)s', 'datefmt': '%Y-%m-%d %H:%M:%S'}
        },
        'handlers': {
            'file': {
                'level': 'DEBUG',
                'class': 'logging.handlers.RotatingFileHandler',
                'formatter': 'default',
                'filename': log_path,
                'maxBytes': 1024,
                'backupCount': 3
            }
        },
        'loggers': {
            'default': {
                'level': 'DEBUG',
                'handlers': ['file']
            },
            'reduce': {
                'level': 'DEBUG',
                'handlers': ['file']
            }
        },
        'disable_existing_loggers': False
    })
    return logging.getLogger(name)

task_logging_init.py

from celery import Celery
from celery.signals import after_setup_logger
from gen_logger import configure_logger

@after_setup_logger.connect
def setup_loggers(*args, **kwargs):
    configure_logger('reduce', 'log_reduce.log')
 

注意初始化, logger位置 after_setup_logger.connect