Advertisement
Guest User

Untitled

a guest
Oct 19th, 2019
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.76 KB | None | 0 0
  1. def lambda_handler(event, context):
  2. operations = {
  3. 'DELETE': lambda dynamo, x: dynamo.delete_item(**x),
  4. 'POST': lambda dynamo, x: dynamo.put_item(**x),
  5. 'PUT': lambda dynamo, x: dynamo.update_item(**x),
  6. 'GET': lambda dynamo, x: dynamo.get_item(**x),
  7. 'GET_ALL': lambda dynamo, x: dynamo.scan(**x),
  8. }
  9.  
  10. for record in event['Records']:
  11. payload = loads(record['body'], parse_float=str)
  12. operation = record['messageAttributes']['Method']['stringValue']
  13. if operation in operations:
  14. try:
  15. operations[operation](dynamo_client, payload)
  16. except Exception as e:
  17. logger.error(e)
  18. else:
  19. logger.error('Unsupported method \'{}\''.format(operation))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement