airflow.providers.amazon.aws.sensors.dynamodb¶

类¶

DynamoDBValueSensor

等待 DynamoDB 表中某个项目的属性值出现。

模块内容¶

class airflow.providers.amazon.aws.sensors.dynamodb.DynamoDBValueSensor(table_name, partition_key_name, partition_key_value, attribute_name, attribute_value, sort_key_name=None, sort_key_value=None, **kwargs)[源码]¶

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.dynamodb.DynamoDBHook]

等待 DynamoDB 表中某个项目的属性值出现。

另请参阅

有关如何使用此 Sensor 的更多信息，请参阅指南：等待 Amazon DynamoDB 项目属性值匹配

参数：

table_name (str) – DynamoDB 表名
partition_key_name (str) – DynamoDB 分区键名
partition_key_value (str) – DynamoDB 分区键值
attribute_name (str) – DynamoDB 属性名
attribute_value (str | collections.abc.Iterable[str]) – DynamoDB 属性值
sort_key_name (str | None) – (可选) DynamoDB 排序键名
sort_key_value (str | None) – (可选) DynamoDB 排序键值
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此值为 None 或为空，则使用 boto3 的默认行为。如果以分布式方式运行 Airflow 且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。
region_name – AWS 区域名称。如果未指定，则使用 boto3 的默认行为。
verify – 是否验证 SSL 证书。参见：https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客户端的配置字典（键值对）。参见：https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[源码]¶

template_fields: collections.abc.Sequence[str][源码]¶

table_name[源码]¶

partition_key_name[源码]¶

partition_key_value[源码]¶

attribute_name[源码]¶

attribute_value[源码]¶

sort_key_name = None[源码]¶

sort_key_value = None[源码]¶

poke(context)[源码]¶

测试 DynamoDB 项目是否匹配指定的属性值。