in src/s3batchproc.py [0:0]
def processRequest(request):
output = ""
print("request: {}".format(request))
bucketName = request["bucketName"]
objectName = request["objectName"]
documentsTable = request["documentsTable"]
outputTable = request["outputTable"]
jobId = request["jobId"]
invocationId = request['invocationId']
invocationSchemaVersion = request['invocationSchemaVersion']
taskId = request['taskId']
print("Input Object: {}/{}".format(bucketName, objectName))
ext = FileHelper.getFileExtenstion(objectName.lower())
print("Extension: {}".format(ext))
if(ext and ext in ["jpg", "jpeg", "png", "pdf"]):
documentId = str(uuid.uuid1())
ds = datastore.DocumentStore(documentsTable, outputTable)
ds.createDocument(documentId, bucketName, objectName)
output = "Saved document {} for {}/{}".format(documentId, bucketName, objectName)
print(output)
results = [{
'taskId': taskId,
'resultCode': 'Succeeded',
'resultString': "Document submitted for processing with Id: {}".format(documentId)
}]
return {
'invocationSchemaVersion': invocationSchemaVersion,
'treatMissingKeysAs': 'PermanentFailure',
'invocationId': invocationId,
'results': results
}