code: def count_events():
      
      # wait loop
      while 1:
          # sleep and let the queue build up
          gevent.sleep(FLUSH_INTERVAL)
  
          # init the data points containers
          events = Counter()
          additional = {}
  
          # flush the queue
          while 1:
              try:
                  site, content_id, event, path = EVENTS_QUEUE.get_nowait()
                  events[(site, content_id)] += 1
                  if event and path:
                      additional[(site, content_id)] = (event, path)
              except queue.Empty:
                  break
              except Exception as e:
                  LOGGER.exception(e)
                  break
  
          # after tabulating, spawn a new thread to send the data to influxdb
          if len(events):
              gevent.spawn(send_point_data, events, additional)
              gevent.spawn(send_trending_data, events)
docs: pulls data from the queue, tabulates it and spawns a send event