def parser_sqs_message()

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