-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathConsoleLog.py
120 lines (104 loc) · 3.81 KB
/
ConsoleLog.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
__author__ = 'Rocky'
__version__ = 1.2
#20230302 修改为使用ConcurrentRotatingFileHandler 多进程安全日志
#20240205 修改添加了一个类似于仅显示控制台信息的LOGGER_CONSOLE
import os
import sys
import logging
from logging import handlers
from logging import getLogger, INFO,DEBUG
from concurrent_log_handler import ConcurrentRotatingFileHandler
dirname, filename = os.path.split(os.path.abspath(sys.argv[0]))
LOG_ROOT = dirname
def get_console_logger(log_filename,level=logging.DEBUG,when='D',back_count=0):
"""
:bfief 日志配置
:param log_filename :日志名称
:param level :日志等级
:param when :间隔时间：
S:秒
M:分
H:小时
D:天
W:每星期（interval==0时代表星期一）
midnight: 每天凌晨
:param back_count: 备份文件的个数，若超过该值，就会自动删除
:return: logger
"""
# 创建一个日志器。提供了应用程序接口
logger = logging.getLogger(log_filename)
# 设置日志输出的最低等级,低于当前等级则会被忽略
logger.setLevel(level)
# 创建日志输出路径
log_path = os.path.join(LOG_ROOT, "logs")
if not os.path.exists(log_path):
os.mkdir(log_path)
log_file_path = os.path.join(log_path, log_filename)
# 创建格式器
formatter = logging.Formatter('%(message)s')
# 创建处理器：ch为控制台处理器，fh为文件处理器
ch = logging.StreamHandler()
ch.setLevel(level)
# 输出到文件
filesize = 50*1024*1024
fh = ConcurrentRotatingFileHandler(log_file_path, "a", filesize,1024 ,encoding="utf-8")
#fh = logging.handlers.TimedRotatingFileHandler(
# filename=log_file_path,
# when=when,
# backupCount=back_count,
# encoding='utf-8')
fh.setLevel(level)
# 设置日志输出格式
fh.setFormatter(formatter)
ch.setFormatter(formatter)
# 将处理器，添加至日志器中
logger.addHandler(fh)
logger.addHandler(ch)
return logger
def get_logger(log_filename,level=logging.DEBUG,when='D',back_count=0):
"""
:bfief 日志配置
:param log_filename :日志名称
:param level :日志等级
:param when :间隔时间：
S:秒
M:分
H:小时
D:天
W:每星期（interval==0时代表星期一）
midnight: 每天凌晨
:param back_count: 备份文件的个数，若超过该值，就会自动删除
:return: logger
"""
# 创建一个日志器。提供了应用程序接口
logger = logging.getLogger(log_filename)
# 设置日志输出的最低等级,低于当前等级则会被忽略
logger.setLevel(level)
# 创建日志输出路径
log_path = os.path.join(LOG_ROOT, "logs")
if not os.path.exists(log_path):
os.mkdir(log_path)
log_file_path = os.path.join(log_path, log_filename)
# 创建格式器
formatter = logging.Formatter('%(asctime)s - %(pathname)s (%(threadName)s) [line:%(lineno)d] - %(levelname)s: %(message)s')
# 创建处理器：ch为控制台处理器，fh为文件处理器
ch = logging.StreamHandler()
ch.setLevel(level)
# 输出到文件
filesize = 50*1024*1024
fh = ConcurrentRotatingFileHandler(log_file_path, "a", filesize,1024 ,encoding="utf-8")
#fh = logging.handlers.TimedRotatingFileHandler(
# filename=log_file_path,
# when=when,
# backupCount=back_count,
# encoding='utf-8')
fh.setLevel(level)
# 设置日志输出格式
fh.setFormatter(formatter)
ch.setFormatter(formatter)
# 将处理器，添加至日志器中
logger.addHandler(fh)
logger.addHandler(ch)
return logger
LOGGER = get_logger(filename.replace('.py','.log'))
LOGGER_CONSOLE = get_console_logger(filename.replace('.py','_console.log'))