airflow - 写入 Airflow 日志

Question

在 Airflow 中写入日志的一种方法是从 PythonOperator 返回一个字符串，如第 44 行 here 所示。 .

还有其他方法可以让我写入 Airflow 日志文件吗？我发现打印语句没有保存到日志中。

Answer 1

您可以将日志记录模块导入到代码中并以这种方式写入日志

import logging

logging.info('Hello')

这里有更多选项

import logging    

logging.debug('This is a debug message')
logging.info('This is an info message')
logging.warning('This is a warning message')
logging.error('This is an error message')
logging.critical('This is a critical message')