将参数传递给 DAG,任务 apache airflow

pass argument to DAG, task apache airflow

我正在探索 apache airflow 1.8。我很好奇有没有办法将参数传递给 DAGstasksbackfilling?

这是我正在搜索的类似内容,

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2

或者它可能是 array 个参数。

有什么方法可以传递参数吗?我搜索了很多,但找不到任何东西。

回填是重新运行一个failed/missed/mis配置的DAG,因此没有提供命令行参数。

但是,您可以转到 DagBag 文件夹并为 dag 对象(Change/fix 现有 dag)提供参数,然后回填 DAG

我找到了可以使用 airflow variables -s my_var="some value"

设置变量的解决方案

现在我可以在应用程序的任何地方访问 my_var

查看更多选项cli