airflow.secrets.base_secrets

模块内容

BaseSecretsBackend

抽象基类,用于检索给定 conn_id 的 Connection 对象或给定 key 的 Variable。

class airflow.secrets.base_secrets.BaseSecretsBackend[源代码]

基类: abc.ABC

抽象基类,用于检索给定 conn_id 的 Connection 对象或给定 key 的 Variable。

static build_path(path_prefix, secret_id, sep='/')[源代码]

给定 conn_id,为密钥后端构建路径。

参数
  • path_prefix (str) – 获取密钥的路径前缀

  • secret_id (str) – 密钥 ID

  • sep (str) – 用于连接 connections_prefix 和 conn_id 的分隔符。默认值:“/”

abstract get_conn_value(conn_id)[源代码]

从密钥后端检索表示 Connection 对象的字符串值。

如果您的密钥后端使用的客户端已经返回 python 字典,您应该重写 get_connection

参数

conn_id (str) – 连接 ID

deserialize_connection(conn_id, value)[源代码]

给定 airflow Connection 的序列化表示,返回一个实例。

查看第一个字符以确定如何反序列化。

参数
  • conn_id (str) – 连接 ID

  • value (str) – Connection 对象的序列化表示

返回

反序列化的 Connection

返回类型

airflow.models.connection.Connection

abstract get_conn_uri(conn_id)[源代码]

从密钥后端获取 conn_uri。

此方法已弃用,将在未来的版本中删除;请改为实现 get_conn_value

参数

conn_id (str) – 连接 ID

get_connection(conn_id)[源代码]

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

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

参数

conn_id (str) – 连接 ID

get_connections(conn_id)[源代码]

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

参数

conn_id (str) – 连接 ID

abstract get_variable(key)[源代码]

返回 Airflow Variable 的值。

参数

key (str) – Variable Key

返回

Variable 值

返回类型

str | None

get_config(key)[源代码]

返回 Airflow Config Key 的值。

参数

key (str) – Config Key

返回

配置值

返回类型

str | None

此条目是否有帮助?