Airflow 从 cli 传递参数

Question

有没有办法将参数传递给:

airflow trigger_dag dag_name {param}

？

我有一个监视文件目录的脚本 - 当文件移动到目标目录时，我想触发 dag 作为参数传递文件路径。

Answer 1

你可以这样传递:

airflow trigger_dag --conf {"file_variable": "/path/to/file"} dag_id

然后在您的 dag 中，您可以使用模板访问此变量，如下所示:

{{ dag_run.conf.file_variable }}

如果这不起作用，分享您的 dag 的简单版本可能有助于获得更好的答案。