def parser_sqs_message()

in lambda_recognize_crowd/lambda_function.py [0:0]


def parser_sqs_message(event):
    dict_event_parsed = {}
    try:
        body = event["Records"][0]["body"]
        body = body.replace("'", '"')
        body_json = json.loads(body)

        body_sqs = body_json["Records"][0]["s3"]

        dict_event_parsed['Bucket'] = body_sqs["bucket"].get("name")
        dict_event_parsed['Object'] = body_sqs["object"].get("key")

        return dict_event_parsed
    except Exception as e:
        raise e