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

conn :dataclasses.InitVar[Optional[Union[airflow.models.connection.Connection, AwsConnectionWrapper]]][source]
region_name :Optional[str][source]
botocore_config :Optional[botocore.config.Config][source]
conn_id :Optional[str][source]
conn_type :Optional[str][source]
login :Optional[str][source]
password :Optional[str][source]
extra_config :Dict[str, Any][source]
aws_access_key_id :Optional[str][source]
aws_secret_access_key :Optional[str][source]
aws_session_token :Optional[str][source]
session_kwargs :Dict[str, Any][source]
endpoint_url :Optional[str][source]
role_arn :Optional[str][source]
assume_role_method :Optional[str][source]
assume_role_kwargs :Dict[str, Any][source]
conn_repr()[source]
__post_init__(conn)[source]
property extra_dejson[source]

Compatibility with airflow.models.Connection.extra_dejson property.

__bool__()[source]

Was this entry helpful?