-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathlambda_function.py
More file actions
49 lines (43 loc) · 1.04 KB
/
lambda_function.py
File metadata and controls
49 lines (43 loc) · 1.04 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
import json
import boto3
from datetime import datetime
# Get the service resource
dynamodb = boto3.resource('dynamodb')
def insert_data(log):
now = datetime.now()
log_name = 'LOG-' + str(now)
table = dynamodb.Table('Logs')
table.put_item(
Item={
'Log_Name': log_name,
'Log_Message': log
}
)
def lambda_handler(event, context):
# Need to make sure it saves data to Dynamo
# POST the following in body as JSON:
'''
{
"log": {
"source": "Bitebody.xyz API",
"date": "2020-02-19T05:02:57+0000",
"action": "/user/all",
"ip-address": "192.168.0.1"
}
}
'''
logged = {}
try:
data = json.loads(event['body'])
insert_data(data['log'])
logged['logged'] = data['log']
return {
'statusCode': 200,
'body': json.dumps(logged)
}
except Exception as e:
logged['error'] = str(e)
return {
'statusCode': 400,
'body': json.dumps(logged)
}