将参数传递给 DAG,任务 apache airflow
pass argument to DAG, task apache airflow
我正在探索 apache airflow 1.8
。我很好奇有没有办法将参数传递给 DAGs
或 tasks
而 backfilling
?
这是我正在搜索的类似内容,
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
我正在探索 apache airflow 1.8
。我很好奇有没有办法将参数传递给 DAGs
或 tasks
而 backfilling
?
这是我正在搜索的类似内容,
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