log.py 3.0 KB

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