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

本模块包含供 Amazon 提供者内部使用的不同 mixin 类。

警告

仅供内部使用，本模块及所有类将来可能会更改、重命名或删除，恕不另行通知。

meta:: 私有

属性¶

AwsHookType

类¶

`AwsHookParams`	默认 Aws Hook 参数存储类。
`AwsBaseHookMixin`	AWS Operators、Sensors 等的 Mixin 类。

函数¶

aws_template_fields(*template_fields)

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

模块内容¶

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

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

基类: 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 Hooks 参数。

示例

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

基类: Generic[AwsHookType]

AWS Operators、Sensors 等的 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 的薄封装 Hooks，此方法实现应视为最终实现。对于厚封装 Hooks，开发者应考虑重写 _hook_parameters 方法。

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

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