File: //usr/local/lib/python3.9/site-packages/agent360/plugins/__pycache__/mysql.cpython-39.pyc
a
q�dg� � @ s@ d dl Z d dlZd dlZG dd� dej�Zedkr<e� �� dS )� Nc @ s e Zd ZdZ dd� ZdS )�Plugin�mysqlc
C s� | � � }i }zt|�dd��|d< W n ty> d|d< Y n0 z|�dd�|d< W n d|d< Y n0 z|�dd�|d< W n d |d< Y n0 z|�dd
�|d
< W n |�dd �|d < Y n0 z|�dd
�|d< W n d|d< Y n0 tjf i |��}|�� }|�d� |�� }d}d}t � } t � }
t
t g} |D ]�\} }
| � � �
� } | D ](}z ||
�}
W n t�yv Y n0 �qR| |v �r�|
| | < n<| |v �r:t|
�t
u�r:| �| t |
�|�| | < t |
�|
| < n �q:|�tjj�}|�d� |�� }d}|du �rt � }|�� D ]�\} }
| � � �
� } | dk�r<|
dk�r8dnd}
| dk�rX|
dk�rTdnd}
| D ](}z ||
�}
W n t�y� Y n0 �q\| |v �r t|
�t
u�r |
| | < n �q |�� t�� |
d< | �|
� | S )z&
MySQL metrics plugin
r �porti� �username�user�root�password�passwd� �host�socketZ unix_socketZdatabase�dbzSHOW GLOBAL STATUS;) �max_used_connections�
open_files� open_tables�qcache_free_blocks�qcache_free_memory�qcache_total_blocks�slave_open_temp_tables�threads_cached�threads_connected�threads_runningZuptime)7Zaborted_clientsZaborted_connectsZbinlog_cache_disk_useZbinlog_cache_useZbytes_receivedZ
bytes_sentZ
com_deleteZcom_delete_multiZ
com_insertZcom_insert_selectZcom_loadZ com_replaceZcom_replace_selectZ
com_selectZ
com_updateZcom_update_multi� connectionsZcreated_tmp_disk_tablesZcreated_tmp_filesZcreated_tmp_tablesZ key_readsZkey_read_requestsZ
key_writesZkey_write_requestsr r r Z
opened_tablesr r Z qcache_hitsZqcache_insertsZqcache_lowmem_prunesZqcache_not_cachedZqcache_queries_in_cacher Z questionsZselect_full_joinZselect_full_range_joinZ select_rangeZselect_range_checkZ select_scanr Zslave_retried_transactionsZslow_launch_threadsZ slow_queriesZ
sort_rangeZ sort_rowsZ sort_scanZtable_locks_immediateZtable_locks_waitedr r Zthreads_createdr zSHOW SLAVE STATUS) Zslave_io_stateZ master_hostZseconds_behind_masterZread_master_log_posZ
relay_log_pos�slave_io_running�slave_sql_runningZ
last_errorZexec_master_log_posZrelay_log_spaceZslave_sql_running_stateZmaster_retry_countNr ZYes� r r �ts)Zget_agent_cache�int�get�
ValueError�MySQLdb�connect�cursor�executeZfetchall�dict�str�float�lower�strip�typeZabsolute_to_per_secondZcursorsZ
DictCursorZfetchone�items�close�timeZset_agent_cache)�self�configZ
prev_cache�authr
r" Z query_resultZ non_deltaZ
delta_keys�results�data� constructors�key�value�cZquery_result_slaveZnon_delta_slave� r6 �@/usr/local/lib/python3.9/site-packages/agent360/plugins/mysql.py�run
s�
:
z
Plugin.runN)�__name__�
__module__� __qualname__r8 r6 r6 r6 r7 r s r �__main__)r, r ZpluginsZ
BasePluginr r9 r# r6 r6 r6 r7 �<module> s '