-
Notifications
You must be signed in to change notification settings - Fork 7
Expand file tree
/
Copy pathsample-api-dynamo.py
More file actions
70 lines (53 loc) · 1.71 KB
/
sample-api-dynamo.py
File metadata and controls
70 lines (53 loc) · 1.71 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
from bottle import *
import boto3
@get('/api/version')
def get_data():
return {'success': True}
# Create a new user
@post('/api/newuser')
def create_user():
# Get the JSON from the API request
request_json = request.json
# Get first name and last name from JSON, default to None
first_name = request_json.get('first_name', default=None)
last_name = request_json.get('last_name', default=None)
# Insert the first_name and last_name into a DynamoDB table called my_users
dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('my_users')
table.put_item(
Item={
'first_name': first_name,
'last_name': last_name
}
)
# Return a boolean OK
return {'Success': True}
# Return all users in the table
@get('/api/all_users')
def get_all_users():
# Instantiate a dynamodb connection
dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('my_users')
# Collect all items from the table
response = table.scan()
items = response['Items']
# Return them to the caller
return items
# Delete a user from the table
@delete('api/delete_user')
def delete_user():
# Get the JSON from the API request
request_json = request.json
# Get first name and last name from JSON, default to None
first_name = request_json.get('first_name', default=None)
last_name = request_json.get('last_name', default=None)
# Instantiate a dynamodb connection
dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('my_users')
table.delete_item(
Key={
'first_name': first_name,
'last_name': last_name
}
)
run(host='0.0.0.0', port=8080, reloader=True, debug=True)