in translate_json/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_xmls"] = os.environ["DELETE_XMLS"]
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)
}