log.py 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. # coding:utf-8
  2. import os
  3. import logging
  4. import time
  5. class Log(object):
  6. # def __init__(self, pag_source, log_path=os.path.join(os.path.dirname(os.path.realpath(__file__)), "logs")):
  7. def __init__(self, log_path=os.path.join(os.path.dirname(os.path.realpath(__file__)), "logs")):
  8. if not os.path.exists(log_path):
  9. os.makedirs(log_path)
  10. # 文件的命名
  11. # self.logname = os.path.join(log_path, '{}_{}.log'.format(pag_source, time.strftime('%Y%m%d')))
  12. self.logname = os.path.join(log_path, '{}.log'.format(time.strftime('%Y%m%d')))
  13. self.logger = logging.getLogger()
  14. self.logger.setLevel(logging.DEBUG)
  15. # 日志输出格式
  16. self.formatter = logging.Formatter('%(asctime)s %(levelname)s: %(message)s')
  17. # self.formatter = logging.Formatter('%(asctime)s [%(filename)s] %(levelname)s: %(message)s')
  18. def __console(self, level, message):
  19. # 创建一个FileHandler,用于写到本地
  20. fh = logging.FileHandler(self.logname, 'a', encoding='utf-8')
  21. fh.setLevel(logging.DEBUG)
  22. fh.setFormatter(self.formatter)
  23. self.logger.addHandler(fh)
  24. # 创建一个StreamHandler,用于输出到控制台
  25. ch = logging.StreamHandler()
  26. ch.setLevel(logging.DEBUG)
  27. ch.setFormatter(self.formatter)
  28. self.logger.addHandler(ch)
  29. if level == 'info':
  30. self.logger.info(message)
  31. elif level == 'debug':
  32. self.logger.debug(message)
  33. elif level == 'warning':
  34. self.logger.warning(message)
  35. elif level == 'error':
  36. self.logger.error(message)
  37. # 这两行代码是为了避免日志输出重复问题
  38. self.logger.removeHandler(ch)
  39. self.logger.removeHandler(fh)
  40. # 关闭打开的文件
  41. fh.close()
  42. def debug(self, message):
  43. self.__console('debug', message)
  44. def info(self, message):
  45. self.__console('info', message)
  46. def warning(self, message):
  47. self.__console('warning', message)
  48. def error(self, message):
  49. self.__console('error', message)