如何在气流中使用--conf选项 [英] how do I use the --conf option in airflow

问题描述

我正在尝试运行气流DAG，并且需要为任务传递一些参数。

I am trying to run a airflow DAG and need to pass some parameters for the tasks.

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

How do I read the JSON string passed as the --conf parameter in the command line trigger_dag command, in the python DAG file.

例如： airflow trigger_dag'dag_name'-r'run_id'--conf'{ key： value}'

推荐答案

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

Two ways. From inside a template field or file:

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

或者当上下文可用时，例如在 PythonOperator 可调用的python中：

Or when context is available, e.g. within a python callable of the PythonOperator:

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

这篇关于如何在气流中使用--conf选项的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！