airflow - 触发 Airflow DAG 时提交配置 : What does it do?

Question

当您通过 UI(参见屏幕截图)或 API (https://airflow.apache.org/docs/stable/rest-api-ref.html) 触发 Airflow DAG 时，您可以选择提交 JSON 配置。然而，据我所知，这个的用处并没有被清楚地记录下来。我有两个基本问题:

• 这是针对应用程序级别的自由格式配置设置，还是仅针对 Airflow 配置变量？
• 如果这是针对自由形式的配置设置，我如何(在我的代码中)访问触发 DAG 时传递的任何配置？

这是您可以在触发 DAG 时提供配置的屏幕截图:

Answer 1

是的，它用于应用程序级别的配置。

示例 -

{"appConfig":"Test"}

在您的 DAG 中阅读它

def read_app_configuration(**kwargs):
    print("Read App Config - Task : Start")
    dag_run = kwargs['dag_run']
    region = kwargs['dag_run'].conf.get('appConfig')