如何限制对airflow.models的访问？

Question

我有一个气流实例，其中有许多拥有 DAG 的租户。他们想在他们的 dagrun 上提取元数据，例如 DagRun.end_date。但是我想限制每个租户，以便他们只能访问与自己的 dagruns 相关的数据，而无法访问其他人的 dagruns 的数据。如何做到这一点？

这就是我想象的 DAG 的样子

# custom macro function
def get_last_dag_run(dag):
    last_dag_run = dag.get_last_dagrun()
    return last_dag_run.end_date

我发现这些资源解释了如何提取数据，而不是如何限制数据。

• Getting the date of the most recent successful DAG execution
• Apache airflow macro to get last dag run execution time
• How to get last two successful execution dates of Airflow job?
• how to get latest execution time of a dag run in airflow
• How to find the start date and end date of a particular task in dag in airflow?
• How to get dag status like running or success or failure

Answer 1

_{注意：我是 Airflow 的贡献者。}

这在当前的 Airflow 架构中是不可能的。

我们正在慢慢努力使 Airflow 支持多租户，但目前我们已经完成了一半，我相信这将是几个主要版本。

目前隔离租户的唯一方法是给每个租户单独的 Airflow 实例，这并不像您最初想象的那么糟糕。如果您在同一个自动扩展 Kubernetes 集群上的不同命名空间中运行它们并添加 KEDA 自动扩展，并使用相同的数据库服务器（但给每个租户一个单独的模式），这可能会相当有效（特别是如果您使用 Terraform 来设置/拆卸例如这样的气流实例）。