oozie - 子任务中的 AirFlow dag id 访问

我有一个包含三个 bash 任务的 DAG，计划每天运行。

我想在所有 bash 脚本中访问 dag 实例的唯一 ID(可能是 PID)。

有没有办法做到这一点？

我正在寻找与 Oozie 类似的功能，我们可以在其中访问工作流 xml 或 java 代码中的 WORKFLOW_ID。

有人可以指点我关于“如何在 AirFlow DAG 中使用内置变量和自定义变量”的 AirFlow 文档

非常感谢
帕里

最佳答案

可以在 jinja2 中使用点表示法访问对象的属性(参见 https://airflow.apache.org/code.html#macros )。在这种情况下，它只是:

{{ dag.dag_id }}

关于oozie - 子任务中的 AirFlow dag id 访问，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/38304567/