我正在尝试运行 Airflow DAG，需要为任务传递一些参数。
如何读取在命令行中作为 --conf 参数传递的 JSON 字符串 trigger_dag命令，在 python DAG 文件中。
例如:airflow trigger_dag 'dag_name' -r 'run_id' --conf '{"key":"value"}'
最佳答案
两种方式。从模板字段或文件中:
{{ dag_run.conf['key'] }}
或者当上下文可用时，例如在
PythonOperator 的 Python 可调用文件中:context['dag_run'].conf['key']
关于airflow - 我如何在 Airflow 中使用 --conf 选项，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45945783/