在dag中使用logging模块记录日志时,如果记录的内容只有一列,不会出现在Airflow的日志中。解决方法是在记录日志时添加一个额外的空列,如下所示:
import logging
logger = logging.getLogger(__name__)
def my_task():
logger.info("This is my log message\t") # 加上一个空列
在日志记录消息后加上 \t
可以添加一个空列,使日志能够显示在Airflow的日志中。
上一篇:Airflow日志无法加载