要让Airflow读取触发的dag_run.conf
内容,可以使用以下步骤:
default_args
中设置了provide_context=True
。例如:default_args = {
'owner': 'airflow',
'start_date': datetime(2022, 1, 1),
'provide_context': True
}
dag_run.conf
的任务中,将**kwargs
参数添加到任务函数中。例如:def my_task(**kwargs):
# 从kwargs中获取dag_run对象
dag_run = kwargs['dag_run']
# 读取dag_run.conf内容
conf = dag_run.conf
# 处理conf内容
# ...
dag_run.conf
来获取触发DAG运行时传递的配置。例如,如果您的dag_run.conf
包含一个名为my_param
的参数,您可以按如下方式使用它:def my_task(**kwargs):
dag_run = kwargs['dag_run']
conf = dag_run.conf
my_param = conf['my_param']
# 使用my_param进行任务处理
# ...
这样,您的任务函数就能够读取并使用触发DAG运行时传递的dag_run.conf
内容了。