indexer.py

def handler(event, context):
    for record in event['Records']:
        try:
            response = S3_CLIENT.get_object(Bucket=bucket, Key=key)
            eventname = record['eventName']
            bucket = unquote(record['s3']['bucket']['name'])
            if eventname == 'ObjectRemoved:Delete':
                event_type = 'Delete'
                post_to_es(event_type, 0, '', key, {})
                continue
            elif eventname == 'ObjectCreated:Put':
                event_type = 'Create'
            key = unquote(record['s3']['object']['key'])
            
            if key.endswith('.ipynb') and config['ipynb']:
                try:
                    notebook = response['Body'].read().decode('utf-8')
                    text = extract_text(notebook)
                    
            post_to_es(event_type, size, text, key, meta, version_id)