Iٝc@ ` d dl mZ d dlZd dlmZ d dlZd dlZd dlZd dlZd dl m
Z
m Z m Z ddl
mZ
ddlmZ ddlmZ d d lmZmZ d d
lmZ d d lmZmZmZ d d l m Z d d
l m Z m Z n-# e $ r% d d l!mZmZ d d
l"mZ d d l#mZmZmZ d dl$m Z m Z m Z Y nw xY w e%d Z& ej' dk Z(ej' dk Z)d Z*efdZ+ G d de Z, G d dee Z-defdZ.e.Z/efdZ0d Z1 G d d e Z2d Z3d Z4d)d Z5dd!e4fd"Z6dd!e4fd#Z7dd!e4fd$Z8d% Z9d& Z:d' Z; dd(l.prometheus_app/ sb M22
'++nb99::!-h
v!N!N vx(((xr& )r r1 s ` r$
make_wsgi_appr3 , s$ r& c e Zd ZdZd ZdS )_SilentHandlerz(WSGI handler that does not log requests.c dS z Log nothing.Nr2 selfformatargss r$ log_messagez_SilentHandler.log_message? r& N)__name__
__module__ __qualname____doc__r< r2 r& r$ r5 r5 < s) 22 r& r5 c e Zd ZdZdZdS )ThreadingWSGIServerz Thread per request HTTP server.TN)r> r? r@ rA daemon_threadsr2 r& r$ rC rC C s )) NNNr& rC r+ c t | }t || |t t }t j |j }d|_ | dS )z?Starts a WSGI server for prometheus metrics as a daemon thread.)
handler_class)targetTN) r3 r rC r5 threadingThread
serve_foreverdaemonstart)portaddrr apphttpdts r$ start_wsgi_serverrR K sV
!
!C dC)z8generate_latest..sample_line..] sr = = = 1 ##qyyu--55dEBBJJ3PUVVX X = = =r& r+ z {0:d}i z{0}{1} {2}{3}
) labelsr: joinsorteditems timestampintfloatnamer value)linelabelstrrf s r$ sample_linez$generate_latest..sample_lineZ s ; ''= = &t{'8'8':': ; ;= = =)> )> ? ?HH
H > % E$.,A,AD,H(I(IJJI '' Ix ! 2 2Fvv!555"--fb99@@Q PPP 6
MM++a..111
2 'n 5& BIN $J$4$4$6$6 7 7 ! !MFE MM/66v{F7=7K7S7STXZ_7`7`7h7himot7u7uw w
x
x
x MM188fMM N N N MM% !
776?? ! !' * **s D7E
E8 E33E8c | pd} | d D ]M}| d d dk rt j t j fc S Nt t fS )Nr+ rU ;r z application/openmetrics-text)splitstrip openmetricsr CONTENT_TYPE_LATEST)r accepteds r$ r r s !'RM!'',, 5 5 >># q ! ' ' ) )-K K K / 35
5
5
5 L / //r& c 8 e Zd ZdZeZd Zd Zed Z dS )MetricsHandlerz2HTTP handler that gives metrics from ``REGISTRY``.c | j }| j d }t t | j j }t ||| \ }}}| t |
d d | j | | | j
| d S )NAccept r )r headersr, r r pathqueryr%
send_responserg r send_header end_headerswfilewrite)r9 r r r r/ r0 r# s r$ do_GETzMetricsHandler.do_GET s = ((22
(49--344!-h
v!N!N 3v||C 0 0 344555&!!
r& c dS r7 r2 r8 s r$ r< zMetricsHandler.log_message r= r& c b t | j }t || t fd|i }|S )zWReturns a dynamic MetricsHandler class tied
to the passed registry.
r )r r> r} object)clsr cls_nameMyMetricsHandlers r$ factoryzMetricsHandler.factory s9 s|$$ 3-!+X 6 8 8 r& N)
r> r? r@ rA r
r r r< classmethodr r2 r& r$ r r sX <<H ! ! ! [ r& r c & | dt j dt j j }t |d 5 }| t | ddd n # 1 swxY w Y t j || dS )zWrite metrics to the given path.
This is intended for use with the Node exporter textfile collector.
The path must end in .prom for the textfile collector to process it..wbN) osgetpidrH current_threadidentopenr r rename)r r tmppathfs r$ write_to_textfiler s
!DD")++++y/G/I/I/O/OPG
gt + ))***+ + + + + + + + + + + + + + + Igt s #A11A58A5c " fd}|S )zDefault handler that implements HTTP/HTTPS connections.
Used by the push_to_gateway functions. Can be re-used by other handlers.c < t } fd| _ D ]\ }}| || t t | }|j dk r-t d |j |j d S )N)datac S )Nr2 )methods r$ z1default_handler..handle.. s V r& )timeouti z%error talking to pushgateway: {0} {1})
r
get_method
add_headerr r r codeIOErrorr: msg) requestr_ r` respr r r r urls r$ handlez default_handler..handle s #D))) +^^^ % %DAq q! $ $ $ $K((--gw-GG 9 AHH 48% % & &
& r& r2 )r r r r r r s ````` r$ default_handlerr s;
& & & & & & & & & Mr& c * fd}|S )zHandler that implements HTTP/HTTPS connections with Basic Auth.
Sets auth headers using supplied 'username' and 'password', if set.
Used by the push_to_gateway functions. Can be re-used by other handlers.c [Yd d } t j | }d|z } d|g t dS )z1Handler that implements HTTP Basic Auth.
Nz{0}:{1}r{ s Basic
Authorization)r: r base64 b64encoder~ r )
auth_value
auth_token auth_headerr r r passwordr r usernames
r$ r z"basic_auth_handler..handle s H$8"))(H==DDWMMJ )*55J#j0K NNO[9 : : :<VWgt<<>>>>>r& r2 )r r r r r r r r s ``````` r$ basic_auth_handlerr sG ? ? ? ? ? ? ? ? ? ? ? Mr& c 0 t d| ||||| dS )aN Push metrics to the given pushgateway.
`gateway` the url for your push gateway. Either of the form
'http://pushgateway.local', or 'pushgateway.local'.
Scheme defaults to 'http' if none is provided
`job` is the job label to be attached to all pushed metrics
`registry` is an instance of CollectorRegistry
`grouping_key` please see the pushgateway documentation for details.
Defaults to None
`timeout` is how long push will attempt to connect before giving up.
Defaults to 30s, can be set to None for no timeout.
`handler` is an optional function which can be provided to perform
requests to the 'gateway'.
Defaults to None, in which case an http or https request
will be carried out by a default handler.
If not None, the argument must be a function which accepts
the following arguments:
url, method, timeout, headers, and content
May be used to implement additional functionality not
supported by the built-in default handler (such as SSL
client certicates, and HTTP authentication mechanisms).
'url' is the URL for the request, the 'gateway' argument
described earlier will form the basis of this URL.
'method' is the HTTP method which should be used when
carrying out the request.
'timeout' requests not successfully completed after this
many seconds should be aborted. If timeout is None, then
the handler should not set a timeout.
'headers' is a list of ("header-name","header-value") tuples
which must be passed to the pushgateway in the form of HTTP
request headers.
The function should raise an exception (e.g. IOError) on
failure.
'content' is the data which should be used to form the HTTP
Message Body.
This overwrites all metrics with the same job and grouping_key.
This uses the PUT HTTP method.PUTN _use_gatewaygatewayjobr grouping_keyr handlers r$ push_to_gatewayr s% R h gwOOOOOr& c 0 t d| ||||| dS )a" PushAdd metrics to the given pushgateway.
`gateway` the url for your push gateway. Either of the form
'http://pushgateway.local', or 'pushgateway.local'.
Scheme defaults to 'http' if none is provided
`job` is the job label to be attached to all pushed metrics
`registry` is an instance of CollectorRegistry
`grouping_key` please see the pushgateway documentation for details.
Defaults to None
`timeout` is how long push will attempt to connect before giving up.
Defaults to 30s, can be set to None for no timeout.
`handler` is an optional function which can be provided to perform
requests to the 'gateway'.
Defaults to None, in which case an http or https request
will be carried out by a default handler.
See the 'prometheus_client.push_to_gateway' documentation
for implementation requirements.
This replaces metrics with the same name, job and grouping_key.
This uses the POST HTTP method.POSTNr r s r$ pushadd_to_gatewayr s$ . #x wPPPPPr& c 0 t d| |d||| dS )a Delete metrics from the given pushgateway.
`gateway` the url for your push gateway. Either of the form
'http://pushgateway.local', or 'pushgateway.local'.
Scheme defaults to 'http' if none is provided
`job` is the job label to be attached to all pushed metrics
`grouping_key` please see the pushgateway documentation for details.
Defaults to None
`timeout` is how long delete will attempt to connect before giving up.
Defaults to 30s, can be set to None for no timeout.
`handler` is an optional function which can be provided to perform
requests to the 'gateway'.
Defaults to None, in which case an http or https request
will be carried out by a default handler.
See the 'prometheus_client.push_to_gateway' documentation
for implementation requirements.
This deletes metrics with the given job and grouping_key.
This uses the DELETE HTTP method.DELETENr )r r r r r s r$ delete_from_gatewayr : s$ * 7C|WgNNNNNr& c t | }|j rt st r |j dvrd | } dj |gt d| R }d} | dk rt
| } |i }|d d t | D z
} ||| |d t fg|
d S ) N)httphttpsz
http://{0}z{0}/metrics/{1}/{2}r r& r r+ c 3 K | ]9\ }} d j t t | t | V :dS )z/{0}/{1}N)r: _escape_grouping_keyr r] s r$ z _use_gateway..b s[ 2 2 Aq
/AA??@2 2 2 2 2 2r& r )r r r r r ) r schemePYTHON376_OR_NEWERPYTHON26_OR_OLDERr: r r rc rd re r )
r r r r r r r gateway_urlr r s
r$ r r R s* 7##K /
/#4/"*;;; %%g..
&
&w
R1EeS1Q1Q
R
R
RC D
x(( 277 2 2<--//002 2 2 2 2 2CGG "567d r& c |dk r| dz dfS d|v r?| dz t j | d d fS | t | fS )Nr+ z@base64=/r{ )r urlsafe_b64encoder decoder )r_ r` s r$ r r l si Bww9}c!! 9}f 6qxx7H7H I I P PQX Y YYY*Q-- r& c t t j t j t j 5 } | d d| d icddd S # 1 swxY w Y dS )z>Grouping key with instance set to the IP Address of this host.) localhostr instancer N)r socketAF_INET
SOCK_DGRAMconnect getsockname)r s r$ instance_ip_grouping_keyr w s v~v/@AA B B 0a "###AMMOOA ./0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0s 1A55A9<A9)
make_asgi_app)NN)>
__future__r r
contextlibr r r sysrH wsgiref.simple_serverr r r r r r r
utilsr BaseHTTPServerr r
SocketServerr urllib2r r r urllibr r r ImportError http.server socketserverurllib.request urllib.parser r version_infor r r% r3 r5 rC rR start_http_serverr r r r r r r r r r r r asgir r2 r& r$ r s ' ' ' ' ' '
M M M M M M M M M M 2 2 2 2 2 2 " " " " " " <AAAAAAAA++++++::::::::::!!!!!!+++++++++ < < <>>>>>>>>++++++AAAAAAAAAA;;;;;;;;;;;; < cDEE ,$v- % 1 F F F $
' .* "$h & & <+ <+ <+ <+~0 0 0! ! ! ! ! + ! ! ! H $ ( .22 )P )P )P )PZ .22 Q Q Q Q6 $(_O O O O0 4 0 0 0 ######## DDs &A% %'BB D( (D-