airflow.secrets.local_filesystem¶

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

属性¶

`log`
`FILE_PARSERS`

从本地文件检索 Connection 对象和 Variable。

`get_connection_parameter_names`()	返回 `airflow.models.connection.Connection` 构造函数参数。
`load_variables`(file_path)	从文本文件加载变量。
`load_connections_dict`(file_path)	从文本文件加载连接。

airflow.secrets.local_filesystem.get_connection_parameter_names()[source]¶

airflow.secrets.local_filesystem.load_variables(file_path)[source]¶

从文本文件加载变量。

支持 JSON, YAML 和 .env 文件。

airflow.secrets.local_filesystem.load_connections_dict(file_path)[source]¶

从文本文件加载连接。

支持 JSON, YAML 和 .env 文件。

类 airflow.secrets.local_filesystem.LocalFilesystemBackend(variables_file_path=None, connections_file_path=None)[source]¶

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

从本地文件检索 Connection 对象和 Variable。

支持 JSON, YAML 和 .env 文件。

参数:

get_connection(conn_id)[source]¶

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

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

get_variable(key)[source]¶

返回 Airflow Variable 的值。