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 配置日志记录。