in functions/start_comprehend_job/app.py [0:0]
def lambda_handler(event, context):
jsonStateMachine = event
#Getting Informations
guid = jsonStateMachine['guid']
s3BucketName = MAIN_BUCKET_NAME
transcriptionText = jsonStateMachine['transcriptionText']['s3ObjectKey']
#S3 URIs
inputS3Uri = "s3://%s/"%(s3BucketName)
outputS3Uri = "s3://%s/comprehendOutputRAW/"%(s3BucketName)
#Get Comprehend Language Code
languageCode = TRANSCRIBE_LANGUAGE_TO_COMPREHEND_LANGUAGE[SOURCE_AUDIO_LANGUAGE]
#Start Async Jobs
jsonStateMachine['comprehend'] = {}
jsonStateMachine['comprehend']['jobIdKeyPhrases'] = detect_keyphrases_job(inputS3Uri, outputS3Uri, transcriptionText, languageCode)
jsonStateMachine['comprehend']['jobIdEntities'] = detect_entities_job(inputS3Uri, outputS3Uri, transcriptionText, languageCode)
return jsonStateMachine