def lambda_handler()

in translate_captions/translate_job_event_handler.py [0:0]


def lambda_handler(event, context):
    logger.setLevel(logging.DEBUG)
    logger.info("event: {}".format(event))
    request = {}
    statusCode = "200"
    message ="success"
    request["delete_captionsin"] = os.environ["DELETE_INTERMEDIATE_FILES"]
    try:
        message = json.loads(event['Records'][0]['Sns']['Message'])
        request["s3uri"] =  message['S3OutputLocation']
        request["jobId"] = message['JobId']
        request["jobName"] = message['JobName']
        status = message['JobStatus']
        request["langCode"] = message['langCode'][0]
        request["accountId"] = context.invoked_function_arn.split(":")[4]
        if status == "COMPLETED" :
            processRequest(request)
        elif status in ["FAILED", "COMPLETED_WITH_ERROR"]:
            statusCode ="500"
            message = "Translation Job failed"
            logger.warn("Job ID {} failed or completed with errors, exiting".format(request["jobId"]))
    except ValueError:
        statusCode ="500"
        message = "Error converting the XML document"
        logger.error("Error occured loading the json from event:{}".format(event))
    return {
            "statusCode": statusCode,
            "body": json.dumps(message)
        }