blame | 历史 | 原始文档
Administrator
2025-06-12 4e5eed2226fae6a057c454155565211dbc9349e9 
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

B  


¬ÏûeW


ã@sÔdZddlZddlZddlZddlZddlmZmZddlm    Z    Gdd„dƒZ


e


ƒZe


ƒZe


ƒZ dd„Zd    d


„Zdd„Zd d„Zdd„Zdd„ZedkrÐe


ƒZe ed¡ejdd„dd ¡e d¡eƒdS)u


异步日志管理器


éN)Úlogger_debugÚ logger_system)Útoolc@sVeZdZdd„Zdd„Zdd„Zdd„Zd    d


„Zdd„Zd d„Z    dd„Z


ddd„ZdS)ÚAsyncLogManagercCst ¡|_dS)N)ÚqueueÚQueueÚ_AsyncLogManager__log_queue)Úself©r


ú4D:\workspace\trade_sell\log_module\async_log_util.pyÚ__init__szAsyncLogManager.__init__cGs|j |t ¡||f¡dS)N)rÚ


put_nowaitÚtime)r    ÚloggerÚmethodÚargsr


r


rZ    __add_logszAsyncLogManager.__add_logcCs|j |¡dS)N)rr )r    Údatar


r


rÚadd_logszAsyncLogManager.add_logcGs|j|df|žŽdS)NÚdebug)Ú_AsyncLogManager__add_log)r    rrr


r


rrszAsyncLogManager.debugcGs|j|df|žŽdS)NÚinfo)r)r    rrr


r


rrszAsyncLogManager.infocGs|j|df|žŽdS)NÚwarning)r)r    rrr


r


rrszAsyncLogManager.warningcGs|j|df|žŽdS)NÚerror)r)r    rrr


r


rr!szAsyncLogManager.errorcGs|j|df|žŽdS)NÚ    exception)r)r    rrr


r


rr$szAsyncLogManager.exceptionFc


Csìtd|ƒt dt ¡›¡xÈy–|j ¡}|sª|d}|d}t|d|ƒ}t|dƒ}dt     t


|ƒ¡›dt|ƒ d¡ddd    …›d


|d|d<t |ƒ}||Žn


t |¡Wq tk


râ}zt |¡Wdd}~XYq Xq WdS)NÚrun_syncurun_sync çº¿ç¨‹ID:ééréú[Ú.éz] )ÚprintrrrÚ get_thread_idrÚgetÚgetattrÚlistZto_time_strÚintÚstrÚsplitÚtupleÚ_common_logrÚ    ExceptionÚloggingr)r    Zadd_to_common_logÚvalZtime_sÚcmdrÚdÚer


r


rr(s 


 


>


zAsyncLogManager.run_syncN)F)Ú__name__Ú


__module__Ú__qualname__rrrrrrrrrr


r


r


rr srcGstj|f|žŽdS)N)r*r)rrr


r


rrCsrcGstj|f|žŽdS)N)r*r)rrr


r


rrGsrcGstj|f|žŽdS)N)r*r)rrr


r


rrKsrcGstj|f|žŽdS)N)r*r)rrr


r


rrOsrcGstj|f|žŽdS)N)r*r)rrr


r


rrSsrcCs t dt ¡›¡t ¡dS)Nuasync_log çº¿ç¨‹ID:)rrrr"r*rr


r


r


rrXsrÚ__main__u    æµ‹è¯•123cCst ¡S)N)ÚasyncLogManagerrr


r


r


rÚ<lambda>aór6T)ÚtargetÚdaemonr)Ú__doc__r,rÚ    threadingrÚlog_module.logrrÚutilsrrZl2_data_logZ huaxin_l2_logr*rrrrrrr1r5ÚThreadÚstartÚsleepr


r


r


rÚ<module>s,/