diVddlZddlZddlZddlmZmZddlmZm Z m Z ddl m Z dZ edhZdZd d d d Zd ZejdZdZdZdZdZdZdZdZdZdZdZdZdZ dS)N)MetricMETRIC_LABEL_NAME_RE)ExemplarSample Timestamp)floatToGoStringc#XKttj|Ed{VdS)z^Parse Openmetrics text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)texts Dlib/python3.11/site-packages/prometheus_client/openmetrics/parser.pytext_string_to_metric_familiesr s9 *(*;D*A*ABBBBBBBBBBBinfc\t|}|tvrdS|t|kS)NF)float_CANONICAL_NUMBERSr )sfs r_isUncanonicalNumberrs3 aA""u "" ""r\ ")z\\z\nz\"cBt|dS)Nr)ESCAPE_SEQUENCESgroup)matchs r_replace_escape_sequencer&s EKKNN ++rz\\[\\n"]cBtt|SN) ESCAPING_REsubr)rs r_replace_escapingr$-s ??3Q 7 77rcg}d}|D]}|ro|dkr|dnP|dkr|dn4|dkr|dn|d|zd}s|dkrd}||||r|dd|S)NFrrnrT)appendjoin)r resultslashchars r_unescape_helpr-1s F E$$  $t| + d#### + c"""" + d#### dTk***EEt| $ d####  d 776??rcd|}||ksd|vrtd| t|S#t$rt |cYSwxYw)Nr'_zInvalid value: )r)strip ValueErrorintr)values r _parse_valuer4Ls GGENNE  6645445555zz U||sAA0/A0c xd|}|sdS||ksd|vrtd| tt |dS#t$r |dd}tt |dt |dddddcYS#t$rPt|}tj |stj |rtd||cYcYSwxYwwxYw) Nr'r/zInvalid timestamp: r. 0) r)r0r1rr2splitljustrmathisnanisinf) timestamppartstss r_parse_timestamprBVsY ""I tIOO%%%> )9>L !A#!5 !   !<#3s#: !  Ac,'''  &&sA..,\"1"-=qAAQ c,''' AI$Qy[1K{" =/ << '-j99 J !AD!HIIIV# P !G$!NOOO!,F: $IMNN3J$$S))   #JKK0J !jAo !  c1 !f 444+d23334s E;FF,c<d}|d}|dks ||d|vrR|d}|d|}||dzd}t|\}}}t|i|||S|d|}||vr2|d} ||dz| } t | } n/t ||dzd\} } | t|z} || dzd}t|\}}}t|| |||S)Nz # {r[rTr7rJr)findr\_parse_remaining_textrrindexrgrYr]) r separator label_startname_endnameremaining_textr3r?exemplar label_endlabelrVrWs r _parse_samplerusPI))C..Kb%J%J"y(dBy(;;;   D +KK$$ [1_Y./u%%>d;QR?CSCS>TUU T* )a-..)N!6~!F!FE9h $y( ; ;;rc>|dd}t|d}t|dkr|ddfSg}g}g}d}d}|d}t|}|D]f} |dkr*| dkr|sd}| dkrd}|| 3|dkr| dkrd}Bt d|z|dkr| dkrd }ct d|z|d kr_| d krG|d |d } } t|| dz| }d }t d|z|d kr | d krd }|d kr| dkrd}t d|z|dkr;| dkr|st d|z| dkrd}4|| K|dkr|| h|dkr|st d|z|dkr|st d|z|dvrt d|zt|} d} |ntd| D}|dkrt d|zt|t|t|} || | fS)NrTr7rr?# exemplarspace exemplarhashrPexemplarstartoflabelsrirJexemplarparsedlabelsexemplarvaluespace exemplarvalueexemplartimestamp)ryrxrzr{c3ZK|]&\}}t|t|zV'dSr!)r]).0kvs r z(_parse_remaining_text..cs6RR$!Qc!ffs1vvoRRRRRRrzExemplar labels are too long: ) r:r4r]iterr(r1r\rlrgrBsumitemsr)r split_textvalr?exemplar_valueexemplar_timestampexemplar_labelsrUitr,rnrsrArrexemplar_lengths rrkrksC##J z!} % %C :!D$INO E a=D dB),), K ( ,s{ '9 '' '&  &&&& n $! ,s{ :' !1D!8999 o % ,s{ :/ !1D!8999 - - ,s{ :)-C$++c:J:JY "/[1_Y5N0O"P"P. !1D!8999 , , ,s{ -, * * ,s{ :' !1D!8999 o % ,s{ ,> , !1D!8999 ,+%%d++++ ) ) ,  % %d + + + 2I2)D0111 ##2,>2)D0111 bb2)D0111 ) $ $BH RR/:O:O:Q:QRRRRR S  F=DEE E   ( ( / 0 0   H rc&|dkriS|dkr)|j|kr|j}|d=|S|dkr|j}||=|S|dvr,|j|dzkr|j}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)rprVcopy)samplerptypds r_group_for_sampleros f}  iFK4/ M    jM j M    dG --&+ AQ2Q M    dG =rc< d}d} fd}|D]}|jtd}t|d}||ks |j|kr| |d d d dd d d|}|j}|dkrct |jd}|dkrd | krt dz|jkrt d z| |j|d vr|j |d vrd|d vrd |jdkrd | |dSdS) NcjtdkrtdzkrtdzrtdzrtdzsstdzrrtdzsrtdzdSdS) 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: )rr1)bucketcounthas_gsumhas_negative_bucketshas_negative_gsumhas_sumrpr3sr do_checksz#_check_histogram..do_checkss/ U6]] " =4t;<< <  I% I@4GHH H  Su SJTQRR R  U ULtSTT T Y8 Y YPSWWXX X  PG PG$NOO O# ^(9 ^UX\\]] ] ^ ^ ^ ^rrFrrrTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)rpr]rr?rrVr1r3)samplesrprr?rrsuffixgbrrrrrrr3s ` @@@@@@@r_check_histogramrs EI^^^^^^^^^^^^ !)!)D # a{ 3 3 :  1   EF#( GH % EK Y  )ahtn%%A1u ,'+$ Ba6k B !9D!@AAAw H !?$!FGGGFGEE , , )GEE x  )GG y  )Hw{ )$(!  rc # Kdg}d}tddggdgdgddgd fd }|D]}|d d kr |dd }|rtd |z|std|dkrd}G|dr|dd}t |dkrtd|z|dkr|rtd|z|dkrL|||| |V|dd} d}d}d} t} d} t} g}|dg}|ddkr+|td|zt |d}G|ddkrY|td|z|d}|dkrtd|zfd|d gD}|dd!kr| td"|z|d} td|zt|}|j|vrJ|||| |V|jd}d} d#}g}d} d} t} t} |jg}|d$kr|j vrtd%|zd&z|jkrK|j d'd(d(kst|j d'rtd)|zd&z|jkrEt|j ts+|j std*|zd+z|jksd,z|jkrEt|j ts+|j std-|z|d.krm|jkrbd/t|j d0d cxkrdkrnnt|j d0rtd1|zt!t#t%||}| || kr|| vrtd2|z| M|| krG|jdu| dukrtd3|z| #| |jkr|d4krtd5|znt} |jt!t#|j f}|j| ks|| vr||| ||} |j} | ||d$kr|j d6vrtd7|z|d4kr|j dkrtd8|z|d.kr(|jkr|j d/krtd9|z|jt dd:vr+t/j|j rtd;|z|jt ddvr|jd&s0|d?vr|jdstd@|z|||| |V|stdAdS)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)r'rrr)rrrr)rrr_info)counterrrrrc|d}t|gdgzD]6}||zvrtd|z|z||z7|d}|d}|r*|d|zstd|z|r|dvrtd|z|dvrt ||t ||||}||_|S) Nunknownr'zClashing name: r/z!Unit does not match metric name: )rrz(Units not allowed for this metric type: r)setgetr1addendswithrrr) rp documentationrunitrrmetric seen_names type_suffixess r build_metricz0text_fd_to_metric_families..build_metrics9  C-++C44t;<< * *Ff} * D !2T!9F!BCCC NN4&= ) ) ) )  M  D  I cDj11 I@4GHH H  PC// PG$NOO O 1 1 , Wd + + +mS$77  rr[rzReceived line after # EOF: zReceived blank linez# EOFTrwrTrPrz!Received metadata after samples: r7HELPzMore than one HELP for metric: TYPEzMore than one TYPE for metric: untypedzInvalid TYPE for metric: cg|]}|zSrDrD)rr&rps r z.text_fd_to_metric_families..s P P Pa P P Prr'UNITzMore than one UNIT for metric: rrzStateset 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: )rr7z4Stateset 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)rr1r^r:r]r-rrurprVr isinstancer3r2 is_integerrtuplesortedrrr?r(rr<r=rrr)fd allowed_nameseofrliner@rrrrr seen_groupsgroup_timestampgroup_timestamp_samplesrr series_idrprrs @@@rr r s DM CJj)555>>>999 M,w@w@ 8t  9D  C:TABB B 4233 3 7?m @CC __S ! !k @JJsA&&E5zzA~ : !1D!8999Qx4 MG M !Dt!KLLLQx4 +P&,t]CwOOOOOQx $ !ee "&*-%%'!&q Qx6! : O$%F%MNNN .uQx 8 8 qV# :O$%F%MNNNAh)#I$%@4%GHHH P P P P=3D3DS2$3O3O P P P qV# :O$%F%MNNNQx !1D!8999"4((F{-/ .P&,t]CwOOOOO{ $ "&*-%%'!ee !' j  DT%> D !;d!BCCCy FK/ >**4775@ >0t1DEE >!!5!<===y FK/ M' c:: MCIrs 777777771111111111######CCCeEll^###   ,,,bj%% 8886,!!!???DA4A4A4H<<<>SSSl&888vi1i1i1i1i1r