airflow.providers.amazon.aws.utils.connection_wrapper

模块内容

类

AwsConnectionWrapper

AWS 连接包装器类助手。
class airflow.providers.amazon.aws.utils.connection_wrapper.AwsConnectionWrapper(context=None)[源代码]

基类：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. 包装器的默认值

property extra_dejson[源代码]

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

property session_kwargs: dict[str, Any][源代码]

传递给 boto3.session.Session 的其他 kwargs。

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

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

参数

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

get_service_endpoint_url(service_name, *, sts_connection_assume=False, sts_test_connection=False)[源代码]
__post_init__(conn)[源代码]

在实例化后初始化 AwsConnectionWrapper 对象。

classmethod from_connection_metadata(conn_id=None, login=None, password=None, extra=None)[源代码]

从连接元数据创建配置。

参数

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

  • login (str | None) – AWS 访问密钥 ID。

  • password (str | None) – AWS 秘密访问密钥。

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

__bool__()[源代码]

返回 AwsConnectionWrapper 实例的真值。

此条目是否有帮助？