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.