Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def lambda_handler(event, context):
- operations = {
- 'DELETE': lambda dynamo, x: dynamo.delete_item(**x),
- 'POST': lambda dynamo, x: dynamo.put_item(**x),
- 'PUT': lambda dynamo, x: dynamo.update_item(**x),
- 'GET': lambda dynamo, x: dynamo.get_item(**x),
- 'GET_ALL': lambda dynamo, x: dynamo.scan(**x),
- }
- for record in event['Records']:
- payload = loads(record['body'], parse_float=str)
- operation = record['messageAttributes']['Method']['stringValue']
- if operation in operations:
- try:
- operations[operation](dynamo_client, payload)
- except Exception as e:
- logger.error(e)
- else:
- logger.error('Unsupported method \'{}\''.format(operation))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement