`airflow.contrib.hooks.aws_dynamodb_hook`¶

Module Contents¶

class airflow.contrib.hooks.aws_dynamodb_hook.AwsDynamoDBHook(table_keys=None, table_name=None, region_name=None, *args, **kwargs)[source]¶

Bases: airflow.contrib.hooks.aws_hook.AwsHook

Interact with AWS DynamoDB.

Parameters

table_keys (list) – partition key and sort key
table_name (str) – target DynamoDB table
region_name (str) – aws region name (example: us-east-1)

get_conn(self)[source]¶

write_batch_data(self, items)[source]¶: Write batch items to dynamodb table with provisioned throughout capacity.