airflow.models.connection

Module Contents

airflow.models.connection.parse_netloc_to_hostname(*args, **kwargs)[source]
This method is deprecated.
airflow.models.connection._parse_netloc_to_hostname(uri_parts)[source]
Parse a URI string to get correct Hostname.
class airflow.models.connection.Connection(conn_id: Optional[str] = None, conn_type: Optional[str] = None, description: Optional[str] = None, host: Optional[str] = None, login: Optional[str] = None, password: Optional[str] = None, schema: Optional[str] = None, port: Optional[int] = None, extra: Optional[Union[str, dict]] = None, uri: Optional[str] = None)[source]

Bases: airflow.models.base.Base, airflow.utils.log.logging_mixin.LoggingMixin

Placeholder to store information about different database instances connection information. The idea here is that scripts use references to database instances (conn_id) instead of hard coding hostname, logins and passwords when using operators or hooks.

See also

For more information on how to use this class, see: Managing Connections

Parameters

  • conn_id (str) -- The connection ID.

  • conn_type (str) -- The connection type.

  • description (str) -- The connection description.

  • host (str) -- The host.

  • login (str) -- The login.

  • password (str) -- The password.

  • schema (str) -- The schema.

  • port (int) -- The port number.

  • extra (str) -- Extra metadata. Non-standard data such as private/SSH keys can be saved here. JSON encoded object.

  • uri (str) -- URI address describing connection parameters.

EXTRA_KEY = __extra__[source]
__tablename__ = connection[source]
id[source]
conn_id[source]
conn_type[source]
description[source]
host[source]
schema[source]
login[source]
_password[source]
port[source]
is_encrypted[source]
is_extra_encrypted[source]
_extra[source]
password[source]

Password. The value is decrypted/encrypted when reading/setting the value.

extra[source]

Extra data. The value is decrypted/encrypted when reading/setting the value.

extra_dejson[source]

Returns the extra property by deserializing json.

on_db_load(self)[source]
parse_from_uri(self, **uri)[source]

This method is deprecated. Please use uri parameter in constructor.

_parse_from_uri(self, uri: str)[source]
get_uri(self)[source]

Return connection in URI format

get_password(self)[source]

Return encrypted password.

set_password(self, value: Optional[str])[source]

Encrypt password and set in object attribute.

get_extra(self)[source]

Return encrypted extra-data.

set_extra(self, value: str)[source]

Encrypt extra-data and save in object attribute to object.

rotate_fernet_key(self)[source]

Encrypts data with a new key. See: Fernet

get_hook(self)[source]

Return hook based on conn_type.

__repr__(self)[source]
log_info(self)[source]

This method is deprecated. You can read each field individually or use the default representation (__repr__).

debug_info(self)[source]

This method is deprecated. You can read each field individually or use the default representation (__repr__).

classmethod get_connection_from_secrets(cls, conn_id: str)[source]

Get connection by conn_id.

Parameters

conn_id -- connection id

Returns

connection

Was this entry helpful?