airflow.providers.amazon.aws.sensors.base_aws¶
类¶
用于在 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
- 参数:
aws_conn_id (str | None) – 用于 AWS 凭证的 Airflow 连接。如果此参数为 None 或为空,则使用 boto3 的默认行为。如果以分布式方式运行 Airflow 并且 aws_conn_id 为 None 或为空,则将使用默认的 boto3 配置(并且必须在每个工作节点上维护此配置)。
region_name (str | None) – AWS 区域名称。如果未指定,则使用 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][source]¶