訪問通過CLI傳遞給Airflow的配置參數

Question

我試圖在觸發dag運行時將下列配置參數傳遞給Airflow CLI。以下是我正在使用的trigger_dag命令。

airflow trigger_dag -c '{"account_list":"[1,2,3,4,5]", "start_date":"2016-04-25"}' insights_assembly_9900 

我的問題是，我如何訪問在dag運行中的運算符內部傳遞的con參數。

Answer 1

有兩種方法可以訪問airflow trigger_dag命令中傳遞的參數。

1. 在PythonOperator定義的可調用的方法，一個可以訪問PARAMS爲kwargs['dag_run'].conf.get('account_list')

2. 給出，其中使用的是這件事是模板化的領域，可以使用{{ dag_run.conf['account_list'] }}

領域

外部觸發式DAG的schedule_interval設置爲None用於上述工作方法