airflow.secrets.metastore

与从元存储数据库获取连接相关的对象。

模块内容

类

MetastoreBackend

从 airflow 元存储数据库检索连接对象和变量。
class airflow.secrets.metastore.MetastoreBackend[源代码]

基类： airflow.secrets.BaseSecretsBackend

从 airflow 元存储数据库检索连接对象和变量。

get_connection(conn_id, session=NEW_SESSION)[源代码]

返回具有给定 conn_id 的连接对象。

首先尝试 get_conn_value，如果未实现，则尝试 get_conn_uri

参数

conn_id (str) – 连接 ID

get_connections(conn_id, session=NEW_SESSION)[源代码]

返回具有给定 conn_id 的连接对象。

参数

conn_id (str) – 连接 ID

get_variable(key, session=NEW_SESSION)[源代码]

从元数据数据库获取 Airflow 变量。

参数

key (str) – 变量键

返回

变量值

返回类型

str | None

此条目是否有帮助？