我正在使用 Airflow 1.10.4,当我在自定义模块中使用日志记录时遇到问题。
我的代码是这样的:
import logging
log = logging.getLogger(__name__)
log.info('hello there')
输出如下:
[2020-01-22 09:44:29,954] {{logging_mixin.py:95}} INFO - [[34m2020-01-22 09:44:29,954[0m] {{[34mbase_hook.py:[0m84}} INFO[0m - hello there.
时间、文件名和日志记录级别在我的日志的每一行中都是重复的。
如何实现Airflow的日志来避免这种情况? (我在我的操作符中使用了 self.log ,没有问题。)
检查log_format
你的价值airflow.cfg
file.
我的默认配置:
# Log format
log_format = [%%(asctime)s] {%%(filename)s:%%(lineno)d} %%(levelname)s - %%(message)s
simple_log_format = %%(asctime)s %%(levelname)s - %%(message)s
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)