airflow.providers.amazon.aws.utils.connection_wrapper

Module Contents

Classes

AwsConnectionWrapper

AWS Connection Wrapper class helper.
class airflow.providers.amazon.aws.utils.connection_wrapper.AwsConnectionWrapper(context=None)[source]

Bases: airflow.utils.log.logging_mixin.LoggingMixin

AWS Connection Wrapper class helper. Use for validate and resolve AWS Connection parameters.

conn reference to Airflow Connection object or AwsConnectionWrapper

if it set to None than default values would use.

The precedence rules for region_name

  1. Explicit set (in Hook) region_name.

  2. Airflow Connection Extra ‘region_name’.

The precedence rules for botocore_config

  1. Explicit set (in Hook) botocore_config.

  2. Construct from Airflow Connection Extra ‘botocore_kwargs’.

  3. The wrapper’s default value

property extra_dejson[source]

Compatibility with airflow.models.Connection.extra_dejson property.

property session_kwargs: dict[str, Any][source]

Additional kwargs passed to boto3.session.Session.

conn: dataclasses.InitVar[Connection | AwsConnectionWrapper | _ConnectionMetadata | None][source]
region_name: str | None[source]
botocore_config: Config | None[source]
verify: bool | str | None[source]
conn_id: str | ArgNotSet | None[source]
conn_type: str | None[source]
login: str | None[source]
password: str | None[source]
schema: str | None[source]
extra_config: dict[str, Any][source]
aws_access_key_id: str | None[source]
aws_secret_access_key: str | None[source]
aws_session_token: str | None[source]
profile_name: str | None[source]
endpoint_url: str | None[source]
role_arn: str | None[source]
assume_role_method: str | None[source]
assume_role_kwargs: dict[str, Any][source]
conn_repr()[source]
get_service_config(service_name)[source]
__post_init__(conn)[source]
classmethod from_connection_metadata(conn_id=None, login=None, password=None, extra=None)[source]

Create config from connection metadata.

Parameters

  • conn_id (str | None) – Custom connection ID.

  • login (str | None) – AWS Access Key ID.

  • password (str | None) – AWS Secret Access Key.

  • extra (dict[str, Any] | None) – Connection Extra metadata.

__bool__()[source]

Was this entry helpful?