python - 如何从 Python 和 Airflow 中的任务中获取 DAG 信息

Question

有没有办法在 Python 中的一个任务中从 Airflow 中的 DAG 获取 dag_id？

我的目的是在任务中删除一个表（已创建与 dag 同名的表）。

标签： pythonairflow

Answer 1

两种方式：

1. 如果您有模板字段https://airflow.apache.org/docs/apache-airflow/stable/macros-ref.html#macros-reference，您可以通过 Jinja 宏来完成
2. context相同的宏以字典的形式提供给execute您的操作员的方法。