H:j!& d dl Z d dlmZmZmZ d dlmZ d dlmZm Z m
Z
d dl m Z e j
d Z G d de Zd Zd
Zd Z G d d
e ZdS ) N)DictListOptional) mysql_lib)cpusers db_accessdblogin_cplogin_pairs) run_commandustatec e Zd ZdS )MySQLOperationalErrorN)__name__
__module__ __qualname__ ~/builddir/build/BUILDROOT/lve-stats-5.0.4-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/ustate.pyr
r
s Dr r
c
| d }| d }| }ddd fd|D }i }d}t | D ]\\ }}|s | dt | dz
}t | t | k o|d } | s<| dt | d z
}| dd
t | t | k r@t d |d d
|t d|dz
|dz ii nWt t || }
| ret |
d } |
d= n# t $ r Y nw xY w|
||< i || d< || dd |
dd |
dd |
dd |
dd |
|| d t |
d < # t t f$ r3} t dt | Y d} ~ Vd} ~ ww xY w|S )a5
parse /usr/sbin/lveps -c 1 -p -d -n -x result
example returned data:
{504:
{'CPU': '26%', 'IO': '0', 'MEM': '1', 'EP': '0', 'IOPS': 'N/A', 'PNO': '3', 'TNO': '3', 'TID':
{4400:
{'CPU': '26%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'md5sum', 'IOPS': 'N/A'},
4381:
{'CPU': '0%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'su', 'IOPS': 'N/A'},
4382:
{'CPU': '0%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'bash', 'IOPS': 'N/A'}}},
500:
{'CPU': '13%', 'IO': '0', 'MEM': '1', 'EP': '0', 'IOPS': 'N/A', 'PNO': '3', 'TNO': '3', 'TID':
{4266:
{'CPU': '0%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'su', 'IOPS': 'N/A'},
4299:
{'CPU': '13%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'cat', 'IOPS': 'N/A'},
4267:
{'CPU': '0%', 'IO': 'N/A', 'MEM': '1', 'CMD': 'bash', 'IOPS': 'N/A'}}}}
example of data manipulation:
getting a list of user id
>>> lveps_data = _parse_lveps_output()
>>> user_id_list = lveps_data.keys()
a list of processes tid particular user id 504
>>> user_tid_list = lveps_data[504]['TID'].keys()
getting CPU load user
>>> user_cpu = lveps_data[504]['CPU']
getting CPU load specific process
>>> lveps_data[504]['TID'][4400]
r CPUCMD)SPEEDCOMc < g | ]} || S r )get).0col_name replace_cols r
z'_parse_lveps_output..< s' UUUHKOOHh77UUUr N z lveps output was incorrect: %sdata lveps_lines )extraIDTIDPIDEPPNOTNOz Can't parse lveps output: %s)splitpop enumeratelenisdigitinsertlogerrormaxdictzipintKeyError
ValueErrorstr)
lveps_outputr$ header_line columns_name
lveps_datauser_idlveps_line_index
lveps_linelveps_line_splitedhas_idlveps_dict_lineer s
@r _parse_lveps_outputrH s% @ $$T**K //!$$K $$&&L !%00KUUUU UUULJG(1+(>(> $B $B$* ' - -dC 4E4E4I J J())S ->->>cDVWXDYDaDaDcDc -!+!1!1$L8I8IA8M!N!N % %a , , , ! " "c,&7&7 7 7 II0
{3qBRUVBV;W;WXhkmXm;m/n op
E s<1C D DEE B/--d3344G
#E**
"1Jw )+Jw & w # #E4 0 0 0 0 d + + + t , , , t , , , d + + +
BN]
7#E*3/B/B5/I/I+J+JKK )
B
B
B 8#a&&AAAAAAAA
B s* /F33
G ?G
1I==K(J<<Kc < t } t | S N)_get_lveps_outputrH r= s r get_lvepsrM h s $&&L | , ,,r c t g dd } t | t r| dd } n)| dd d } | S )N) z/usr/sbin/lvepsz-c1z-pz-dz-nz-xz-oz;id:10,ep:10,pno:10,pid:15,tno:5,tid:15,cpu:7,mem:15,com:256F)convert_to_strutf-8replace)r
isinstancebytesdecodeencoderL s r rK rK m s +
!
!
!L$ ,&& O#**7I>> #**7I>>EEgNN r c F e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d d
Z d S ) SQLSnapshotc H d | _ i | _ t | _ d S rJ ) _mysql_conn_dblogin_cplogin_mapset _db_usersselfs r __init__zSQLSnapshot.__init__ s! $&! r c . | | S rJ )connectr^ s r __enter__zSQLSnapshot.__enter__ s r c . | d S rJ )close)r_ exc_typeexc_valexc_tbs r __exit__zSQLSnapshot.__exit__ s
r c < t }|d }|d }| dd }t j |||dd } | | _ dS # t j $ r"}t t | |d}~ww xY w) zB
Obtain access data and connect to mysql database
loginpasshost localhostFutf8mb4)rm userpasswd use_unicodecharsetN) r r r MySQLConnectorrb rZ
MySQLErrorr
r< )r_ access mysql_login
mysql_pass
mysql_host connectorrG s r rb zSQLSnapshot.connect s Wo F^
ZZ 44
,
7 ( 0 0 2 2D # 7 7 7'A//Q 6 7s A* *B9 BBc F t t | _ dS )z;
Refresh : map
N)r7 r r[ r^ s r _refresh_mapzSQLSnapshot._refresh_map s! %))>)@)@$A$A!!!r c 8 | j dS )z(
Close Mysql connection
N)rZ re r^ s r re zSQLSnapshot.close s
r c L t } | j }| d | }t d |D }n8# t
j $ r&}t d| Y d }~nd }~ww xY w|S )NzSHOW FULL PROCESSLISTc 3 H K | ] }t d |D V dS )c 3 p K | ]1}t |t r| d d n|V 2dS )rQ rR N)rS rT rU )r cols r z9SQLSnapshot._raw_processlist... sZ 7Ae6L6LUCJJw 222RU r N)tuple)r rows r r z/SQLSnapshot._raw_processlist.. s^
" r zCError occurred during executing the `SHOW FULL PROCESSLIST` command)exc_info) r rZ cursorexecutefetchallr ru r4 warning)r_ resultr rawrG s r _raw_processlistz SQLSnapshot._raw_processlist s k%,,..F NN2 3 3 3//##C
FF # k k k KK]hiK j j j j j j j j k
s AA, ,B!; B B!c i }| D ]`}|d }|d }|d }|d pd}|dk r+|||g}| |g }| | |||< a|S )zN
Group processlist by database user name
:rtype: dict
r r% r" Sleep)r r append) r_ process_snapshot sql_tuple db_usernamesql_cmdsql_time sql_query
snapshot_linegrouped_by_users r _get_sql_process_listz!SQLSnapshot._get_sql_process_list s
..00 < New database user(s) %s detected; database users map refreshedr )r r\ keysr] r| r4 debugr< listaddr itemsr[ r extend) r_ cplogin_lstr new_db_users new_db_user sql_snapshot cplogin_lst_r sql_snap cp_username sql_snap_s r r zSQLSnapshot.get sU 5577 +002233dnD 0 IIPD &&''"-
,
0
0 "";//// "5gii52 %)*:*@*@*B*B%C%C 6 6 !K 377 DDK&;,+F+F ( , ,[" = = ***,5 [)r rJ ) r r r r` rc ri rb r| re r r r r r r rX rX s
7 7 72B B B ! ! ! , ( r rX )loggingtypingr r r clcommonr clcommon.cpapir r r clcommon.utilsr
getLoggerr4 Exceptionr
rH rM rK objectrX r r r r s ' ' ' ' ' ' ' ' ' ' D D D D D D D D D D & & & & & &g!! I O O Od- - -
6{ { { { { & { { { { { r