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]
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?