如何将变量传递给 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 对象。