def lambda_handler()

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