airflow.providers.amazon.aws.utils.mixins¶

此模块包含供 Amazon 提供程序内部使用的不同 mixin 类。

警告

仅供内部使用，此模块及所有类可能在未来被更改、重命名或移除，恕不另行通知。

meta：: 私有

属性¶

AwsHookType

类¶

`AwsHookParams`	默认的 AWS Hook 参数存储类。
`AwsBaseHookMixin`	用于 AWS 操作符、传感器等的 Mixin 类。

函数¶

aws_template_fields(*template_fields)

合并提供的 template_fields 与通用字段，并按字母顺序返回。

模块内容¶

airflow.providers.amazon.aws.utils.mixins.AwsHookType[source]¶

class airflow.providers.amazon.aws.utils.mixins.AwsHookParams[source]¶

Bases: NamedTuple

默认的 AWS Hook 参数存储类。

aws_conn_id: str | None[source]¶

region_name: str | None[source]¶

verify: bool | str | None[source]¶

botocore_config: dict[str, Any] | None[source]¶

classmethod from_constructor(aws_conn_id, region_name, verify, botocore_config, additional_params)[source]¶

在类构造函数中解析通用的 AWS Hook 参数。

示例

class AwsFooBarOperator(BaseOperator):
    def __init__(
        self,
        *,
        aws_conn_id: str | None = "aws_default",
        region_name: str | None = None,
        verify: bool | str | None = None,
        botocore_config: dict | None = None,
        foo: str = "bar",
        **kwargs,
    ):
        params = AwsHookParams.from_constructor(
            aws_conn_id, region_name, verify, botocore_config, additional_params=kwargs
        )
        super().__init__(**kwargs)
        self.aws_conn_id = params.aws_conn_id
        self.region_name = params.region_name
        self.verify = params.verify
        self.botocore_config = params.botocore_config
        self.foo = foo

class airflow.providers.amazon.aws.utils.mixins.AwsBaseHookMixin[source]¶

Bases: Generic[AwsHookType]

用于 AWS 操作符、传感器等的 Mixin 类。

警告

仅供内部使用，未来此类可能会在未另行通知的情况下更改、重命名或移除。

aws_hook_class: type[AwsHookType][source]¶

aws_conn_id: str | None[source]¶

region_name: str | None[source]¶

verify: bool | str | None[source]¶

botocore_config: dict[str, Any] | None[source]¶

validate_attributes()[source]¶: 验证类属性。

property hook: AwsHookType[source]¶

基于 `aws_hook_class` 返回 AWS Provider 的 hook。

该方法实现应视为围绕 boto3 的轻量包装 Hook 的最终实现。对于厚包装 Hook，开发者应考虑重写 `_hook_parameters` 方法。

airflow.providers.amazon.aws.utils.mixins.aws_template_fields(*template_fields)[source]¶

合并提供的 template_fields 与通用字段，并按字母顺序返回。