ruạṛ
3 ?L�i� � @ s� y0d dl mZmZ d dlmZmZ d dlmZ W n@ ek rp d dlmZ d dl mZ d dl mZmZmZ Y nX d dl Z d dl Z d dl Z d dlZd dlmZ d dlZG d d � d e j�Zed kr�e� j� dS ) � )�urlparse� urlencode)�urlopen�Request)� HTTPError)r )r )r r r N)� HTTPBasicAuthc @ s e Zd ZdZ dd� ZdS )�Plugin�rabbitmqc C s� dd� }t � }t � }y$|jdd�}|jdd�}||f}W n d}Y nX tj|jdd�|d�}|jd kr�tj|jdd�t||�d�}|jd kr�y |j� } W q� tk r� } z| S d } ~ X q�X n d j|j�S t j � |d < | j � } y | d W n i | d< Y nX | |d< t j � |d d < | j d| d d | d �|d< | d d |d< | j d| d d | d �|d< | d d |d< | j d| d d | d �|d< | d d |d< | j d| d d | d �|d< | d d |d< | j d| d d | d �|d< | d d |d< | d d |d< | d d |d < | d d |d < t | d �|d < | d d |d < | d d! |d!< | d d" |d"< | d d# |d#< | d d$ |d$< | j |� |S )%z. rabbitmq status page metrics c s" dd� � t � fdd�| j� D ��S )Nc S s t | t�r| jd�S | S )N�ascii)� isinstance�unicode�encode)�x� r �B/root/tmp/pip-build-3x0y2zol/agent360/agent360/plugins/rabbitmq.py�<lambda> s z7Plugin.run.<locals>.ascii_encode_dict.<locals>.<lambda>c 3 s | ]}t � |�V qd S )N)�map)�.0�pair)� ascii_encoder r � <genexpr> s z8Plugin.run.<locals>.ascii_encode_dict.<locals>.<genexpr>)�dict�items)�datar )r r �ascii_encode_dict s z%Plugin.run.<locals>.ascii_encode_dictr �username�passwordFZstatus_page_url)�authi� �� Nz Could not load status page: {}�tsZ message_statsZ published�publishZpublished_totalZackZ ack_totalZ deliver_getZdeliver_get_totalZ redeliverZredeliver_totalZdeliverZ deliver_totalZ queue_totals�messagesZmessages_readyZmessages_unacknowledgedZ listenersZ object_totalsZ consumersZqueuesZ exchanges� connectionsZchannels)r �get�requests� status_coder �json� Exception�format�text�timeZget_agent_cacheZabsolute_to_per_second�lenZset_agent_cache) �self�configr �resultsZ next_cacher r � user_pass�request�j�eZ prev_cacher r r �run s^ z Plugin.runN)�__name__� __module__� __qualname__r3 r r r r r s r �__main__)� urllib.parser r �urllib.requestr r � urllib.errorr � ImportError�urllib�urllib2r* Zpluginsr& r$ Z requests.authr �sysZ BasePluginr r4 �executer r r r �<module> s F
cải xoăn