我有一个包含三个 bash 任务的 DAG,计划每天运行。
我想在所有 bash 脚本中访问 dag 实例的唯一 ID(可能是 PID)。
有什么办法可以做到这一点吗?
我正在寻找与 Oozie 类似的功能,我们可以在工作流 xml 或 java 代码中访问 WORKFLOW_ID。
有人可以向我指出有关“如何在 AirFlow DAG 中使用内置变量和自定义变量”的 AirFlow 文档吗?
非常感谢
帕里
对象的属性可以通过 jinja2 中的点表示法访问(参见https://airflow.apache.org/code.html#macros https://airflow.apache.org/code.html#macros)。在这种情况下,它只是:
{{ dag.dag_id }}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)