Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/prometheus_client/__pycache__/metrics.cpython-39.pyc
Ðазад
a e�hEe � @ s� d dl Z d dlmZ d dlZd dlZd dlmZmZmZm Z m Z m Z m Z m Z mZmZ ddlmZ ddlmZmZmZ ddlmZmZmZmZ ddlm Z m Z m Z dd l m Z m!Z! dd l"m#Z#m$Z$ ed d d �Z%ededef d �Z&dd� Z'dd� Z(dd� Z)dd� Z*e+d�dd�Z,e,� Z-G dd � d e �Z.G d d � d e.�Z/G d d � d e.�Z0G d d!� d!e.�Z1G d"d#� d#e.�Z2G d$d%� d%e.�Z3G d&d'� d'e.�Z4dS )(� N)�Lock) �Any�Callable�Dict�Iterable�List�Optional�Sequence�Type�TypeVar�Union� )�values)�ExceptionCounter�InprogressTracker�Timer)�Metric�METRIC_LABEL_NAME_RE�METRIC_NAME_RE� RESERVED_METRIC_LABEL_NAME_RE)� Collector�CollectorRegistry�REGISTRY)�Exemplar�Sample)�floatToGoString�INF�T�MetricWrapperBase)�bound�F.c C s� d}|r||d 7 }|r$||d 7 }||7 }| dkrJ|� d�rJ|d d� }|rh|� d| �sh|d| 7 }|r�| dv r�td| ��|S )N� �_�counter�_totali����)�info�statesetz2Metric name is of a type that cannot have a unit: )�endswith� ValueError)� metric_type�name� namespace� subsystem�unitZ full_name� r. ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/prometheus_client/metrics.py�_build_full_name s r0 c C s0 t �| �std| ��t�| �r,td| ��d S )NzInvalid label metric name: � Reserved label metric name: )r �matchr( r )�lr. r. r/ �_validate_labelname( s r4 c C s4 t |�}|D ]"}t|� || jv r td| ��q |S )Nr1 )�tupler4 �_reserved_labelnamesr( )�cls� labelnamesr3 r. r. r/ �_validate_labelnames/ s r9 c C sJ d}| � � D ](\}}t|� |t|�7 }|t|�7 }q |dkrFtd��d S )Nr � zDExemplar labels have %d UTF-8 characters, exceeding the limit of 128)�itemsr4 �lenr( )�exemplarZrunes�k�vr. r. r/ �_validate_exemplar8 s r@ ��returnc C s t j�dd��� dvS )NZ!PROMETHEUS_DISABLE_CREATED_SERIES�False)�true�1�t)�os�environ�get�lowerr. r. r. r/ �_get_use_createdB s rK c @ s< e Zd ZU dZee ed< dZee ed< dd� Z dd� Z d d � Z d d � Z e e d �dd�Ze e d �dd�Zed �dd�Zed �dd�Zddddedfeeee e eeeee eee dd� dd�Zeeeed�dd �Zedd �d d �Zdd �d d!�Ze e d �d"d#�Z e e d �d$d%�Z e e d �d&d'�Z d(d)� Z dS )*r N�_typer. r6 c C s | j p| j o| jS �N�� _labelnames� _labelvalues��selfr. r. r/ �_is_observableM s z MetricWrapperBase._is_observablec C s | � � stdt| j� ��d S )Nz!%s metric is missing label values)rS r( �strrL rQ r. r. r/ �_raise_if_not_observableS s z*MetricWrapperBase._raise_if_not_observablec C s | j o | j S rM rN rQ r. r. r/ � _is_parentZ s z MetricWrapperBase._is_parentc C s t | j| j| j| j�S rM )r �_name�_documentationrL �_unitrQ r. r. r/ � _get_metric] s z MetricWrapperBase._get_metricrA c C s | � � gS rM )rZ rQ r. r. r/ �describe` s zMetricWrapperBase.describec C s> | � � }| �� D ]&\}}}}}|�| j| ||||� q|gS rM )rZ �_samplesZ add_samplerW )rR �metric�suffix�labels�value� timestampr= r. r. r/ �collectc s zMetricWrapperBase.collectc C s | j � d| j� �S )N�:)rL rW rQ r. r. r/ �__str__i s zMetricWrapperBase.__str__c C s$ t | �}|j� d|j� d| j� d�S )N�.�(�))�type� __module__�__name__rW )rR r) r. r. r/ �__repr__l s zMetricWrapperBase.__repr__r! ) rR r* � documentationr8 r+ r, r- �registryrP rB c C s� t | j||||�| _t| |�| _t|p(d�| _i | _|| _|| _ t � | j�sZt d| j ��| � � rpt� | _i | _| �� r�| �� | js�|r�|�| � d S )Nr. zInvalid metric name: )r0 rL rW r9 rO r5 rP �_kwargsrX rY r r2 r( rV r �_lock�_metricsrS � _metric_init�register) rR r* rl r8 r+ r, r- rm rP r. r. r/ �__init__p s zMetricWrapperBase.__init__)rR � labelvalues� labelkwargsrB c s | j std| ��| jr6td�| tt| j | j�����|rF� rFtd��� r~t� �t| j �krdtd��t� fdd�| j D ��}n,t|�t| j �kr�td��tdd� |D ��}| j �P || j vr�| j | j f| j | j | j|d �| j��| j |< | j | W d � S 1 �s0 Y d S ) ar Return the child for the given labelset. All metrics can have labels, allowing grouping of related time series. Taking a counter as an example: from prometheus_client import Counter c = Counter('my_requests_total', 'HTTP Failures', ['method', 'endpoint']) c.labels('get', '/').inc() c.labels('post', '/submit').inc() Labels can also be provided as keyword arguments: from prometheus_client import Counter c = Counter('my_requests_total', 'HTTP Failures', ['method', 'endpoint']) c.labels(method='get', endpoint='/').inc() c.labels(method='post', endpoint='/submit').inc() See the best practices on [naming](http://prometheus.io/docs/practices/naming/) and [labels](http://prometheus.io/docs/practices/instrumentation/#use-labels). �,No label names were set when constructing %sz@{} already has labels set ({}); can not chain calls to .labels()z"Can't pass both *args and **kwargszIncorrect label namesc 3 s | ]}t � | �V qd S rM �rT ��.0r3 �ru r. r/ � <genexpr>� � z+MetricWrapperBase.labels.<locals>.<genexpr>zIncorrect label countc s s | ]}t |�V qd S rM rw rx r. r. r/ r{ � r| )rl r8 r- rP N)rO r( rP �format�dict�zip�sortedr5 r< ro rp � __class__rW rX rY rn )rR rt ru r. rz r/ r_ � s: � ��� zMetricWrapperBase.labels)rt rB c G s~ | j std| ��t|�t| j �kr:tdt| j �|f ��tdd� |D ��}| j� | j|= W d � n1 sp0 Y d S )Nrv z+Incorrect label count (expected %d, got %s)c s s | ]}t |�V qd S rM rw rx r. r. r/ r{ � r| z+MetricWrapperBase.remove.<locals>.<genexpr>)rO r( r< r5 ro rp )rR rt r. r. r/ �remove� s zMetricWrapperBase.removec C s0 | j � i | _W d � n1 s"0 Y dS )z$Remove all labelsets from the metricN)ro rp rQ r. r. r/ �clear� s zMetricWrapperBase.clearc C s | � � r| �� S | �� S d S rM )rV �_multi_samples�_child_samplesrQ r. r. r/ r\ � s zMetricWrapperBase._samplesc c s� | j � | j�� }W d � n1 s&0 Y |�� D ]R\}}tt| j|��}|�� D ]0\}}}}} t|t |t|�� � �||| �V qXq8d S rM ) ro rp �copyr; �listr rO r\ r r~ ) rR Zmetricsr_ r] Z series_labelsr^ Z sample_labelsr` ra r= r. r. r/ r� � s (z MetricWrapperBase._multi_samplesc C s t d| ��d S )Nz*_child_samples() must be implemented by %r��NotImplementedErrorrQ r. r. r/ r� � s z MetricWrapperBase._child_samplesc C s t d| ��dS )z� Initialize the metric object as a child, i.e. when it has labels (if any) set. This is factored as a separate function to allow for deferred initialization. z(_metric_init() must be implemented by %rNr� rQ r. r. r/ rq � s z MetricWrapperBase._metric_init) rj ri � __qualname__rL r rT �__annotations__r6 r rS rU rV rZ r r r[ rb rd rk r r r rs r r_ r� r� r r\ r� r� rq r. r. r. r/ r I sD � � !7 c @ sl e Zd ZdZdZdd�dd�Zdeeee e f dd�d d �Z e fe e ed �d d �Zee d�dd�ZdS )�Counterar A Counter tracks counts of events or running totals. Example use cases for Counters: - Number of requests processed - Number of items that were inserted into a queue - Total amount of data that a system has processed Counters can only go up (and be reset when the process restarts). If your use case can go down, you should use a Gauge instead. An example for a Counter: from prometheus_client import Counter c = Counter('my_failures_total', 'Description of counter') c.inc() # Increment by 1 c.inc(1.6) # Increment by given value There are utilities to count exceptions raised: @c.count_exceptions() def f(): pass with c.count_exceptions(): pass # Count only one type of exception with c.count_exceptions(ValueError): pass r# NrA c C s0 t �| j| j| jd | j| j�| _t�� | _d S )Nr$ ) r � ValueClassrL rW rO rP �_value�time�_createdrQ r. r. r/ rq s �zCounter._metric_initr ��amountr= rB c C sL | � � |dk rtd��| j�|� |rHt|� | j�t||t�� �� dS )z&Increment counter by the given amount.r z9Counters can only be incremented by non-negative amounts.N)rU r( r� �incr@ � set_exemplarr r� )rR r� r= r. r. r/ r� s z Counter.inc)� exceptionrB c C s | � � t| |�S )z�Count exceptions in a block of code or function. Can be used as a function decorator or context manager. Increments the counter when an exception of the given type is raised up out of the code. )rU r )rR r� r. r. r/ �count_exceptions# s zCounter.count_exceptionsc C s< t di | j�� d | j�� �}tr6|t di | jd d �fS |fS )Nr$ r� )r r� rI � get_exemplar� _use_createdr� )rR �sampler. r. r/ r� - s �zCounter._child_samples)r N)rj ri r� �__doc__rL rq �floatr r rT r� � Exceptionr � BaseExceptionr r� r r r� r. r. r. r/ r� � s r� c s� e Zd ZdZdZed�Zddddeddfeee e eeee e e e e ed� � fd d � Z dd �d d �Zd"edd�dd�Zd#edd�dd�Zedd�dd�Zdd �dd�Zed �dd�Zed �dd �Zeg ef dd �d d �Ze e d �d d!�Z� Z S )$�Gaugea� Gauge metric, to report instantaneous values. Examples of Gauges include: - Inprogress requests - Number of items in a queue - Free memory - Total memory - Temperature Gauges can go both up and down. from prometheus_client import Gauge g = Gauge('my_inprogress_requests', 'Description of gauge') g.inc() # Increment by 1 g.dec(10) # Decrement by given value g.set(4.2) # Set to a given value There are utilities for common use cases: g.set_to_current_time() # Set to current unixtime # Increment when entered, decrement when exited. @g.track_inprogress() def f(): pass with g.track_inprogress(): pass A Gauge can also take its value from a callback: d = Gauge('data_objects', 'Number of objects') my_dict = {} d.set_function(lambda: len(my_dict)) Zgauge)�min�maxZlivesumZliveall�allr. r! Nr� ) r* rl r8 r+ r, r- rm rP �multiprocess_modec sH | | _ | | jvr td| ��t� j||||||||d� | j | jd< d S )NzInvalid multiprocess mode: �r* rl r8 r+ r, r- rm rP r� )�_multiprocess_mode�_MULTIPROC_MODESr( �superrs rn ) rR r* rl r8 r+ r, r- rm rP r� �r� r. r/ rs _ s � zGauge.__init__rA c C s( t j| j| j| j| j| j| jd�| _d S )N)r� )r r� rL rW rO rP r� r� rQ r. r. r/ rq y s �zGauge._metric_initr �r� rB c C s | � � | j�|� dS )z$Increment gauge by the given amount.N�rU r� r� �rR r� r. r. r/ r� s z Gauge.incc C s | � � | j�| � dS )z$Decrement gauge by the given amount.Nr� r� r. r. r/ �dec� s z Gauge.dec)r` rB c C s | � � | j�t|�� dS )z Set gauge to the given value.N)rU r� �setr� )rR r` r. r. r/ r� � s z Gauge.setc C s | � t�� � dS )z"Set gauge to the current unixtime.N)r� r� rQ r. r. r/ �set_to_current_time� s zGauge.set_to_current_timec C s | � � t| �S )z�Track inprogress blocks of code or functions. Can be used as a function decorator or context manager. Increments the gauge when the code is entered, and decrements when it is exited. )rU r rQ r. r. r/ �track_inprogress� s zGauge.track_inprogressc C s t | d�S )z�Time a block of code or function, and set the duration in seconds. Can be used as a function decorator or context manager. r� �r rQ r. r. r/ r� � s z Gauge.time)�frB c s2 | � � ttt d�� fdd� }t�|| �| _dS )z�Call the provided function to return the Gauge value. The function must return a float, and may be called from multiple threads. All other methods of the Gauge become NOOPs. )r" rB c s t di t� � �d d �fS �Nr! )r r� )r" �r� r. r/ �samples� s z#Gauge.set_function.<locals>.samplesN)rU r� r r �types� MethodTyper� )rR r� r� r. r� r/ � set_function� s zGauge.set_functionc C s t di | j�� d d �fS r� )r r� rI rQ r. r. r/ r� � s zGauge._child_samples)r )r ) rj ri r� r� rL � frozensetr� r rT r r r r rs rq r� r� r� r� r� r r� r r� r r� r r� � __classcell__r. r. r� r/ r� 7 s< $� � r� c @ sX e Zd ZdZdZdgZdd�dd�Zedd�d d �Ze d�d d �Z e e d�d d�Z dS )�Summarya� A Summary tracks the size and number of events. Example use cases for Summaries: - Response latency - Request size Example for a Summary: from prometheus_client import Summary s = Summary('request_size_bytes', 'Request size (bytes)') s.observe(512) # Observe 512 (bytes) Example for a Summary using time: from prometheus_client import Summary REQUEST_TIME = Summary('response_latency_seconds', 'Response latency (seconds)') @REQUEST_TIME.time() def create_response(request): '''A dummy function''' time.sleep(1) Example for using the same Summary object as a context manager: with REQUEST_TIME.time(): pass # Logic to be timed �summaryZquantileNrA c C sR t �| j| j| jd | j| j�| _t �| j| j| jd | j| j�| _t�� | _ d S )N�_count�_sum) r r� rL rW rO rP r� r� r� r� rQ r. r. r/ rq � s �"zSummary._metric_initr� c C s$ | � � | j�d� | j�|� dS �af Observe the given amount. The amount is usually positive or zero. Negative values are accepted but prevent current versions of Prometheus from properly detecting counter resets in the sum of observations. See https://prometheus.io/docs/practices/histograms/#count-and-sum-of-observations for details. r N)rU r� r� r� r� r. r. r/ �observe� s zSummary.observec C s t | d�S �z�Time a block of code or function, and observe the duration in seconds. Can be used as a function decorator or context manager. r� r� rQ r. r. r/ r� � s z Summary.timec C sP t di | j�� d d �t di | j�� d d �g}trH|�t di | jd d �� t|�S )Nr� r� r� )r r� rI r� r� �appendr� r5 )rR r� r. r. r/ r� � s �zSummary._child_samples)rj ri r� r� rL r6 rq r� r� r r� r r r� r. r. r. r/ r� � s r� c s� e Zd ZdZdZdgZdddddd d d d d ddddefZddddedefe e e e e e e e e e e e e eee f d� � fdd� Ze eee f dd�dd�Zdd�d d �Zd%ee ee e f dd �d d �Zed�d!d"�Ze e d�d#d$�Z� ZS )&� Histograma A Histogram tracks the size and number of events in buckets. You can use Histograms for aggregatable calculation of quantiles. Example use cases: - Response latency - Request size Example for a Histogram: from prometheus_client import Histogram h = Histogram('request_size_bytes', 'Request size (bytes)') h.observe(512) # Observe 512 (bytes) Example for a Histogram using time: from prometheus_client import Histogram REQUEST_TIME = Histogram('response_latency_seconds', 'Response latency (seconds)') @REQUEST_TIME.time() def create_response(request): '''A dummy function''' time.sleep(1) Example of using the same Histogram object as a context manager: with REQUEST_TIME.time(): pass # Logic to be timed The default buckets are intended to cover a typical web/rpc request from milliseconds to seconds. They can be overridden by passing `buckets` keyword argument to `Histogram`. Z histogram�leg{�G�zt?g{�G�z�?g�������?g�������?g333333�?g�������?g �?g �?g �?� �?g @g @g @g $@r. r! N) r* rl r8 r+ r, r- rm rP �bucketsc s4 | � | � t� j||||||||d� | | jd< d S )Nr� r� )�_prepare_bucketsr� rs rn ) rR r* rl r8 r+ r, r- rm rP r� r� r. r/ rs " s � zHistogram.__init__)�source_bucketsrB c C sZ dd� |D �}|t |�kr"td��|r<|d tkr<|�t� t|�dk rPtd��|| _d S )Nc S s g | ] }t |��qS r. )r� )ry �br. r. r/ � <listcomp>; r| z.Histogram._prepare_buckets.<locals>.<listcomp>zBuckets not in sorted order���� z Must have at least two buckets)r� r( r r� r< � _upper_bounds)rR r� r� r. r. r/ r� : s zHistogram._prepare_bucketsrA c C s| g | _ t�� | _| jd }t�| j| j| jd | j| j�| _ | j D ]4}| j � t�| j| j| jd || jt |�f �� qBd S )N)r� r� �_bucket) �_bucketsr� r� rO r r� rL rW rP r� r� r� r )rR Zbucket_labelnamesr� r. r. r/ rq F s " �zHistogram._metric_initr� c C sp | � � | j�|� t| j�D ]L\}}||kr | j| �d� |rft|� | j| �t||t � � �� qlq dS r� ) rU r� r� � enumerater� r� r@ r� r r� )rR r� r= �ir r. r. r/ r� T s zHistogram.observec C s t | d�S r� r� rQ r. r. r/ r� h s zHistogram.timec C s� g }d}t | j�D ]B\}}|| j| �� 7 }|�tddt|�i|d | j| �� �� q|�tdi |d d �� | jd dkr�|�tdi | j�� d d �� t r�|�tdi | j d d �� t |�S )Ng r� r� r� r r� r� ) r� r� r� rI r� r r r� r� r� r� r5 )rR r� �accr� r r. r. r/ r� o s * zHistogram._child_samples)N)rj ri r� r� rL r6 r ZDEFAULT_BUCKETSr rT r r r r r r� rs r� rq r r� r r� r r� r� r. r. r� r/ r� � s6 ""� � r� c @ sF e Zd ZdZdZdd� Zeeef dd�dd�Ze e d �d d �Z dS ) �Infoa� Info metric, key-value pairs. Examples of Info include: - Build information - Version information - Potential target metadata Example usage: from prometheus_client import Info i = Info('my_build', 'Description of info') i.info({'version': '1.2.3', 'buildhost': 'foo@bar'}) Info metrics do not work in multiprocess mode. r% c C s t | j�| _t� | _i | _d S rM )r� rO �_labelname_setr ro r� rQ r. r. r/ rq � s zInfo._metric_initN)�valrB c C sV | j �|�� �r"td�| j|���| j� t|�| _W d � n1 sH0 Y dS )zSet info metric.z8Overlapping labels for Info metric, metric: {} child: {}N) r� � intersection�keysr( r} rO ro r~ r� )rR r� r. r. r/ r% � s �z Info.inforA c C s> | j �$ td| jdd d �fW d � S 1 s00 Y d S )N�_infor� )ro r r� rQ r. r. r/ r� � s zInfo._child_samples) rj ri r� r� rL rq r rT r% r r r� r. r. r. r/ r� } s r� c s� e Zd ZdZdZddddeddfeeee eeeee eee eee d� � fdd� Z dd �d d �Z edd �d d�Z e e d �dd�Z� ZS )�Enuma` Enum metric, which of a set of states is true. Example usage: from prometheus_client import Enum e = Enum('task_state', 'Description of enum', states=['starting', 'running', 'stopped']) e.state('running') The first listed state will be the default. Enum metrics do not work in multiprocess mode. r& r. r! N) r* rl r8 r+ r, r- rm rP �statesc sX t � j||||||||d� ||v r2td|� ���| sDtd|� ���| | jd< | _d S )Nr� z$Overlapping labels for Enum metric: z$No states provided for Enum metric: r� )r� rs r( rn �_states) rR r* rl r8 r+ r, r- rm rP r� r� r. r/ rs � s � z Enum.__init__rA c C s d| _ t� | _d S )Nr )r� r ro rQ r. r. r/ rq � s zEnum._metric_init)�staterB c C s@ | � � | j� | j�|�| _W d � n1 s20 Y dS )zSet enum metric state.N)rU ro r� �indexr� )rR r� r. r. r/ r� � s z Enum.statec sB � j �( � fdd�t� j�D �W d � S 1 s40 Y d S )Nc s4 g | ],\}}t d � j|i|� jkr&dnddd��qS )r! r r N)r rW r� )ry r� �srQ r. r/ r� � s �z'Enum._child_samples.<locals>.<listcomp>)ro r� r� rQ r. rQ r/ r� � s �zEnum._child_samples)rj ri r� r� rL r rT r r r rs rq r� r r r� r� r. r. r� r/ r� � s. � �r� )5rG � threadingr r� r� �typingr r r r r r r r r r r! r Zcontext_managersr r r Z metrics_corer r r r rm r r r r� r r �utilsr r r r r0 r4 r9 r@ �boolrK r� r r� r� r� r� r� r� r. r. r. r/ �<module> s6 0 *E~F $
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка