1#@!#!123s

��JFIF�� 1#@!#!123s
: / opt / sharedrads / mysql / __pycache__ /
Filename : slowqueryparser.cpython-39.pyc
back
a

�����g����������������������@���s����d�dl�Z�d�dlZd�dlmZ�d�dlZd�dlZd�dlmZ�e�	d�Z
e�	d�Zdd��ZG�dd	��d	�Z
d
d��Zdd
��Zdd��Zdd��Zedkr�e���dS�)�����N)�Path)�Parserz^# User@Host:\s+([a-z0-9]+)zc^# Query_time:\s+([0-9\.]+)\s+Lock_time:\s+([0-9\.]+)\s+Rows_sent:\s+(\d+)\s+Rows_examined:\s+(\d+)c������������������C���s����t����}�|�jdddddd��|�jddd	dd
d��|�jddd
dd��|�jdddd�dd��|�jddddd��|�jdddd��|����S�)Nz-qz--quiet�quiet�
store_truezSuppress stderr output)�dest�action�helpz-Hz--no-header�	no_headerzSuppress column headersz-oz--output�FILEz&Write output to FILE (default: stdout))�metavarr���z-uz--user�USERz'Output USER's queries instead of tallys)r����defaultr���z-az	--averagez*Print averages per query instead of totals)r���r����logpath�?zPath to slow query log)�nargsr���)�argparse�ArgumentParser�add_argument�
parse_args)�parser��r����)./opt/sharedrads/mysql/slowqueryparser.pyr������s.���������r���c�������������������@���s����e�Zd�ZdZed�dd�Zejd�dd�Ze	e
jfdd	��Ze	e
jfd
d��Z
ee
jfee�d�d
d��Ze
jfdd�Ze
jfdd�ZdS�)�	MySQLUserz/Holds a user name and tracks numbers of queries)�usernamec�����������������C���s(���||�_�d|�_d|�_d|�_d|�_d|�_d�S�)Nr���g��������)r����num_queries�
query_time�	lock_time�	rows_sent�
rows_examined)�selfr���r���r���r����__init__/���s����zMySQLUser.__init__)�stats_matchc�����������������C���sj���|����\}}}}|��jd7��_|��jt|�7��_|��jt|�7��_|��jt|�7��_|��jt|�7��_d�S�)N����)�groupsr���r����floatr���r����intr���)r���r!���r���r���r���r���r���r���r����	add_query7���s����zMySQLUser.add_queryc�����������������C���s���|�j�g�d�|d��d�S�)N)�QUERIESZTIMEZLOCKTIMEZROWSSENTZ	ROWSRECVD��file��header��clsr)���r���r���r����
row_header?���s�����zMySQLUser.row_headerc�����������������C���s���|�j�g�d�|d��d�S�)N)r'���zTIME/Qz
LOCKTIME/Qz
ROWSSENT/Qz
ROWSRECV/Qr(���r*���r,���r���r���r����
avg_headerE���s�����zMySQLUser.avg_header)�colsc�����������������C���s0���t�d�d�d|d��t�tdd��|��d|i��d�S�)Nr�������� ��endr)���c�����������������S���s
���|���d�S�)N�
���)�rjust��xr���r���r����<lambda>O��������z"MySQLUser.header.<locals>.<lambda>r)���)�printr6����map)r0���r)���r���r���r���r+���L���s����zMySQLUser.headerc��������������	���C���sf���t�|�j�d�t|�j��d�tt|�j���d�tt|�j���d�t|�j��d�t|�j	��d�|d��d�S��Nr1���r5���r(����
r;���r���r6����strr���r%���r���r���r���r����r���r)���r���r���r����	row_printQ���s����
�zMySQLUser.row_printc��������������
���C���s����t�|�j�d�t|�j��d�tt|�j|�j����d�tt|�j|�j����d�tt|�j|�j����d�tt|�j	|�j����d�|d��d�S�r=���r>���r@���r���r���r����	avg_print\���s����
�zMySQLUser.avg_printN)�__name__�
__module__�__qualname__�__doc__r?���r ����re�Matchr&����classmethod�sys�stdoutr.���r/����staticmethod�listr+���rA���rB���r���r���r���r���r���,���s���r���c������������������C���st���zXt�dd�}�|��d�sW�d�S�t|��dd�����}|td�krPtdtjd��W�d�S�t|�W�S��t	j
yn���Y�d�S�0�d�S�)	NF)�strictz/etc/my.cnfZmysqldZslow_query_log_filez	/dev/nullz'MySQL log points to /dev/null currentlyr(���)�
PyMySQLParser�readr����get�resolver;���rJ����stderrr?����configparser�Error)r����pathr���r���r����default_log_pathh���s����


rW���c�����������������C���s����|�j�s\tj���r\t��}|s2tdtjd��t�d��|�js\td|��d�tjd��t	|ddd�S�|�j�rl|�j�d	kr�tj}|�js�td
tjd��tjS�t	|�j�ddd�S�)Nz2Failed to get slow query log path from /etc/my.cnfr(���r"���z$Reading from the default log file, `�'�utf-8�replace)�encoding�errors�-z6MySQL slow query log parser reading from stdin/pipe...)
r���rJ����stdin�isattyrW���r;���rS����exitr����open)�args�	query_logr���r���r����open_logv���s.�����

��rd���c��������������
���c���st���z@t�|���$}|����}r |V��qW�d�����n1�s40����Y��W�n.�tyn�}�zt�|��W�Y�d�}~n
d�}~0�0�d�S��N)rd����readline�OSErrorrJ���r`���)rb���rc����line�excr���r���r����iter_log����s����
*rj���c���������������
���C���s���t���}�|�jrt|�jddd�}ntj}|��h�i�}d}t|��D�]�}t�|��}rx|�d�}|�j	rv||�j	krvt
|d|d��q<t�|��}r�||vr�t|�||<�||��
|��|�j	r�||�j	kr�t
|d|d��q<|�j	r<||�j	kr<zt
|d|d��W�q<�t�y���t�d	��Y�q<0�q<|�j	�r$W�d�����d�S�|�j�sJ|�j�r@t�|��n
t�|��t|���d
d��d�D�]$}|�j�rv|�|��n
|�|���q^W�d�����n1��s�0����Y��d�S�)
N�wrY���)r[���ZNO_SUCH_USERr"���r2���r3�����r���c�����������������S���s���|�j�S�re���)r���r7���r���r���r���r9�������r:���zmain.<locals>.<lambda>)�key)r����outputra���rJ���rK���rj����USER_RE�match�group�userr;����STATS_REr���r&����	Exceptionr`���r	���Zaverager/���r.����sorted�valuesrB���rA���)rb���Zout_fileZ
user_tableZ	this_userrh���Z
user_matchr!����datar���r���r����main����sB����

rx����__main__)r���rT����pathlibr���rJ���rG���Zpymysql.optionfiler���rO����compilero���rs���r���r���rW���rd���rj���rx���rC���r���r���r���r����<module>���s"���
�<	(