airflow.providers.amazon.aws.operators.base_aws¶

類¶

AwsBaseOperator

構建基於 AWS Hooks 的 Operators 的基礎 AWS (Amazon) Operator 類。

模組內容¶

class airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator(*, aws_conn_id='aws_default', region_name=None, verify=None, botocore_config=None, region=NOTSET, **kwargs)[原始碼]¶

基類: airflow.models.BaseOperator, airflow.providers.amazon.aws.utils.mixins.AwsBaseHookMixin[airflow.providers.amazon.aws.utils.mixins.AwsHookType]

構建基於 AWS Hooks 的 Operators 的基礎 AWS (Amazon) Operator 類。

警告

僅供內部使用，此類將來可能會更改、重新命名或刪除，恕不另行通知。

示例

from airflow.providers.amazon.aws.hooks.foo_bar import FooBarThinHook, FooBarThickHook


class AwsFooBarOperator(AwsBaseOperator[FooBarThinHook]):
    aws_hook_class = FooBarThinHook

    def execute(self, context):
        pass


class AwsFooBarOperator2(AwsBaseOperator[FooBarThickHook]):
    aws_hook_class = FooBarThickHook

    def __init__(self, *, spam: str, **kwargs):
        super().__init__(**kwargs)
        self.spam = spam

    @property
    def _hook_parameters(self):
        return {**super()._hook_parameters, "spam": self.spam}

    def execute(self, context):
        pass

引數:

aws_conn_id (str | None) – 用於 AWS 憑據的 Airflow 連線。如果此引數為 None 或為空，則使用預設的 boto3 行為。如果以分散式方式執行 Airflow 且 aws_conn_id 為 None 或為空，則將使用預設的 boto3 配置（並且必須在每個 worker 節點上維護）。
region_name (str | None) – AWS region_name。如果未指定，則使用預設的 boto3 行為。
verify (bool | str | None) – 是否驗證 SSL 證書。參見: https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config (dict | None) – botocore 客戶端的配置字典（鍵值對）。參見: https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

template_fields: collections.abc.Sequence[str][原始碼]¶

aws_conn_id[原始碼]¶

region_name[原始碼]¶

verify[原始碼]¶

botocore_config[原始碼]¶