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 合併，並按字母順序返回。