in lambda-sns-notify/lambda_function.py [0:0]
def parser_sqs_message(event):
parsed_dict = {}
try:
body_json = event
records = body_json["Records"][0]["body"]
records = records.replace("'", '"')
records = json.loads(records)
parsed_dict['Bucket'] = records["Bucket"]
parsed_dict['Object'] = records["Object"]
print(parsed_dict)
return parsed_dict
except Exception as e:
raise e