· 6 years ago · Feb 02, 2019, 02:40 AM
1import boto3
2import sys
3
4access_key = "..."
5secret_key = "..."
6
7session = boto3.Session(
8 aws_access_key_id=access_key,
9 aws_secret_access_key=secret_key
10)
11
12dynamodb = session.resource('dynamodb')
13
14table_name = "..."
15table = dynamodb.Table(table_name)
16
17response = table.scan()
18while len(response['Items']) > 0:
19 for item in response['Items']:
20 table.delete_item(
21 Key={
22 'p_key': item['p_key']
23 }
24 )
25 response = table.scan()
26
27print (len(response['Items']))