in functions/start_comprehend_job/app.py [0:0]
def detect_entities_job(inputS3Uri, outputS3Uri, file, languageCode):
jobIdentifier = 'entities-job-{0}'.format(ntpath.basename(file).replace('.txt', ''))
response = comprehend_cli.start_entities_detection_job(
InputDataConfig={
'S3Uri': '{0}{1}'.format(inputS3Uri, file),
'InputFormat': 'ONE_DOC_PER_FILE'
},
OutputDataConfig={
'S3Uri': outputS3Uri,
},
DataAccessRoleArn= COMPREHEND_SERVICE_ROLE_ARN,
JobName=jobIdentifier,
LanguageCode= languageCode
)
return response['JobId']