如何将变量传递给 UI 中的单个 Airflow 任务实例

Question

我在 Kubernetes 上运行气流（所以不想要涉及 CLI 命令的解决方案，理想情况下一切都应该通过 GUI 完成。）

我有一些任务，只想手动向命令注入变量。我可以使用气流变量来实现此目的，但用户必须创建然后重置变量。

使用变量，它可能看起来像：

flag = Variable.get(
    "NAME_OF_VARIABLE", False
)
append_args = "--injected-argument" if flag == "True" else ""

或者你可以使用 jinja 模板。

有没有一种方法可以在不使用 CLI 的情况下一次性将变量注入到任务中？

Answer 1

无法将值传递给 Airflow 中的单个任务，但您可以触发 DAG 并为该单个 DAG 运行提供 JSON 对象。

当模板化为

{{ dag_run.conf }}

时，可以访问 JSON 对象。