如何配置Celery子模块的日志记录器？

Question

我理解的是，@after_setup_logger.connect应该可以让你添加自定义的处理器。不过，这对我来说不起作用。

@after_setup_logger.connect
def setup_loggers(logger: logging.Logger, *args, **kwargs):
    h = LogCollector()
    logger.addHandler(h)  # or even logger.getLogger().addHandler(h)


@app.task()
def add(x: int, y: int):
    result = x + y
    logger.info(f"Add: {x} + {y} = {result}")
    return result

在add函数里面，logger没有处理器。我哪里做错了呢？

Answer 1

我之前可能写了其他错误的代码。这里写的内容是正确的，正是如何用Celery配置日志的方式。