1jJ d dl mZ d dlmZ d dlZd dlZd dlZddlmZ ddl m
Z
ddl m Z ddl
mZ e n
# e$ r eZY nw xY wd Z G d
d e Zd
d ZdS ) )unicode_literals) defaultdictN )Metric)
MmapedDict)Sample)floatToGoStringzMultiprocess metricc d e Zd ZdZd dZed
d Zed Zed Zd Z dS ) MultiProcessCollectorz+Collector for files for multi-process mode.Nc | t j d }|r t j | st d || _ |r| | d S d S )Nprometheus_multiproc_dirz:env prometheus_multiproc_dir is not set or not a directory)osenvirongetpathisdir
ValueError_pathregister)selfregistryr s p/builddir/build/BUILD/cloudlinux-venv-1.0.11/venv/lib/python3.11/site-packages/prometheus_client/multiprocess.py__init__z MultiProcessCollector.__init__ s| <:>>"<==D [27==.. [ YZZ Z
$ d # # # # # $ $ Tc l t | }t || S )zMerge metrics from given mmap files.
By default, histograms are accumulated, as per prometheus wire format.
But if writing the merged data back to mmap files, use
accumulate=False to avoid compound accumulation.
)r
_read_metrics_accumulate_metrics)files
accumulatemetricss r mergezMultiProcessCollector.merge! s- (55e<<$88*MMMr c P i }i fd}| D ]}t j | d }|d } t j | }n!# t $ r |dk r |d dv rY o w xY w|D ]\ }}} || \ }
} } }
| |
}|t |
t | }|||
< |dk r;|d d d }|d |_
| | |
d |ffz | | | |
| |S )
Nc | }|sQt j | \ }}}t t | }||||fx}| < |S N)r jsonloadstuplesorteditems)keyval metric_namenamelabels
labels_key key_caches r
_parse_keyz7MultiProcessCollector._read_metrics.._parse_key1 sj --$$C
O,0JsOO) T6 "6&,,..#9#9 : :
(3T6:'NNinJr _r gauger )livealllivesum pid) r r basenamesplitr read_all_values_from_fileFileNotFoundErrorr r MP_METRIC_HELP_multiprocess_mode
add_sample)r r r1 fpartstyp file_valuesr* valueposr, r- r. r/ metricr8 r0 s @r r z#MultiProcessCollector._read_metrics, s ? ?AG$$Q''--c22E(C
( B1 E E $
'>>eAh2H&H&H H
$/
?
?UC8B
35 T6: [11> #K E EF+1GK('>> (3B3-C05aF-%%dJ5#, ,H%PPPP %%dJ>>>>
? s A A><A>c p | D ]
}t t }t d }|j }|j D ]#}|\ }}} }
} |j dk r|t
d |D f} |j dk r || | }
| |
k r| || < T|j dk r || | }
| |
k r| || < w|j dk r|| xx | z
cc< | |||f< |j dk rk|D ]T}|d d k rFt |d
}t
d |D }|| |xx | z
cc< nU|||fxx | z
cc< |||fxx | z
cc< %|j dk r| D ]p\ }}d }t | D ]6\ }} |j
d
z |d t | ffz f}|r || z
}|||< 1| ||< 7|r|||j
dz |f< qd | D |_ | S )Nc * t t S r$ )r float r r z;MultiProcessCollector._accumulate_metrics..Z s +e*<*< r r3 c * g | ]}|d dk |S )r r8 rJ .0ls r
z=MultiProcessCollector._accumulate_metrics.._ s" 3W3W3W!1QV A r minmaxr5 histogramr ler c 3 2 K | ]}|d dk |V dS )r rT NrJ rM s r z.t s* .Q.QQAaDDLLqLLLL.Q.Qr g _bucket_countc V g | ]&\ \ }}}t |t | | 'S rJ )r dict)rN name_r. rD s r rP z=MultiProcessCollector._accumulate_metrics.. s4 o o oE[_eVV[fUDLL% @ @ o o or ) valuesr rI
setdefaultsamplestyper' r> r) r( r- r )r r rF r^ bucketssamples_setdefaultsr- r. rD timestampexemplarwithout_pid_keycurrentrO bucket_value
without_ler\ accbucket
sample_keys r r z)MultiProcessCollector._accumulate_metricsV s nn&& 8 p 8 pF!%((G!"<"<==G!(!3 ^
5
5;<8feY;'))'+U3W3Wv3W3W3W-X-X&YO 0E99"4"4_e"L"L 7??7r s ' ' ' ' ' ' # # # # # # ! ! ! ! ! ! " " " " " " '@2 @2 @2 @2 @2F @2 @2 @2F s 5 ??