airflow.secrets.local_filesystem

与从本地文件检索连接和变量相关的对象。

模块内容

LocalFilesystemBackend

从本地文件检索连接对象和变量。

函数

get_connection_parameter_names()

返回 airflow.models.connection.Connection 构造函数参数。

load_variables(file_path)

从文本文件加载变量。

load_connections(file_path)

使用 airflow.secrets.local_filesystem.load_connections_dict,此方法已弃用。

load_connections_dict(file_path)

从文本文件加载连接。

属性

log

FILE_PARSERS

airflow.secrets.local_filesystem.log[来源]
airflow.secrets.local_filesystem.get_connection_parameter_names()[来源]

返回 airflow.models.connection.Connection 构造函数参数。

airflow.secrets.local_filesystem.FILE_PARSERS[来源]
airflow.secrets.local_filesystem.load_variables(file_path)[来源]

从文本文件加载变量。

支持 JSONYAML.env 文件。

参数

file_path (str) – 将被处理的文件的位置。

airflow.secrets.local_filesystem.load_connections(file_path)[来源]

使用 airflow.secrets.local_filesystem.load_connections_dict,此方法已弃用。

airflow.secrets.local_filesystem.load_connections_dict(file_path)[来源]

从文本文件加载连接。

支持 JSONYAML.env 文件。

返回

一个字典,其中键包含连接 ID,值包含连接。

返回类型

dict[str, Any]

class airflow.secrets.local_filesystem.LocalFilesystemBackend(variables_file_path=None, connections_file_path=None)[来源]

基类:airflow.secrets.base_secrets.BaseSecretsBackend, airflow.utils.log.logging_mixin.LoggingMixin

从本地文件检索连接对象和变量。

支持 JSONYAML.env 文件。

参数
  • variables_file_path (str | None) – 包含变量数据的文件位置。

  • connections_file_path (str | None) – 包含连接数据的文件位置。

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

get_variable(key)[来源]

返回 Airflow 变量的值。

参数

key (str) – 变量键

返回

变量值

返回类型

str | None

此条目是否有帮助?