File: //usr/local/lib/python3.6/site-packages/agent360/plugins/__pycache__/mysql.cpython-36.pyc
3
3 Eg� � @ s@ d dl Z d dlZd dlZG dd� dej�Zedkr<e� j� dS )� Nc @ s e Zd ZdZ dd� ZdS )�Plugin�mysqlc W C s� | j � }i }yt|jdd��|d< W n tk
r@ d|d< Y nX y|jdd�|d< W n d|d< Y nX y|jdd�|d< W n d |d< Y nX y|jdd
�|d
< W n |jdd �|d < Y nX y|jdd
�|d< W n d|d< Y nX tjf |�}|j� }|jd� |j� }dZ}d[}t � } t � }
t
t g} x�|D ]�\} }
| j � j
� } x2| D ]*}y ||
�}
W n tk
�rz Y nX �qTW | |k�r�|
| | < n<| |k�r:t|
�t
k �r:| j| t |
�|�| | < t |
�|
| < n �q:W |jtjj�}|jdH� |j� }d\}|dUk�r t � }x�|j� D ]�\} }
| j � j
� } | dOk�rF|
dVk�rBdWndX}
| dNk�rb|
dVk�r^dWndX}
x2| D ]*}y ||
�}
W n tk
�r� Y nX �qhW | |k�rt|
�t
k �r|
| | < n �qW |j� tj� |
dY< | j|
� | 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_running�uptime�aborted_clients�aborted_connects�binlog_cache_disk_use�binlog_cache_use�bytes_received�
bytes_sent�
com_delete�com_delete_multi�
com_insert�com_insert_select�com_load� com_replace�com_replace_select�
com_select�
com_update�com_update_multi� connections�created_tmp_disk_tables�created_tmp_files�created_tmp_tables� key_reads�key_read_requests�
key_writes�key_write_requests�
opened_tables� qcache_hits�qcache_inserts�qcache_lowmem_prunes�qcache_not_cached�qcache_queries_in_cache� questions�select_full_join�select_full_range_join� select_range�select_range_check� select_scan�slave_retried_transactions�slow_launch_threads� slow_queries�
sort_range� sort_rows� sort_scan�table_locks_immediate�table_locks_waited�threads_createdzSHOW SLAVE STATUS�slave_io_state� master_host�seconds_behind_master�read_master_log_pos�
relay_log_pos�slave_io_running�slave_sql_running�
last_error�exec_master_log_pos�relay_log_space�slave_sql_running_state�master_retry_countNZYes� r �ts) r r r r r r r r r r r )7r r r r r r r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r r r r1 r r r2 r3 r4 r5 r6 r r7 r8 r9 r: r; r< r r= r> r? r@ rA rB rC rD r r rE r ) rF rG rH rI rJ rK rL rM rN rO rP rQ )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
rY Z query_resultZ non_deltaZ
delta_keys�results�dataZ constructors�key�value�cZquery_result_slaveZnon_delta_slave� rl �?/root/tmp/pip-build-f6rmvwrq/agent360/agent360/plugins/mysql.py�run
s
z
Plugin.runN)�__name__�
__module__� __qualname__rn rl rl rl rm r s r �__main__)rc rW ZpluginsZ
BasePluginr ro rZ rl rl rl rm �<module> s '