Transfers the all the entries from one DynamoDB table to another

transfer_ddb.py

from boto3 import resource


OLD_TABLE = ''
NEW_TABLE = ''
OLD_REGION = ''
NEW_REGION = ''


def put_new_items(response, newTable):

    items = response['Items']

    with newTable.batch_writer() as batch:
        for item in items:
            batch.put_item(Item=item)

    return len(items)


if __name__ == '__main__':

    ddbOld = resource('dynamodb', region_name=OLD_REGION)
    ddbNew = resource('dynamodb', region_name=NEW_REGION)

    oldTable = ddbOld.Table(OLD_TABLE)
    newTable = ddbNew.Table(NEW_TABLE)

    count = 0

    response = oldTable.scan()
    count += put_new_items(response, newTable)

    while 'LastEvaluatedKey' in response:

        response = oldTable.scan(ExclusiveStartKey=response['LastEvaluatedKey'])
        count += put_new_items(response, newTable)

        print(count)