admin
2025-01-15 f84dcf456dbfa318f490d6cf878be5d5d5262718
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
B
€ÿFf
ã@sØdZddlZddlZddlZddlZddlmZmZmZddl    m
Z
Gdd„dƒZ e ƒZ e ƒZ e ƒZdd„Zd    d
„Zd d „Zd d„Zdd„Zdd„ZedkrÔe ƒZe ed¡ejdd„dd ¡e d¡eƒdS)u
异步日志管理器
éN)Ú logger_debugÚ logger_systemÚprintlog)Útoolc@sVeZdZdd„Zdd„Zdd„Zdd„Zd    d
„Zd d „Zd d„Z    dd„Z
ddd„Z dS)Ú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 r Z    __add_logszAsyncLogManager.__add_logcCs|j |¡dS)N)r    r)r
Údatar r r Úadd_logszAsyncLogManager.add_logcGs|j|df|žŽdS)NÚdebug)Ú_AsyncLogManager__add_log)r
rrr r r rszAsyncLogManager.debugcGs|j|df|žŽdS)NÚinfo)r)r
rrr r r rszAsyncLogManager.infocGs|j|df|žŽdS)NÚwarning)r)r
rrr r r rszAsyncLogManager.warningcGs|j|df|žŽdS)NÚerror)r)r
rrr r r r!szAsyncLogManager.errorcGs|j|df|žŽdS)NÚ    exception)r)r
rrr r r r$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] )rrrrÚ get_thread_idr    ÚgetÚgetattrÚlistZ to_time_strÚintÚstrÚsplitÚtupleÚ _common_logrÚ    ExceptionÚloggingr)r
Zadd_to_common_logÚvalZtime_sÚcmdrÚdÚer r r r(s 
 
 >
zAsyncLogManager.run_syncN)F) Ú__name__Ú
__module__Ú __qualname__r rrrrrrrrr r r r r srcGstj|f|žŽdS)N)r*r)rrr r r rDsrcGstj|f|žŽdS)N)r*r)rrr r r rHsrcGstj|f|žŽdS)N)r*r)rrr r r rLsrcGstj|f|žŽdS)N)r*r)rrr r r rPsrcGstj|f|žŽdS)N)r*r)rrr r r rTsrcCs t dt ¡›¡t ¡dS)Nuasync_log çº¿ç¨‹ID:)rrrr"r*rr r r r rYsrÚ__main__u    æµ‹è¯•123cCst ¡S)N)ÚasyncLogManagerrr r r r Ú<lambda>bór6T)ÚtargetÚdaemonr)Ú__doc__r,rÚ    threadingrÚlog_module.logrrrÚutilsrrZ l2_data_logÚ huaxin_l2_logr*rrrrrrr1r5ÚThreadÚstartÚsleepr r r r Ú<module>s, 0