个人中心
gpt4 book ai didi

Python logging模块异步线程写日志实现过程解析

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Python logging模块异步线程写日志实现过程解析由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

通过logging模块，重写一个logging2模块，独立开启线程，将待写的日志信息异步放入队列，做到日志输出不影响主流程性能，环境python3.8 。

logging2.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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
import os
import threading
import queue
import time
import datetime
import logging
from logging.handlers import RotatingFileHandler
 
class logging2(threading.Thread):
   AQueue = queue.Queue( 100000 )
   nPID = os.getpid()
   Adt = datetime.datetime.now().strftime( '%Y%m%d' )
   nCount = 1
  
   def __init__( self , threadID, name, module, logLevel):
     threading.Thread.__init__( self )
     self .threadID = threadID
     self .name = name
     self .module = module
    
     print ( "set loglevel: [%s]" % (logLevel) )
     formatter = logging.Formatter( '%(asctime)s|%(name)s|%(process)d|%(levelname)s|%(message)s' )
     logfile = "log_" + self .module + "_" + str (logging2.nPID) + "_" + str (logging2.Adt) + ".log"
     self .logger = logging.getLogger(__name__)
    
     self .rHandler = RotatingFileHandler(logfile, maxBytes = 10 * 1024 * 1024 , backupCount = 10 )
     self .rHandler.setFormatter(formatter)
    
     self .console = logging.StreamHandler() 
     self .console.setFormatter(formatter)
    
     if logLevel = = 'DEBUG' :
       self .logger.setLevel(level = logging.DEBUG)
       self .rHandler.setLevel(logging.DEBUG)
       self .console.setLevel(logging.DEBUG)
     elif logLevel = = 'INFO' :
       self .logger.setLevel(level = logging.INFO)
       self .rHandler.setLevel(logging.INFO)
       self .console.setLevel(logging.INFO)
     elif logLevel = = 'WARNING' :
       self .logger.setLevel(level = logging.WARN)
       self .rHandler.setLevel(logging.WARN)
       self .console.setLevel(logging.WARN)
     elif logLevel = = 'ERROR' :
       self .logger.setLevel(level = logging.ERROR)
       self .rHandler.setLevel(logging.ERROR)
       self .console.setLevel(logging.ERROR)   
 
     self .logger.addHandler( self .rHandler)
     self .logger.addHandler( self .console)   
 
   #如果跨天了，则重新生成新的文件名
   def reSetLog( self ):
     AdtTemp = datetime.datetime.now().strftime( '%Y%m%d' )
     #比较新的时间
     if AdtTemp = = logging2.Adt:
       return ( True )
      
     logging2.Adt = AdtTemp
     logfile = "log_" + self .module + "_" + str (logging2.nPID) + "_" + str (AdtTemp) + ".log"
     self .rHandler = RotatingFileHandler(logfile, maxBytes = 1 * 1024 , backupCount = 10 )
    
     self .logger.addHandler( self .rHandler)
     self .logger.addHandler( self .console) 
     logging2.nCount + = 1
    
   def run( self ):
     print ( "开启日志线程：" + self .name)
     i = 0
     while True :
       #data = "queue test data"
       #debug(data)
       #print("Queuesize: %s" % (logging2.AQueue.qsize()))
       self .reSetLog()
       if logging2.AQueue.empty() = = False :
         #从队列获取日志消息
         data = logging2.AQueue.get()
         #解析日志消息，格式：日志级别，内容
         level = list (data.keys())[ 0 ]
         content = data.get(level)
         #把内容按分隔符|解析成list传入参数
         lstContent = list (content.split( '|' ))
         if level = = 'DEBUG' :
           self .logger.debug( * lstContent)
         elif level = = 'INFO' :
           self .logger.info( * lstContent)
         elif level = = 'WARNING' :
           self .logger.warn( * lstContent)
         elif level = = 'ERROR' :
           self .logger.error( * lstContent)
       else :
         time.sleep( 0.5 )
 
     print ( "退出线程：" + self .name) 
  
def debug( * content): 
   logMsg = ""
   #传入多个参数用竖线分隔符分开
   for i in range ( len (content)):
     if i = = len (content) - 1 :
       logMsg + = content[i]
     else :
       logMsg + = content[i] + "|"
   logging2.AQueue.put({ 'DEBUG' :logMsg})
      
def info( * content):
   logMsg = ""
   for i in range ( len (content)):
     if i = = len (content) - 1 :
       logMsg + = content[i]
     else :
       logMsg + = content[i] + "|"
   logging2.AQueue.put({ 'INFO' :logMsg})
        
def warn( * content):
   logMsg = ""
   for i in range ( len (content)):
     if i = = len (content) - 1 :
       logMsg + = content[i]
     else :
       logMsg + = content[i] + "|"
   logging2.AQueue.put({ 'WARNING' :logMsg})
    
def error( * content):
   logMsg = ""
   for i in range ( len (content)):
     if i = = len (content) - 1 :
       logMsg + = content[i]
     else :
       logMsg + = content[i] + "|"
   logging2.AQueue.put({ 'ERROR' :logMsg})
          
def init(module, level):
   # 创建新线程
   thread1 = logging2( 1 , "Thread-log" , module, level)
   # 开启新线程
   thread1.start()
#  thread1.join()

测试桩logMain.py 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import sys
import os
import time
import threading
 
if __name__ = = '__main__' :
   import logging2
   logging2.init( "logMain" , "DEBUG" )
  
   teststr = "22222"
  
   while True :
     logging2.debug( 'this is a debug log test [%s] ' , teststr)
     logging2.info( 'this is a info log test [%s] [%s]' , teststr, teststr)
     logging2.warn( 'this is a warn log test' )
     logging2.error( 'this is a error log test' )
     #time.sleep(0.1)
  
  
   print (threading. enumerate ())
  
   print ( 'press ctrl_c to exit' )

测试结果 。

生成日志文件:

-rw-rw-r--. 1 zxl zxl 10152463 6月 24 17:52 log_logMain_57554_20200624.log 。

文件内容如下:

Python logging模块异步线程写日志实现过程解析

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.

原文链接：https://www.cnblogs.com/yindianhaidao/p/13201074.html 。

最后此篇关于Python logging模块异步线程写日志实现过程解析的文章就讲到这里了,如果你想了解更多关于Python logging模块异步线程写日志实现过程解析的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： 基于tf.shape(tensor)和tensor.shape()的区别说明
文章推荐： Tensorflow全局设置可见GPU编号操作
文章推荐： 浅谈多卡服务器下隐藏部分 GPU 和 TensorFlow 的显存使用设置
文章推荐： Tensorflow中批量读取数据的案列分析及TFRecord文件的打包与读取
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com