MhhddlZddlmZddlZddlmZddlZddlZddlm Z ddl Z ddl Z ddl Z ddl mZmZmZmZmZmZmZmZddlmZddlmZmZmZddlmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&d d l'm(Z'd d l)m*Z*m+Z+d d l,m-Z-d dl.m/Z/dZ0dZ1 Gdde Z2dZ3e+dfde*de4defdZ5Gdde%Z6Gdde e&Z7dZ8 dNde9de9d e:d!ee9d"ee9d#e4de j;fd$Zffd*Z?e?Z@e+fde*deAfd+ZBd,e9deee*geAfe9ffd-ZCd.e9de4fd/ZDGd0d1eZEd2e9de*ddfd3ZFd4e9d5e9d6eeGd7eee9e9fd8eAd9eeeHfdegdffd:ZId4e9d5e9d6eeGd7eee9e9fd8eAdegdff d;ZJd4e9d5e9d6eeGd7eee9e9fd8eAdegdff d<ZK dOd4e9d5e9d6eeGd7eee9e9fd8eAd=ee9d>ee9degdffd?ZLde jMdfd4e9d5e9d6eeGd7eee9e9fd8eAde9de9d!ee9d e:d@e4degdffdAZNddBeJfdCe9dDe9de*dEeee9efd6eeGdFeddfdGZOddBeJfdCe9dDe9dee*dEeee9efd6eeGdFeddfdHZPddBeJfdCe9dDe9dEeee9efd6eeGdFeddf dIZQd5e9dCe9dDe9dee*dEeee9efd6eeGdFeddfdJZRdKZSdee9effdLZTd dMlUmVZVdS)PN)closing)BaseHTTPRequestHandler)ThreadingMixIn)AnyCallableDictListOptionalSequenceTupleUnion) HTTPError)parse_qs quote_plusurlparse) BaseHandler build_opener HTTPHandlerHTTPRedirectHandler HTTPSHandlerRequest) make_serverWSGIRequestHandler WSGIServer) exposition)CollectorRegistryREGISTRY)floatToGoString)_is_valid_legacy_metric_name) CONTENT_TYPE_LATESTdelete_from_gatewaygenerate_latestinstance_ip_grouping_key make_asgi_app make_wsgi_appMetricsHandlerpush_to_gatewaypushadd_to_gatewaystart_http_serverstart_wsgi_serverwrite_to_textfilez(text/plain; version=0.0.4; charset=utf-8ceZdZdZdZdS)_PrometheusRedirectHandleraw Allow additional methods (e.g. PUT) and data forwarding in redirects. Use of this class constitute a user's explicit agreement to the redirect responses the Prometheus client will receive when using it. You should only use this class if you control or otherwise trust the redirect behavior involved and are certain it is safe to full transfer the original request (method and data) to the redirected URL. For example, if you know there is a cosmetic URL redirect in front of a local deployment of a Prometheus server, and all redirects are safe, this is the class to use to handle redirects in that case. The standard HTTPRedirectHandler does not forward request data nor does it allow redirected PUT requests (which Prometheus uses for some operations, for example `push_to_gateway`) because these cannot generically guarantee no violations of HTTP RFC 2616 requirements for the user to explicitly confirm redirects that could have unexpected side effects (such as rendering a PUT request non-idempotent or creating multiple resources not named in the original request). ct|d|}|dvr|dvs |dvr|dvst|j||||t |dd|j|jd|j }||_ |S) a Apply redirect logic to a request. See parent HTTPRedirectHandler.redirect_request for parameter info. If the redirect is disallowed, this raises the corresponding HTTP error. If the redirect can't be determined, return None to allow other handlers to try. If the redirect is allowed, return the new request. This method specialized for the case when (a) the user knows that the redirect will not cause unacceptable side effects for any request method, and (b) the user knows that any request data should be passed through to the redirect. If either condition is not met, this should not be used. method)-./i3)GETHEAD)r1r2r3)POSTPUT z%20T)headersorigin_req_host unverifiabledata) getattr get_methodrfull_urlrreplacer9r:r<r0) selfreqfpcodemsgr9newurlm new_requests \/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/prometheus_client/exposition.pyredirect_requestz+_PrometheusRedirectHandler.redirect_requestBs$ C3>>#3#3 4 4,,,o1E1E?**qO/C/CCL$WbAA A NN3 & &K/     N)__name__ __module__ __qualname____doc__rJrKrIr.r.,s-*rKr.ct|\}}d|vr||d}||}d|fg}|s8t|r)tj|}|dd||fS)zBake output for metrics output.zname[] Content-Type)zContent-Encodinggzip200 OK)choose_encoderrestricted_registry gzip_acceptedrScompressappend) registry accept_headeraccept_encoding_headerparamsdisable_compressionencoder content_typeoutputr9s rI _bake_outputrbcs+=99G\6//x0@AA WX  F -.G 5=1G#H#H5v&&3444 Wf $$rKFrZr^returncfd}|S)z;Create a WSGI app which serves the metrics from a registry.c|d}|d}t|dd}|d}|dkrd}dg}d }n^|d kr.d }dg}d ||}n*|d dkrd}g}d }nt ||| \}}}||||gS)N HTTP_ACCEPTHTTP_ACCEPT_ENCODING QUERY_STRINGREQUEST_METHODOPTIONSrT)Allowz OPTIONS,GETrKr4z405 Method Not Allowedz"# HTTP {}: {}; use OPTIONS or GET PATH_INFOz /favicon.ico)getrformatencoderb) environstart_responser[r\r]r0statusr9rar^rZs rIprometheus_appz%make_wsgi_app..prometheus_appus M22 !(-C!D!D'++nb99::)* Y  F/0GFF u__-F/0G:AA&&QQXXZZFF [ !^ 3 3FGFF '38]Lbdjl'A'A #FGVvw'''xrKrP)rZr^rts`` rIr&r&rs*: rKceZdZdZdZdS)_SilentHandlerz(WSGI handler that does not log requests.cdSz Log nothing.NrPrAroargss rI log_messagez_SilentHandler.log_messagerKN)rLrMrNrOr{rPrKrIrvrvs)22rKrvceZdZdZdZdS)ThreadingWSGIServerzThread per request HTTP server.TN)rLrMrNrOdaemon_threadsrPrKrIr~r~s))NNNrKr~ctj||tjtj}t t |\}}}}}||dfS)z8Automatically select address family depending on address)typeflagsr)socket getaddrinfo SOCK_STREAM AI_PASSIVEnextiter)addressportinfosfamily_sockaddrs rI_get_best_familyrsP  w63EVM^ _ _ _E $T%[[ 1 1FAq!X 8A; rKcertfilekeyfileprotocolcafilecapathclient_auth_requiredc tj|}||\ |||n#t$r7}t |}t |} |d|d|d| d}~wwxYw |tjjn>#t$r1}t |}t |} |d| d}~wwxYw|rtj |_ | ||nD#t$r7}t |}t |} |d |d |d| d}~wwxYw|S) zLoad context supports SSL.rNz+Cannot load CA certificate chain from file z or directory z: )purposez*Cannot load default CA certificate chain: rrz$Cannot load server certificate file z or its private key file ) ssl SSLContextload_verify_locationsIOErrorrstrload_default_certsPurpose CLIENT_AUTH CERT_REQUIRED verify_modeload_cert_chain) rrrrrrssl_cxtexcexc_typerEs rI _get_ssl_ctxrsnh///G V/ I  ) )&& 9 9 9 9 I I ICyyHc((C(H$HH6<HHBEHHII I I  O  & &s{/F & G G G G O O OCyyHc((C(MMMNN N O 0!/C7CCCC CCC99#hhhBhBB/6BB.TmpServerzz8generate_latest..sample_line..s_@@@1!!1!44k6I!6L6LNN@@@rKrir8idz{{{0}}} {z} )labelsrojoinsorteditems timestampintfloatr namervaluerescape_metric_name)sampleslabelstrr maybe_commas rI sample_linez$generate_latest..sample_lines{ > ||CHH@@ &w~';';'='= > >@@@%A%ABBHH H   (DCg&7 8 84 ?@@DDDI ' 5 5 ] 6$++H55l\H\\w}/M/M\y\\\ \  KJK27<@@J+JxJJ\klsly\z\zJ}FJJJ JrKcounter_totalinfo_infogaugestatesetgaugehistogram histogramunknownuntypedz # HELP {} {} \z\\rz\nz# TYPE r8)_created_gsum_gcount)riNz gauge riutf-8)collectrrrYrorr documentationr@r setdefault Exceptionrzrrextendrrp) rZrrametricmnamemtype om_samplesssuffix exceptionliness rIr#r#sJJJ*F""$$(!(!! KEKE !!(&*$$***$)##! MM*11.u55v7K7S7STXZ_7`7`7h7himot7u7uww x x x MMUK$B5$I$IUUEUUU V V V/1J^ 2 2>22Fvv!555"--fb99@@QPPP6 MM++a..111 2   'n5&BIN  $J$4$4$6$677 ! !MFE MM*11+2PQWQ\_eQe2f2f282F2N2NtUZ2[2[2c2cdhjo2p2prr s s s MMbK$B6;QWCW$X$Xbbb c c c MM%  ! 776?? ! !' * **sEE-- F7F  Fr[c|pd}|dD]M}|dddkrtjtjfcSNttfS)Nrir;rzapplication/openmetrics-text)splitstriprr#r!)r[accepteds rIrUrU=s!'RM!'',,55 >>#  q ! ' ' ) )-K K K/35 5 5 5 L / //rKr\c|pd}|dD]H}|dddkrdSIdS)NrirrrrSTF)rrlower)r\rs rIrWrWFso39r*0055 >>#  q ! ' ' ) ) / / 1 1V ; ;44 < 5rKc^eZdZUdZeZeed<d dZde de ddfdZ e dede fd ZdS) r'z2HTTP handler that gives metrics from ``REGISTRY``.rZrcNc|j}|jd}|jd}tt |jj}t||||d\}}}|t| dd|D] }|j | | |j |dS)NAcceptzAccept-EncodingFr8r)rZr9rnrrpathqueryrb send_responserr send_header end_headerswfilewrite) rArZr[r\r]rsr9raheaders rIdo_GETzMetricsHandler.do_GETRs= ((22 !%!1!12C!D!D(49--344".xH^`fhm"n"n 3v||C00344555 & &F D f % % %       rKrorzcdSrxrPrys rIr{zMetricsHandler.log_messagear|rKcbt|j}t||tfd|i}|S)zWReturns a dynamic MetricsHandler class tied to the passed registry. rZ)rrLrobject)clsrZcls_nameMyMetricsHandlers rIfactoryzMetricsHandler.factoryds9s|$$3-!+X 688rKrcN)rLrMrNrOrrZr__annotations__r rrr{ classmethodrrrPrKrIr'r'Ns<<"*H*** ! ! ! !#cd  0  T    [    rKr'rc|dtjdtjj} t |d5}|t|dddn #1swxYwYtjdkrtj ||dStj ||dS#t$r5tj |rtj|wxYw)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..wbNnt)osgetpidrcurrent_threadidentopenrr#rr@renamerrexistsremove)rrZtmppathfs rIr,r,ts3 HH HHi&>&@&@&FHHG  '4  /A GGOH-- . . . / / / / / / / / / / / / / / / 7d?? Jw % % % % % Igt $ $ $ $ $  7>>' " "  Ig    s5B;#A2& B;2A66B;9A6:(B;$B;;?C:urlr0timeoutr9r< base_handlerc(dfd }|S)Nrcct }fd|_D]\}}|||t|}|jdkrt d|jd|jdS)N)r<cS)NrP)r0srIz/_make_handler..handle..sVrK)r#izerror talking to pushgateway: r8)rr> add_headerrrrDOSErrorrE) requestrrrespr$r<r9r0r#r"s rIhandlez_make_handler..handles#D)))+^^^ % %DAq   q! $ $ $ $L))..w.HH 9  Q49QQtxQQRR R  rKrrP)r"r0r#r9r<r$r-s`````` rI _make_handlerr.sQSSSSSSSSSSS MrKc4t|||||tS)zDefault handler that implements HTTP/HTTPS connections. Used by the push_to_gateway functions. Can be re-used by other handlers.)r.rr"r0r#r9r<s rIdefault_handlerr1s fgwk J JJrKc4t|||||tS)a Handler that automatically trusts redirect responses for all HTTP methods. Augments standard HTTPRedirectHandler capability by permitting PUT requests, preserving the method upon redirect, and passing through all headers and data from the original request. Only use this handler if you control or trust the source of redirect responses you encounter when making requests via the Prometheus client. This handler will simply repeat the identical request, including same method and data, to the new redirect URL.)r.r.r0s rIpassthrough_redirect_handlerr3s" fgw>X Y YYrKusernamepasswordc*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 KI d}tj|}d|z}d|ft dS)z1Handler that implements HTTP Basic Auth. N:sBasic Authorization)rpbase64 b64encoderYr1) auth_value auth_token auth_headerr<r9r0r5r#r"r4s rIr-z"basic_auth_handler..handles  H$8$11x1188::J)*55J#j0K NNO[9 : : :<VWgt<<>>>>>rKrP)r"r0r#r9r<r4r5r-s``````` rIbasic_auth_handlerr?sG??????????? MrKinsecure_skip_verifyc .tj|} || |n| | rd| _tj| _| ||t| } t|||||| S)aLHandler that implements an HTTPS connection with TLS Auth. The default protocol (ssl.PROTOCOL_TLS_CLIENT) will also enable ssl.CERT_REQUIRED and SSLContext.check_hostname by default. This can be disabled by setting insecure_skip_verify to True. Both this handler and the TLS feature on pushgateay are experimental.rNFr)r) rrrrcheck_hostname CERT_NONErrrr.) r"r0r#r9r<rrrrr@rhandlers rItls_auth_handlerrEs&nh///G %%f----""$$$,!&!m Xw???7+++G fgwg F FFrKgatewayjob grouping_keyrDc 0td||||||dS)aNPush 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.r7N _use_gatewayrGrHrZrIr#rDs rIr(r(s%\h gwOOOOOrKc 0td||||||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.r6NrKrMs rIr)r)-s$8#xwPPPPPrKc 0td||d|||dS)aDelete 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.DELETENrK)rGrHrIr#rDs rIr"r"Ls$47C|WgNNNNNrKct|}|jr |jdvrd|}|d}dj|gt d|R}d} |dkr|t }t |} |i}|dd t| Dz }||||d tfg| dS) N)httphttpszhttp:///z{}/metrics/{}/{}rHrKrPric 3K|]9\}}djtt|t|V:dS)z/{}/{}N)ro_escape_grouping_keyrrs rI z_use_gateway..sZ22 Aq -c!ffc!ff==>222222rKrRr0) rschemerstriprorVrr#rrrr!) r0rGrHrZrIr#rD gateway_urlr"r<s rIrLrLis17##K  &!3;L!L!L%G%%nnS!!G #  #G O.B5#.N.N O O OC D   Hx(( 27722<--//00222 2 22CGG  "567drKc|dkr|dzdfSd|vr?|dztj|ddfS|t |fS)Nriz@base64=rTr)r:urlsafe_b64encoderpdecoder)rrs rIrVrVsiBww9}c!! 9}f6qxx7H7HIIPPQXYYYY*Q--rKcPttjtjtj5}tjdkr|dn|dd|dicdddS#1swxYwYdS)z>Grouping key with instance set to the IP Address of this host.darwin)z10.255.255.255r) localhostrinstancerN)rrAF_INET SOCK_DGRAMsysplatformconnect getsockname)rs rIr$r$s v~v/@AA B B 0a <8 # # II+ , , , , II& ' ' 'AMMOOA./ 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0sABB"B)r%)NNF)NN)Wr: contextlibrrS http.serverrrr socketserverrrrertypingrrrr r r r r urllib.errorr urllib.parserrrurllib.requestrrrrrrwsgiref.simple_serverrrrrrrZrrutilsr validationr __all__r!r.rbboolr&rvr~rrrrrPROTOCOL_TLS_SERVERrr+r*bytesr#rUrWr'r,rrr.r1r3r?PROTOCOL_TLS_CLIENTrEr(r)r"rLrVr$asgir%rPrKrIrys   ...... '''''' NNNNNNNNNNNNNNNNNNNN""""""7777777777NMMMMMMMMM22222211111111""""""444444 A,44444!4444n % % %19V[  - t `h    F'.*!% $%* &&&&& &  & # & ^&&&&V&."&!%'+'+/%*$3-  #   }  }# :y' '(:&3;B+B+/B+uB+B+B+B+J0#0%:K9Le9S0TVY0Y*Z0000#$# # # # # +# # # LC+<* %%S/*    K-. b$h( K  K K% KeCHo& K  K b$h K K K KZ ZZ%ZeCHo& Z  Z b$h ZZZZ4#'"& %eCHo&    3- 3-b$hF!%/%*GG GG%GeCHo& G  G  GG GG#Gb$hGGGGL26#%+ .P.P.P .P$.PtCH~. .P % .P  .P .P.P.P.Pj26#%+ QQQ Q,-QtCH~. Q % Q  Q QQQQD26#%+ OOO OtCH~.O% O  O  OOOO:    ,-  tCH~.  %       F    0$sCx. 0 0 0 0  rK