將參數傳遞給DAG，任務apache airflow

我在探索apache airflow 1.8。我很好奇，有沒有辦法將參數傳遞給DAGs或tasks而backfilling？將參數傳遞給DAG，任務apache airflow

下面是類似的東西，我在尋找，

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2

，也可能是參數的個數array。

有沒有辦法傳遞參數？我搜索了很多，但無法找到任何東西。

2017-04-06 Mubin

我對面，我可以使用airflow variables -s my_var="some value"

設置變量的解決方案來

現在我可以在整個應用程序的任何地方訪問my_var。

更多選項查看cli

2017-04-13 15:15:16 Mubin

如果你有一次一個單一的運行，這是可以接受的。對於具有不同變量的各種併發運行，這是行不通的，因爲變量是全局的。 – ilcord

回填將重新運行失敗/錯過/錯誤配置的DAG，因此沒有規定提供命令行參數。

但是，你可以去DagBag文件夾，並給PARAMS到DAG對象（改變/修復現有DAG），然後回填土的DAG

2017-04-07 07:04:46

回答