| |
| |
| :mod:`airflow.contrib.hooks.aws_dynamodb_hook` |
| ============================================== |
| |
| .. py:module:: airflow.contrib.hooks.aws_dynamodb_hook |
| |
| |
| |
| |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| |
| |
| |
| |
| |
| .. py:class:: AwsDynamoDBHook(table_keys=None, table_name=None, region_name=None, *args, **kwargs) |
| |
| Bases::class:`airflow.contrib.hooks.aws_hook.AwsHook` |
| |
| |
| |
| Interact with AWS DynamoDB. |
| |
| :param table_keys: partition key and sort key |
| :type table_keys: list |
| :param table_name: target DynamoDB table |
| :type table_name: str |
| :param region_name: aws region name (example: us-east-1) |
| :type region_name: str |
| |
| |
| |
| |
| |
| |
| |
| |
| .. method:: get_conn(self) |
| |
| |
| |
| |
| |
| |
| |
| .. method:: write_batch_data(self, items) |
| |
| |
| Write batch items to dynamodb table with provisioned throughout capacity. |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
