如何在气流中使用--conf选项

我试图运行气流DAG并需要传递任务的一些参数。如何在气流中使用--conf选项

如何在python DAG文件中读取命令行trigger_dag命令中作为--conf参数传递的JSON字符串。

ex：airflow trigger_dag 'dag_name' -r 'run_id' --conf '{"key":"value"}'

发现样品在https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/example_trigger_target_dag.py#L62 –

两种方式。从模板字段或文件内部：

{{ dag_run.conf['key'] }}

或者当上下文可用时，例如，可调用的PythonOperator蟒内：

context['dag_run'].conf['key']

2017-08-31 18:32:05

回答