Loading transfer_service/log_listener.py +20 −5 Original line number Diff line number Diff line Loading @@ -29,8 +29,23 @@ class LogListener(Process): os.remove(self.logFilePath) while True: time.sleep(1) while self.redisCli.llen(self.logQueue) > 0: try: queueLen = self.redisCli.llen(self.logQueue) except Exception: queueLen = 0 raise while queueLen > 0: try: lfp = open(self.logFilePath, 'a') except IOError: raise else: try: logRecord = self.redisCli.brpop(self.logQueue)[1].decode("utf-8") except Exception: raise else: lfp.write(logRecord + '\n') queueLen -= 1 finally: lfp.close() Loading
transfer_service/log_listener.py +20 −5 Original line number Diff line number Diff line Loading @@ -29,8 +29,23 @@ class LogListener(Process): os.remove(self.logFilePath) while True: time.sleep(1) while self.redisCli.llen(self.logQueue) > 0: try: queueLen = self.redisCli.llen(self.logQueue) except Exception: queueLen = 0 raise while queueLen > 0: try: lfp = open(self.logFilePath, 'a') except IOError: raise else: try: logRecord = self.redisCli.brpop(self.logQueue)[1].decode("utf-8") except Exception: raise else: lfp.write(logRecord + '\n') queueLen -= 1 finally: lfp.close()