in code/extension_detector/extension_detector.py [0:0]
def processRecord(record, syncBucketName, asyncBucketName, callerId):
newImage = record["dynamodb"]["NewImage"]
documentId = None
bucketName = None
objectName = None
if("documentId" in newImage and "S" in newImage["documentId"]):
documentId = newImage["documentId"]["S"]
if("bucketName" in newImage and "S" in newImage["bucketName"]):
bucketName = newImage["bucketName"]["S"]
if("objectName" in newImage and "S" in newImage["objectName"]):
objectName = newImage["objectName"]["S"]
print("DocumentId: {}, BucketName: {}, ObjectName: {}".format(documentId, bucketName, objectName))
if(documentId and bucketName and objectName):
processRequest(documentId, bucketName, objectName, callerId)