python - 在 Airflow 中启动时执行代码

Question

有什么方法可以在 Airflow 启动后只执行一次代码？我想配置日志记录的处理方式，但我找不到一种方法来只初始化一次这个配置......

from utils import logger
logger.initialize()

基本上就是这些行（utils 是本地定义的包）。当我将这些行放入其中一个 DAG 时它可以工作，但随后该函数被多次执行，这是不必要的......

标签： pythonairflow

Answer 1

创建一个airflow_local_settings可以全局导入的模块。Airflow在启动期间airflow.settings 尝试加载模块。