`airflow.secrets.metastore`¶

Objects relating to sourcing connections from metastore database

Module Contents¶

Retrieves Connection object and Variable from airflow metastore database.

class airflow.secrets.metastore.MetastoreBackend(**kwargs)[source]¶

Bases: airflow.secrets.BaseSecretsBackend

Retrieves Connection object and Variable from airflow metastore database.

get_connection(self, conn_id, session=None) → Optional[airflow.models.connection.Connection][source]¶

Return connection object with a given conn_id.

get_connections(self, conn_id, session=None) → List[airflow.models.connection.Connection][source]¶

Return connection object with a given conn_id.

get_variable(self, key: str, session=None)[source]¶

Get Airflow Variable from Metadata DB