script/stream/recorder_tweetstream.py
changeset 256 2f335337ff64
parent 255 500cd0405c7a
child 260 b97a72ab59a2
equal deleted inserted replaced
255:500cd0405c7a 256:2f335337ff64
   265             try:
   265             try:
   266                 record = lqueue.get_nowait()
   266                 record = lqueue.get_nowait()
   267                 logging.getLogger(record.name).handle(record)
   267                 logging.getLogger(record.name).handle(record)
   268             except Queue.Empty:
   268             except Queue.Empty:
   269                 continue
   269                 continue
       
   270             except IOError:
       
   271                 continue
   270         time.sleep(0.1)
   272         time.sleep(0.1)
   271 
   273 
   272         
   274         
   273 def get_options():
   275 def get_options():
   274     parser = OptionParser()
   276     parser = OptionParser()