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 專案是否匹配指定的屬性值。