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 references an 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[airflow.models.connection.Connection | AwsConnectionWrapper | _ConnectionMetadata | None][source]
region_name: str | None[source]
botocore_config: botocore.config.Config | None[source]
verify: bool | str | None[source]
conn_id: str | airflow.utils.types.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]
service_config: dict[str, dict[str, Any]][source]
conn_repr()[source]
get_service_config(service_name)[source]

Get AWS Service related config dictionary.

Parameters

service_name (str) – Name of botocore/boto3 service.

get_service_endpoint_url(service_name, *, sts_connection_assume=False, sts_test_connection=False)[source]
__post_init__(conn)[source]

Initialize the AwsConnectionWrapper object after instantiation.

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]

Return the truth value of the AwsConnectionWrapper instance.

Was this entry helpful?