Airflow 峰會 2025 將於 10 月 07-09 日舉行。立即註冊獲取早鳥票!

airflow.secrets.base_secrets

BaseSecretsBackend

給定 conn_id 時檢索 Connection 物件,或給定 key 時檢索 Variable 的抽象基類。

模組內容

class airflow.secrets.base_secrets.BaseSecretsBackend[source]

Bases: abc.ABC

給定 conn_id 時檢索 Connection 物件,或給定 key 時檢索 Variable 的抽象基類。

static build_path(path_prefix, secret_id, sep='/')[source]

給定 conn_id,為 Secrets 後端構建路徑。

引數:
  • path_prefix (str) – 獲取金鑰的路徑字首

  • secret_id (str) – 金鑰 ID

  • sep (str) – 用於連線 connections_prefix 和 conn_id 的分隔符。預設值:“/”

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 的序列化表示,返回一個例項。

檢視第一個字元以確定如何反序列化。

引數:
  • conn_id (str) – 連線 ID

  • value (str) – Connection 物件的序列化表示

返回:

反序列化的 Connection

返回型別:

airflow.models.connection.Connection

get_connection(conn_id)[source]

返回給定 conn_id 的 connection 物件。

首先嚐試 get_conn_value,如果未實現,則嘗試 get_conn_uri

引數:

conn_id (str) – 連線 ID

abstract get_variable(key)[source]

返回 Airflow Variable 的值。

引數:

key (str) – Variable 鍵

返回:

Variable 值

返回型別:

str | None

get_config(key)[source]

返回 Airflow 配置鍵的值。

引數:

key (str) – 配置鍵

返回:

配置值

返回型別:

str | None

此條目有幫助嗎?