

def index(self, event, index_name=None):
    event_id = uuid.uuid4().hex
    body = self.prepare_object(event.body)
    body.update({
        'type': event.evt_type,
        'source': event.source,
        'logged_at': datetime.utcnow(),
    })
    self.es.index(index=(index_name or self.index_name), doc_type='event', id=event_id, body=body)

dataset/ETHPy150Open deliveryhero/lymph/lymph/utils/event_indexing.py EventIndex.index/original