airflow.providers.amazon.aws.sensors.base_aws

AwsBaseSensor

用于在 AWS Hooks 之上构建传感器的基础 AWS (Amazon) 传感器类。

模块内容

class airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor(*, aws_conn_id='aws_default', region_name=None, verify=None, botocore_config=None, region=NOTSET, **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator, airflow.providers.amazon.aws.utils.mixins.AwsBaseHookMixin[airflow.providers.amazon.aws.utils.mixins.AwsHookType]

用于在 AWS Hooks 之上构建传感器的基础 AWS (Amazon) 传感器类。

警告

仅供内部使用,此类将来可能会更改、重命名或删除,恕不另行通知。

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


class AwsFooBarSensor(AwsBaseSensor[FooBarThinHook]):
    aws_hook_class = FooBarThinHook

    def poke(self, context):
        pass


class AwsFooBarSensor(AwsBaseSensor[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 poke(self, context):
        pass
参数
template_fields: collections.abc.Sequence[str][source]
aws_conn_id[source]
region_name[source]
verify[source]
botocore_config[source]

此条目有帮助吗?