Xha"ddlZddlZddlZddlmZddlmZmZm Z m Z m Z m Z ddl mZmZmZmZmZddlmZddlmZmZdZed hZd Zd d d dZdZej<dZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,y)N)Metric)_last_unquoted_char_next_unquoted_char _parse_value _split_quoted_unquote_unescape parse_labels) BucketSpanExemplarNativeHistogramSample Timestamp)floatToGoString)_is_valid_legacy_metric_name_validate_metric_namec#\Kttj|Ed{y7w)z^Parse Openmetrics text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)texts X/var/www/html/myenv/lib/python3.12/site-packages/prometheus_client/openmetrics/parser.pytext_string_to_metric_familiesrs! *(*;*;D*ABBBs ",*,infcFt|}|tvry|t|k7S)NF)float_CANONICAL_NUMBERSr)sfs r_isUncanonicalNumberrs' aA"" " ""\ ")z\\z\nz\"c2t|jdS)Nr)ESCAPE_SEQUENCESgroup)matchs r_replace_escape_sequencer(+s EKKN ++r z\\[\\n"]c6tjt|SN) ESCAPING_REsubr()rs r_replace_escapingr-2s ??3Q 77r cNg}d}|D]y}|r\|dk(r|jdnB|dk(r|jdn+|dk(r|jdn|jd|zd}a|dk(rd}i|j|{|r|jddj|S)NFr!r#nr"T)appendjoin)rresultslashchars r_unescape_helpr66s F E$ t| d# c" d# dTk*Et| d#$"  d 776?r c dj|}|sy||jk7sd|vrtd| tt |dS#t$r |j dd}tt |dt |dddj ddcYS#t$rJt|}tj|stj|rtd||cYcYSwxYwwxYw) Nr0_zInvalid timestamp: r. 0) r2strip ValueErrorrintsplitljustrmathisnanisinf) timestamppartstss r_parse_timestamprHQs "I IOO%% )9.ym<== Y++   OOC+ESq]Ca! 0B0B1c0J,KL L y!Bzz"~B #6ym!DEEI   s1A C<AB%"C<%AC83C<7C88C<cnd}||kDr'||dz |z dk(r|dz }||kDr||dz |z dk(r|dzdk(S)Nrr:r!r)rcharpos num_bslashess r_is_character_escapedrMgs_L \ !1|+,4  \ !1|+,4 ! q  r cd}t|d}|dk(s||d|vrPt|d}|d|}t|std|z||dzd}t|\}}}t |i|||S|d|}t|d} t ||dz| d} |sd | vrt| d }| d =nd | vr td || d zd}t|\}}}t || |||S) Nz # { zinvalid metric name:r:}T__name__z$metric name specified more than oncer)rrr>_parse_remaining_textrr ) r separator label_startname_endnameremaining_textvaluerEexemplar label_endlabelss r _parse_sampler^os'I%dC0KbIl{);;&tS1IX+D13d:; ;hlm,%:>%J"y(dBy(;;   D#D#.I ${Qy94 @F  V # j! :  v ?@@)a-.)N!6~!FE9h $y( ;;r c@|jdd}t|d}t|dk(r|ddfSg}g}g}d}d}|d}t|}d} |D](} | dk(r| } | r|dk(r$| dk(r|sd}| dk(rd }&|j | 8|d k(r| dk(rd}Et d |z|dk(r| dk(rd }`t d |z|d k(r@| d k(r-t |d } t|d } t|| dz| d}d}t d |z|dk(r | d k(sd}|dk(r| dk(rd}t d |z|dk(r0| dk(r|st d |z| dk(rd}|j | |dk(s|j | +|dk(r|st d |z|dk(r|st d |z|dvrt d |zt|} d}|Rtd|jD}|dkDrt d|zt|t|t|}|| |fS)NrQr:rrEFr## exemplarspace exemplarhashInvalid line: exemplarstartoflabelsrOrRTexemplarparsedlabelsexemplarvaluespace exemplarvalueexemplartimestamp)rbrardrec3PK|]\}}t|t|z ywr*)len).0kvs r z(_parse_remaining_text..s R$!Qc!fs1voRs$&zExemplar labels are too long: ) r@rrjiterr1r>rrr rHsumitemsr )r split_textvalrEexemplar_valueexemplar_timestampexemplar_labelsstateit in_quotesr5rVr\rGr[exemplar_lengths rrTrTsC#J z!} %C :!D$INO E a=D dBI., 3;% I   K s{9'&  & n $s{' !1D!899 o %s{/ !1D!899 - -s{1$< /c: ".tK!OI/NPT"U. !1D!899 , ,s{, * *s{' !1D!899 o %s{> !1D!899+%%d+ ) )  % %d +].,b I)D011 ##,>)D011 bb)D011 ) $BH"R/:O:O:QRR S =DE E   ( / 0  H r ct|d}d}d}d}t|d}|dk(ry||dk(rd}t|d|x}}|dk(rtt|d|d z}|dk(ryt|d |d z}|dk7r||kryt|d|}|dk(rt|rp||d z|} t| d} |} |d| } | j|r td | | sd | vrt| d } | d =| sd} ||d} t | }t | | ddd|S||d} |d z } |d| } | j|r td | t | }t | dddd|S)zJDetermines if the line has a native histogram sample, and parses it if so.rOrPrFz {NTrRr:r`zIthe sample name of a native histogram with labels should have no suffixesrSz=the sample name of a native histogram should have no suffixes)rr>r endswith_parse_nh_structr)rsuffixes labels_start labels_endihas_metric_labelsnh_value_startr[ nh_value_end labelstextr]rWrXnh_valuenat_hist_values r_parse_nh_samplers&tS1LJ AD$'ABw Aw#~ ,T3:: Q   )sAE:N#4a!e4H2~(^3&tS.ALr,*:6 j$/IX == "hjno o'  *%Dz"()(3dFD$nEE(!A%IX == "\^bc c)(3dD$dNCCr c d}tjd}tjd}ttj||}|j|}t|j|}t |d}t |d}t |d} t |d} t |d} t |d } t |d } t|d }t|d }t||| | | | | || S)Nz(\w+):\s*([^,}]+)z8(positive_spans|negative_spans):\[(\d+:\d+(,\d+:\d+)*)\]z8(positive_deltas|negative_deltas):\[(-?\d+(?:,-?\d+)*)\]countrqschemazero_threshold zero_countpositive_spansnegative_spanspositive_deltasnegative_deltas) count_value sum_valuerrr pos_spans neg_spans pos_deltas neg_deltas) recompiledictfindallr?r_compose_spans_compose_deltasr )rpatternre_spans re_deltasrr span_matchesdeltasrrrrrrrrrs rr~r~4s"GzzUVH VWI GT* +E##D)L )##D) *FeGn%KE%L!I x !F5!123NU<()J|-=>I|-=>I ):;J ):;J %  r c 8i}|D]S}|d}|djdDcgc]*}ttt|jd,}}|||<U||vryg}||D] \}} |j t || "t|} | Scc}w)zTakes a list of span matches (expected to be a list of tuples) and a string (the expected span list name) and processes the list so that the values extracted from the span matches can be used to compose a tuple of BucketSpan objectsrr:,:N)r@tuplemapr?r1r ) r spans_namespansr'keypairrZ out_spansstartendout_spans_tuples rrrUs EAh?DAhnnS>QRds3 301RRc IJ'1 s E3/01 I&O Ss/Bc||vry|j|}|!|jr|jd}tdD}|S)zTakes a list of deltas matches (a dictionary) and a string (the expected delta list name), and processes its elements to compose a tuple of integers representing the deltasNrc3NK|]}t|jywr*)r?r=)rkxs rrnz"_compose_deltas..zs;S^;s#%)getr=r@r)r deltas_name out_deltaselemsout_deltas_tuples rrrpsW& K(J*"2"2"4  %;U;; r c@|dk(riS|dk(r.|j|k(r|jj}|d=|S|dk(r|jj}||=|S|dvr1|j|dzk(r|jj}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)rXr]copy)samplerXtypds r_group_for_sampler~s f}  iFKK4/ MM    jM j MM    dG --&++ AQ2Q MM    dG ==r cb d}d} fd}|D]}|jtd}t|d}t|dk(r8||k7s|j|k7r||d d d dd d d|}|j}|dk(r`t |j d}|dkrd | krt dz|jkrt d z| |j|d vr |j |d vrd|d vsd |jdksd  ||yy) Nc"tdk7rtdzk7rtdzrtdzrtdzsstdzrrtdzsrtdzyy) Nz+Infz+Inf bucket missing: z!Count does not match +Inf value: z+_count must be present if _sum is present: z-_gcount must be present if _gsum is present: z1_sum/_gsum must be present if _count is present: z(Cannot have _sum with negative buckets: z6Cannot have negative _gsum with non-negative buckets: )rr>)bucketrhas_gsumhas_negative_bucketshas_negative_gsumhas_sumrXrZsr do_checksz#_check_histogram..do_checkss U6] "4t;< <  %@4GH H u}JTQR R  LtST T8):PSWWX X GG$NO O#(9UX\\] ]):#r rrFrrTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)rXrjrrErr]r>rZ)samplesrXr&rErrsuffixgbrrrrrrrZs ` @@@@@@@r_check_histogramrsj EI^^ #)D # a{ 3 v;!   : 1  EF#( GH % EKK Y ahhtn%A1u'+$!a6k !9D!@AAww !?$!FGGFGGE , ,GGE x G y Hww{$(!G#)J  r c # Kd}g}d}tddggdgdgddgd fd }d}d}|D]k}|d d k(r|dd }|rtd |z|s td|dk(rd}6|jdrFt|dd}t |dkrtd|zt |d\} } | st | st| |k(r rtd|z| |k7r5||| |  | }d} d}d} d}t}d}t}g} | g}|ddk(r  td|zt|d}  |ddk(rM|td|z|d}|dk(rtd|zj|dgDcgc]}||z }}a|dd k(r td!|z|d} td|z|d"k(r*d}t|td"}|d}t|}n d}t|}|j|vrl|sj||| |  t |j\} } | st | st| }d} d} d#}g} d}d}t}t}|jg}|d$k(r||jvrtd%|z|d&z|jk(rE|jjd'd(d(k(st|jd'rtd)|z|d&z|jk(rBt|j t"s(|j j%std*|z|d+z|jk(s|d,z|jk(rBt|j t"s(|j j%std-|z|d.k(rf||jk(rWd/t'|jjd0d cxkrdkrnnt|jd0rtd1|z|s)tt)t+|||j-}||k7r|vrtd2|z|J||k(rE|j.duduk7rtd3|z|,||j.kDr|d4k7rtd5|zt}|jtt)|jj-f}|j.k7s|vr j1|j3||}|j.}j3|n j1||d$k(r|j d6vrtd7|z|d4k(r|j dk7rtd8|z|d.k(r,||jk(r|j d/krtd9|z|jt |dd:vr-t5j6|j rtd;|z|jt |ddvr|jj;d&r?|d?vr|jj;dr`td@|z||| |  |s tdAycc}ww)BzParse Prometheus text format from a file descriptor. This is a laxer parser than the main Go parser, so successful parsing does not imply that the parsed text meets the specification. Yields Metric's. NF_total_created)r0rrr)rrrr)rrr_info)counterrrrrc|d}tj|gdgzD].}||zvrtd|z|zj||z0|d}|d}|r"|j d|zstd|z|r|dvrtd|z|dvr t ||t |t||||}||_|S) Nunknownr0zClashing name: r8z!Unit does not match metric name: )rrz(Units not allowed for this metric type: r) setrr>addr}rrrr) rX documentationrunitrrmetric seen_names type_suffixess r build_metricz0text_fd_to_metric_families..build_metrics ;C-++C4t;< *Ff} * !2T!9F!BCC NN4&= ) *  M <D  cDj1@4GH H C//G$NO O 1 1 Wd +d#mS$7  r rPr"zReceived line after # EOF: zReceived blank linez# EOFTr`rQrcrz!Received metadata after samples: r:HELPzMore than one HELP for metric: TYPEzMore than one TYPE for metric: untypedzInvalid TYPE for metric: r0UNITzMore than one UNIT for metric: rrrzStateset missing label: rrNaNzInvalid le label: z!Bucket value must be an integer: rrz Count value must be an integer: rrrzInvalid quantile label: zInvalid metric grouping: z*Mix of timestamp presence within a group: rz*Timestamps went backwards within a group: )rr:z4Stateset samples can only have values zero and one: z&Info samples can only have value one: z$Quantile values cannot be negative: )rrrrrrz$Counter-like samples cannot be NaN: )rrrrrz)Counter-like samples cannot be negative: r)rzTInvalid line only histogram/gaugehistogram buckets and counters can have exemplars: zMissing # EOF at end)rr> startswithrrjr rr6rrrr^rXr]r isinstancerZr? is_integerrsortedrrrrEr1rrBrCr[r})fdrX allowed_nameseofris_nhrlinerFcandidate_namequotedrrrr& seen_groupsgroup_timestampgroup_timestamp_samplesr/rr series_idrrs @@rrrs DM CJj)5>9 M. E CJ@ 8t 9D :TAB B23 3 7?C __S !!$Q/E5zA~ !1D!899%6uQx%@ "NF">~"N  %' !Dt!KLL%#&t]CwOO% $ !e "&*-%'!/ 0 Qx6! ,$%F%MNN .uQx 8 qV#?$%F%MNNAh)#$%@4%GHH3@3D3DS2$3O Pa P PqV##$%F%MNNQx !1D!899k!)$mK6P0QR>!E*40F&t,{{-/#&t]CwOO):6;;)G&&B>&R$$% $ "&*-%'!e !' j T%> !;d!BCCy FKK/**475@0t1DE !5!<==y FKK/' c:6<rs !ON#LCEl^#   ,bjj% 86,!<>YxGDTB6 &:z1r