airflow.secrets.base_secrets¶
类¶
给定 conn_id 时检索 Connection 对象,或给定 key 时检索 Variable 的抽象基类。 |
模块内容¶
- class airflow.secrets.base_secrets.BaseSecretsBackend[source]¶
Bases:
abc.ABC
给定 conn_id 时检索 Connection 对象,或给定 key 时检索 Variable 的抽象基类。
- abstract get_conn_value(conn_id)[source]¶
从 Secrets 后端检索表示 Connection 对象的字符串值。
如果您的 secrets 后端使用的客户端已返回 Python dict,则应改为覆盖
get_connection
。- 参数:
conn_id (str) – 连接 ID
- deserialize_connection(conn_id, value)[source]¶
给定 Airflow Connection 的序列化表示,返回一个实例。
查看第一个字符以确定如何反序列化。
- 参数:
- 返回:
反序列化的 Connection
- 返回类型:
- get_connection(conn_id)[source]¶
返回给定
conn_id
的 connection 对象。首先尝试
get_conn_value
,如果未实现,则尝试get_conn_uri
- 参数:
conn_id (str) – 连接 ID