in gremlin/neptune-streams/lambda/neptune-streams-demo/neptune_stream_handler.py [0:0]
def handle_event(self, op, data):
type = data['type']
if op == ADD_OPERATION:
if type == 'vl':
self.__increment_vertex_count()
if type == 'e':
self.__update_degree_centrality(data['to'])
if op == REMOVE_OPERATION:
if type == 'vl':
self.__decrement_vertex_count()
if type == 'e':
self.__update_degree_centrality(data['to'])