airflow.secrets.local_filesystem

Objects relating to retrieving connections and variables from local file

Module Contents

airflow.secrets.local_filesystem.log[source]
airflow.secrets.local_filesystem.get_connection_parameter_names() → Set[str][source]
Returns :class:`airflow.models.connection.Connection` constructor parameters.
airflow.secrets.local_filesystem.FILE_PARSERS[source]
airflow.secrets.local_filesystem.load_variables(file_path: str) → Dict[str, str][source]
Load variables from a text file.

JSON, YAML and .env files are supported.

Parameters

file_path (str) -- The location of the file that will be processed.

Return type

Dict[str, List[str]]

airflow.secrets.local_filesystem.load_connections(file_path) → Dict[str, List[Any]][source]
This function is deprecated. Please use `airflow.secrets.local_filesystem.load_connections_dict`.",
airflow.secrets.local_filesystem.load_connections_dict(file_path: str) → Dict[str, Any][source]
Load connection from text file.

JSON, YAML and .env files are supported.

Returns

A dictionary where the key contains a connection ID and the value contains the connection.

Return type

Dict[str, airflow.models.connection.Connection]

class airflow.secrets.local_filesystem.LocalFilesystemBackend(variables_file_path: Optional[str] = None, connections_file_path: Optional[str] = None)[source]

Bases: airflow.secrets.base_secrets.BaseSecretsBackend, airflow.utils.log.logging_mixin.LoggingMixin

Retrieves Connection objects and Variables from local files

JSON, YAML and .env files are supported.

Parameters

  • variables_file_path (str) -- File location with variables data.

  • connections_file_path (str) -- File location with connection data.

get_connection(self, conn_id: str)[source]
get_connections(self, conn_id: str)[source]
get_variable(self, key: str)[source]

Was this entry helpful?