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.")