def lambda_handler()

in code/document_registrar/document_registrar.py [0:0]


def lambda_handler(event, context):

    print("event: {}".format(event))
    for record in event['Records']:
        if 'eventSource' in record and record['eventSource'] == 'aws:s3':
            bucketName = record['s3']['bucket']['name']
            documentName = urllib.parse.unquote_plus(record['s3']['object']['key'])
            documentVersion = record['s3']['object'].get('versionId', None)
            principalIAMWriter = record['userIdentity']['principalId']
            eventName = record['eventName']
            if eventName == "ObjectRemoved:Delete":
                processDeleteRequest(bucketName, documentName, documentVersion, principalIAMWriter, eventName)
            elif eventName.startswith("ObjectCreated"):
                processCreateRequest(bucketName, documentName, documentVersion, principalIAMWriter, eventName)
            else:
                print("Processing not yet implemented")
        else:
            print("Uninvoked recorded event structure.")