ó 6]c@sŒddlmZddlZddlmZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZyldd lmZmZdd lmZdd lmZmZmZdd lmZdd lmZmZWnoek rdd l mZmZdd l!mZdd l"mZmZmZddl#mZmZmZnXe$dƒZ%ej&d'kZ'ed„Z(de fd„ƒYZ)ded„Z*ed„Z+d„Z,defd„ƒYZ-deefd„ƒYZ.ded„Z/d„Z0d„Z1ddd „Z3dd!e1d"„Z4dd!e1d#„Z5dd!e1d$„Z6d%„Z7d&„Z8dS((iÿÿÿÿ(tunicode_literalsN(tclosing(t make_servertWSGIRequestHandleri(t exposition(tREGISTRY(tfloatToGoString(tBaseHTTPRequestHandlert HTTPServer(tThreadingMixIn(t build_openertRequestt HTTPHandler(t quote_plus(tparse_qsturlparse(R RRu(text/plain; version=0.0.4; charset=utf-8iics‡fd†}|S(u;Create a WSGI app which serves the metrics from a registry.c sœt|jddƒƒ}ˆ}t|jdƒƒ\}}d|kr[|j|dƒ}n||ƒ}tdƒ}tdƒ|fg}|||ƒ|gS(Nu QUERY_STRINGuu HTTP_ACCEPTuname[]u200 OKu Content-type(Rtgettchoose_encodertrestricted_registrytstr( tenvirontstart_responsetparamstrtencodert content_typetoutputtstatustheaders(tregistry(s;lib/python2.7/site-packages/prometheus_client/exposition.pytprometheus_app's    ((RR((Rs;lib/python2.7/site-packages/prometheus_client/exposition.pyt make_wsgi_app$s t_SilentHandlercBseZdZd„ZRS(u(WSGI handler that does not log requests.cGsdS(u Log nothing.N((tselftformattargs((s;lib/python2.7/site-packages/prometheus_client/exposition.pyt log_message:t(t__name__t __module__t__doc__R$(((s;lib/python2.7/site-packages/prometheus_client/exposition.pyR 7sucCsPt|ƒ}t|||dtƒ}tjd|jƒ}t|_|jƒdS(u?Starts a WSGI server for prometheus metrics as a daemon thread.t handler_classttargetN( RRR t threadingtThreadt serve_forevertTruetdaemontstart(tporttaddrRtappthttpdtt((s;lib/python2.7/site-packages/prometheus_client/exposition.pytstart_wsgi_server>s   c Csd„}g}xì|jƒD]Þ}yZ|j}|j}|dkrP|d}n^|dkro|d}d}n?|dkr„d}n*|dkr™d }n|d kr®d }n|jd j||jjd dƒjddƒƒƒ|jdj||ƒƒi}xw|jD]l}xcdddgD]?}|j|j|kr!|j|gƒj||ƒƒPq!q!W|j||ƒƒq WWn/t k r­} | j pšd|f| _ ‚nXxIt |j ƒƒD]5\}} |jdj|j|ƒƒ|j | ƒqÁWqWdj|ƒjdƒS(uHReturns the metrics from the registry in latest text format as a string.c SsÞ|jr|djdjgt|jjƒƒD]B\}}dj||jddƒjddƒjdd ƒƒ^q+ƒƒ}nd }d }|jdk r¼d jtt |jƒd ƒƒ}nd j|j |t |j ƒ|ƒS(Nu{{{0}}}u,u {0}="{1}"u\u\\u u\nu"u\"uu {0:d}ièu{0}{1} {2}{3} ( tlabelsR"tjointsortedtitemstreplacet timestamptNonetinttfloattnameRtvalue(tlinetktvtlabelstrR<((s;lib/python2.7/site-packages/prometheus_client/exposition.pyt sample_lineJs  d%ucounteru_totaluinfou_infougaugeustatesetugaugehistogramu histogramuunknownuuntypedu# HELP {0} {1} u\u\\u u\nu# TYPE {0} {1} u_createdu_gsumu_gcountuu# TYPE {0}{1} gauge uutf-8(u(tcollectR@ttypetappendR"t documentationR;tsamplest setdefaultt ExceptionR#R9R:textendR8tencode( RRFRtmetrictmnametmtypet om_sampleststsuffixt exceptiontlines((s;lib/python2.7/site-packages/prometheus_client/exposition.pytgenerate_latestGsD               (cCs_|p d}xF|jdƒD]5}|jdƒdjƒdkrtjtjfSqWttfS(Nuu,u;iuapplication/openmetrics-text(tsplittstript openmetricsRXtCONTENT_TYPE_LATEST(t accept_headertaccepted((s;lib/python2.7/site-packages/prometheus_client/exposition.pyR„s  tMetricsHandlercBs5eZdZeZd„Zd„Zed„ƒZRS(u2HTTP handler that gives metrics from ``REGISTRY``.cCsÉ|j}tt|jƒjƒ}t|jjdƒƒ\}}d|kra|j|dƒ}ny||ƒ}Wn|j ddƒ‚nX|j dƒ|j d|ƒ|j ƒ|j j|ƒdS(NuAcceptuname[]iôuerror generating metric outputiÈu Content-Type(RRRtpathtqueryRRRRt send_errort send_responset send_headert end_headerstwfiletwrite(R!RRRRR((s;lib/python2.7/site-packages/prometheus_client/exposition.pytdo_GET‘s    cGsdS(u Log nothing.N((R!R"R#((s;lib/python2.7/site-packages/prometheus_client/exposition.pyR$¡R%cCs2t|jƒ}t||tfi|d6ƒ}|S(uWReturns a dynamic MetricsHandler class tied to the passed registry. uregistry(RR&RHtobject(tclsRtcls_nametMyMetricsHandler((s;lib/python2.7/site-packages/prometheus_client/exposition.pytfactory¤s ( R&R'R(RRRhR$t classmethodRm(((s;lib/python2.7/site-packages/prometheus_client/exposition.pyR_s   t_ThreadingSimpleServercBseZdZeZRS(uThread per request HTTP server.(R&R'R(R.tdaemon_threads(((s;lib/python2.7/site-packages/prometheus_client/exposition.pyRo´scCsPtj|ƒ}t||f|ƒ}tjd|jƒ}t|_|jƒdS(u?Starts an HTTP server for prometheus metrics as a daemon threadR*N( R_RmRoR+R,R-R.R/R0(R1R2RtCustomMetricsHandlerR4R5((s;lib/python2.7/site-packages/prometheus_client/exposition.pytstart_http_server¾s  cCsad|tjƒtjƒjf}t|dƒ}|jt|ƒƒWdQXtj||ƒdS(u²Write 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.u%s.%s.%suwbN( tostgetpidR+tcurrent_threadtidenttopenRgRXtrename(R`Rttmppathtf((s;lib/python2.7/site-packages/prometheus_client/exposition.pytwrite_to_textfileÇs"cs‡‡‡‡‡fd†}|S(u…Default handler that implements HTTP/HTTPS connections. Used by the push_to_gateway functions. Can be re-used by other handlers.csštˆdˆƒ}‡fd†|_x$ˆD]\}}|j||ƒq+Wttƒj|dˆƒ}|jdkr–tdj|j|j ƒƒ‚ndS(NtdatacsˆS(N(((tmethod(s;lib/python2.7/site-packages/prometheus_client/exposition.pytÚR%ttimeoutiu%error talking to pushgateway: {0} {1}( R t get_methodt add_headerR R RwtcodetIOErrorR"tmsg(trequestRCRDtresp(R|RR}Rturl(s;lib/python2.7/site-packages/prometheus_client/exposition.pythandleØs ((R‡R}RRR|Rˆ((R|RR}RR‡s;lib/python2.7/site-packages/prometheus_client/exposition.pytdefault_handlerÓs cs%‡‡‡‡‡‡‡fd†}|S(uÕHandler 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.csˆdk rbˆdk rbdjˆˆƒjdƒ}tj|ƒ}d|}ˆjd|gƒntˆˆˆˆˆƒƒdS(u1Handler that implements HTTP Basic Auth. u{0}:{1}uutf-8sBasic u AuthorizationN(R=R"ROtbase64t b64encodeRIR‰(t auth_valuet auth_tokent auth_header(R|RR}tpasswordRR‡tusername(s;lib/python2.7/site-packages/prometheus_client/exposition.pyRˆës  ((R‡R}RRR|RRRˆ((R|RR}RRR‡Rs;lib/python2.7/site-packages/prometheus_client/exposition.pytbasic_auth_handlerås! icCs td||||||ƒdS(uNPush 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.uPUTN(t _use_gateway(tgatewaytjobRt grouping_keyRthandler((s;lib/python2.7/site-packages/prometheus_client/exposition.pytpush_to_gatewayøs)cCs td||||||ƒdS(u"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.uPOSTN(R’(R“R”RR•RR–((s;lib/python2.7/site-packages/prometheus_client/exposition.pytpushadd_to_gateway$scCs td||d|||ƒdS(uî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.uDELETEN(R’R=(R“R”R•RR–((s;lib/python2.7/site-packages/prometheus_client/exposition.pytdelete_from_gateway>sc Csét|ƒ}|j s+tr=|jdkr=dj|ƒ}ndj|t|ƒƒ}d} |dkrvt|ƒ} n|dkr‹i}n|djd„t|j ƒƒDƒƒ7}|d |d |d |d d t fgd| ƒƒdS(Nuhttpuhttpsu http://{0}u{0}/metrics/job/{1}R%uDELETEucss?|]5\}}djtt|ƒƒtt|ƒƒƒVqdS(u/{0}/{1}N(R"R R(t.0RCRD((s;lib/python2.7/site-packages/prometheus_client/exposition.pys csR‡R}RRu Content-TypeR|(uhttpuhttps( RtschemetPYTHON26_OR_OLDERR"R RXR=R8R9R:R\( R}R“R”RR•RR–t gateway_urlR‡R|((s;lib/python2.7/site-packages/prometheus_client/exposition.pyR’Vs     cCsMttjtjtjƒƒ)}|jdƒi|jƒdd6SWdQXdS(u>Grouping key with instance set to the IP Address of this host.u localhostiuinstanceN(u localhosti(RtsockettAF_INETt SOCK_DGRAMtconnectt getsockname(RT((s;lib/python2.7/site-packages/prometheus_client/exposition.pytinstance_ip_grouping_keyls! (ii(9t __future__RRŠt contextlibRRsRžtsysR+twsgiref.simple_serverRRR[RRRtutilsRtBaseHTTPServerRRt SocketServerR turllib2R R R turllibR RRt ImportErrort http.servert socketserverturllib.requestt urllib.parseRR\t version_infoRœRR R6RXRR_RoRrR{R‰R=R‘R—R˜R™R’R£(((s;lib/python2.7/site-packages/prometheus_client/exposition.pytsR          = '   +