def processRecord()

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)