这个问题通常出现在Airflow日志配置中,如果配置的processor不存在,则会显示该错误。解决办法是更新日志配置,确保指定的处理器存在。以下是一个示例,演示如何使用默认的Python配置来初始化Airflow日志记录器:
from airflow import settings
from airflow.logging_config import configure_logging
config = settings.RunningConfig()
# use the python default config
logging_config = None
if config.get("logging_config_file"):
logging_config = config["logging_config_file"]
configure_logging(logging_config)
其中,settings.RunningConfig()返回Airflow配置对象,configure_logging()函数用于初始化日志配置,传入logging_config即可。如果不定义logging_config,则使用默认的Python日志配置。
上一篇:Airflow:Sensormode='reschedule'givesduplicatedlogging。
下一篇:Airflow:unixuserfromrun_as_userparameterdoesn'tknowairflowcommand