관리-도구
편집 파일: graphite.cpython-38.pyc
U .?�fQ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZm Z ddl m Z m Z e� d�Zdd� ZG d d � d ej�ZG d d � d �ZdS ) � N)� default_timer)�Callable�Tuple� )�CollectorRegistry�REGISTRYz[^a-zA-Z0-9_-]c C s t �d| �S )N�_)�_INVALID_GRAPHITE_CHARS�sub)�s� r �O/opt/hc_python/lib/python3.8/site-packages/prometheus_client/bridge/graphite.py� _sanitize s r c s$ e Zd Z� fdd�Zdd� Z� ZS )� _RegularPushc s t � �� || _|| _|| _d S �N)�super�__init__�_pusher� _interval�_prefix)�selfZpusher�interval�prefix�� __class__r r r s z_RegularPush.__init__c C st t � }t � }||kr*||k r:|| j7 }qq:t�|| � qz| jj| jd� W q tk rl t� d� Y qX qd S )N)r z Push failed) r r �time�sleepr �pushr �OSError�logging� exception)r Z wait_until�nowr r r �run s z_RegularPush.run)�__name__� __module__� __qualname__r r" � __classcell__r r r r r s r c @ sd e Zd Zedejdfeeef ee e g e f e d�dd�Z dedd�d d �Z de edd �d d�ZdS )�GraphiteBridge� F)�address�registry�timeout_seconds�_timer�tagsc C s" || _ || _|| _|| _|| _d S r )�_address� _registry�_tags�_timeoutr, )r r) r* r+ r, r- r r r r 1 s zGraphiteBridge.__init__� N)r �returnc s� t | �� �}g }d}|r |d }| j�� D ]�}|jD ]~}|jr~| jrNd}d� nd}d� ||�� fdd�t|j� � �D �� }nd}|� |� t |j �� |� dt |j�� d|� d �� q4q*t�| j| j�} | �d�|��d �� | �� d S ) Nr2 �.�;z{0}={1}z{0}.{1}c s$ g | ] \}}� � t|�t|���qS r )�formatr )�.0�k�v��fmtr r � <listcomp>P s � �z'GraphiteBridge.push.<locals>.<listcomp>� � �ascii)�intr, r/ ZcollectZsamples�labelsr0 �join�sorted�items�appendr �name�float�value�socket�create_connectionr. r1 �sendall�encode�close) r r r! �outputZ prefixstrZmetricr �sepZlabelstr�connr r: r r > s. ��4zGraphiteBridge.push� N@)r r r3 c C s t | ||�}d|_|�� d S )NT)r �daemon�start)r r r �tr r r rS [ s zGraphiteBridge.start)r2 )rQ r2 )r# r$ r% r r r �strr@ r rG r �boolr r rS r r r r r' 0 s � � r' )r �rerI � threadingr Ztimeitr �typingr r r* r r �compiler r �Threadr r' r r r r �<module> s