Airflow 2025 峰会将于 10 月 07-09 日举行。立即注册抢购早鸟票!

airflow.secrets.cache

SecretCache

一个用于管理全局密钥缓存的静态类。

模块内容

class airflow.secrets.cache.SecretCache[source]

一个用于管理全局密钥缓存的静态类。

exception NotPresentException[source]

基类: Exception

当缓存中不存在某个键时引发此异常。

classmethod init()[source]

初始化缓存,如果配置允许的话。

可以安全地多次调用。

classmethod reset()[source]

仅用于测试目的。

classmethod get_variable(key)[source]

尝试从缓存中获取与键关联的值。

返回值:

如果值存在于缓存中且未过期,则返回保存的值(可以为 None),否则引发 NotPresent 异常。

返回类型:

str | None

classmethod get_connection_uri(conn_id)[source]

尝试从缓存中获取与 conn_id 关联的 URI。

返回值:

如果 URI 存在于缓存中且未过期,则返回保存的 URI,否则引发 NotPresent 异常。

返回类型:

str

classmethod save_variable(key, value)[source]

将该键的值保存在缓存中,如果缓存已初始化的话。

classmethod save_connection_uri(conn_id, uri)[source]

将该连接的 URI 表示形式保存在缓存中,如果缓存已初始化的话。

classmethod invalidate_variable(key)[source]

使该 Variable 在缓存中存储的值失效(实际是移除)。

此条目有帮助吗?