如何在气流中使用

本文介绍了如何在气流中使用--conf选项的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

我正在尝试运行气流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']