import requests import time

def call_ISS_API(): print("Calling ISS") time.sleep(1) r = requests.get('http://api.open-notify.org/iss-now.json') json = r.json() json['latitude'] = json['iss_position']['latitude'] json['longitude'] = json['iss_position']['longitude'] del json['iss_position'] del json['message'] return json

api_calls = {}

for i in range(5):
response = call_ISS_API() api_calls[response['timestamp']] = response

#%% import boto3

replace the keys below

client = boto3.client( 'dynamodb', aws_access_key_id='', aws_secret_access_key='**********', region_name = 'us-east-1', )

dynamodb = boto3.resource( 'dynamodb', aws_access_key_id='', aws_secret_access_key='**********', region_name = 'us-east-1' )

ddb_exceptions = client.exceptions

#%%

try: table = client.create_table( TableName='ISS_locations', KeySchema=[ { 'AttributeName': 'timestamp', 'KeyType': 'HASH' } ], AttributeDefinitions=[ { 'AttributeName': 'timestamp', 'AttributeType': 'N' }

    ],
    ProvisionedThroughput={
        'ReadCapacityUnits': 10,
        'WriteCapacityUnits': 10
    }
)

print("Creating table")
waiter = client.get_waiter('table_exists')
waiter.wait(TableName='ISS_locations')
print("Table created")

except ddb_exceptions.ResourceInUseException: print("Table exists")

#%%

print("Putting items") for response in api_calls: dynamodb.Table('ISS_locations').put_item( Item=api_calls[response] )

#%%

print("Scanning table") response = dynamodb.Table('ISS_locations').scan()

for i in response['Items']: print(i) #%%

print("Query table") from boto3.dynamodb.conditions import Key

k = api_calls[list(api_calls)[0]]['timestamp']

response = dynamodb.Table('ISS_locations').query( KeyConditionExpression=Key('timestamp').eq(k) )

for i in response['Items']: print(i)

#%% print("Remove item")

k = api_calls[list(api_calls)[1]]['timestamp']

response = dynamodb.Table('ISS_locations').delete_item( Key={'timestamp':k} )

print("Scanning table") response = dynamodb.Table('ISS_locations').scan()

for i in response['Items']: print(i)

#%%

print("Deleting Table") client.delete_table(TableName='ISS_locations') waiter = client.get_waiter('table_not_exists') waiter.wait(TableName='ISS_locations') print("Table deleted")