airflow.providers.amazon.aws.sensors.dynamodb

Module Contents

Classes

DynamoDBValueSensor

Waits for an attribute value to be present for an item in a DynamoDB table.
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, aws_conn_id=DynamoDBHook.default_conn_name, region_name=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for an attribute value to be present for an item in a DynamoDB table.

Parameters

  • partition_key_name (str) – DynamoDB partition key name

  • partition_key_value (str) – DynamoDB partition key value

  • attribute_name (str) – DynamoDB attribute name

  • attribute_value (str) – DynamoDB attribute value

  • sort_key_name (str | None) – (optional) DynamoDB sort key name

  • sort_key_value (str | None) – (optional) DynamoDB sort key value

poke(context)[source]

Test DynamoDB item for matching attribute value

hook()[source]

Create and return a DynamoDBHook

Was this entry helpful?