airflow.providers.amazon.aws.utils.connection_wrapper

类

AwsConnectionWrapper

AWS 连接包装器类助手。

模块内容

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

Bases: airflow.utils.log.logging_mixin.LoggingMixin

AWS 连接包装器类助手。

用于验证和解析 AWS 连接参数。

conn 引用一个 Airflow 连接对象或 AwsConnectionWrapper

如果设置为 None，则使用默认值。

region_name 的优先级规则

  1. 显式设置（在 Hook 中）region_name。

  2. Airflow 连接额外参数 ‘region_name’。

botocore_config 的优先级规则

  1. 显式设置（在 Hook 中）botocore_config。

  2. 从 Airflow 连接额外参数 ‘botocore_kwargs’ 构建。

  3. 包装器的默认值

conn: dataclasses.InitVar[airflow.models.connection.Connection | AwsConnectionWrapper | _ConnectionMetadata |None][source]
region_name: str | None = None[source]
botocore_config: botocore.config.Config | None = None[source]
verify: bool | str | None = None[source]
conn_id: str | airflow.utils.types.ArgNotSet |None[source]
conn_type: str | None = None[source]
login: str | None = None[source]
password: str | None = None[source]
schema: str | None = None[source]
extra_config: dict[str, Any][source]
aws_access_key_id: str | None = None[source]
aws_secret_access_key: str | None = None[source]
aws_session_token: str | None = None[source]
profile_name: str | None = None[source]
endpoint_url: str | None = None[source]
role_arn: str | None = None[source]
assume_role_method: str | None = None[source]
assume_role_kwargs: dict[str, Any][source]
service_config: dict[str, dict[str, Any]][source]
property conn_repr[source]
get_service_config(service_name)[source]

获取 AWS 服务相关的配置字典。

参数:

service_name (str) – botocore/boto3 服务的名称。

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

实例化后初始化 AwsConnectionWrapper 对象。

classmethod from_connection_metadata(conn_id=None, login=None, password=None, extra=None)[source]

从连接元数据创建配置。

参数:

  • conn_id (str | None) – 自定义连接 ID。

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

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

  • extra (dict[str, Any] | None) – 连接额外元数据。

property extra_dejson[source]

与 airflow.models.Connection.extra_dejson 属性兼容。

property session_kwargs: dict[

传递给 boto3.session.Session 的额外关键字参数。

__bool__()[source]

返回 AwsConnectionWrapper 实例的真值。

这篇文章有帮助吗？