a ܌xdiV@sddlZddlZddlZddlmZmZddlmZm Z m Z ddl m Z ddZ edhZd d Zd d d dZddZedZddZddZddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Z dS)*N)MetricMETRIC_LABEL_NAME_RE)ExemplarSample Timestamp)floatToGoStringccstt|EdHdS)z^Parse Openmetrics text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)textr \/var/www/html/Ranjet/env/lib/python3.9/site-packages/prometheus_client/openmetrics/parser.pytext_string_to_metric_families srinfcCs t|}|tvrdS|t|kS)NF)float_CANONICAL_NUMBERSr)sfr r r _isUncanonicalNumbersr\ ")z\\z\nz\"cCst|dS)Nr)ESCAPE_SEQUENCESgroup)matchr r r _replace_escape_sequence&srz\\[\\n"]cCs tt|SN) ESCAPING_REsubr)rr r r _replace_escaping-srcCsg}d}|D]p}|rd|dkr(|dn6|dkr<|dn"|dkrP|dn|d|d}q |dkrrd}q ||q |r|dd|S)NFrrnrT)appendjoin)r resultslashcharr r r _unescape_help1s$     r'cCsVd|}||ksd|vr,td|z t|WStyPt|YS0dS)Nr!_zInvalid value: )r#strip ValueErrorintr)valuer r r _parse_valueLs   r-c Csd|}|sdS||ks&d|vr4td|ztt|dWStyz<|dd}tt|dt|dddddWYStyt|}t |st |rtd||YYS0Yn0dS) Nr!r(zInvalid timestamp: r. 0) r#r)r*rr+splitljustrmathisnanisinf) timestamppartstsr r r _parse_timestampVs    0 r:cCs6d}||kr*||d|dkr*|d7}q|ddkS)Nrr/rrr )rZcharposZ num_bslashesr r r _is_character_escapedls  r;cCsd}g}g}i}d}|D]}|dkrF|dkr4d}nd}||n|dkrj|dkr\d}n ||nd|dkr|dkrd }n td |n>|d kr|d krd }nd|dkrd |}t|std|||vrtd|d |||<g}g}d}n ||n|dkrF|dkr(d}n|dkr8d}n td |n|d krd }|d krj|d n:|dkr|dn$|dkr|dn|d |n(|dkr|dkrqn td ||d7}q||fS)NZstartoflabelnamer}Z endoflabels labelname=Zlabelvaluequoter labelvalueInvalid line: rZlabelvalueslashr!zInvalid line, bad label name: z$Invalid line, duplicate label name: Zendoflabelvalue,r r r/)r"r*r#rr)r stater=r?labels labels_lenr&lnr r r _parse_labels_with_state_machinetsl                      rGc Csi}|rd|vrt|}zR|rh|d}|d|}||dd}|rX|ddkr\t|dd}|rx|ddkr|t|r|ddkrtd}|t|kr|d|}t|d||sq|d7}q|d}|d|}d|vrt|}t|std|||vrtd ||||<||dd}|drFd} nd} || d}|r| dkrtq|WStytd |Yn0dS) Nr>r/rrrArzinvalid line, bad label name: z$invalid line, duplicate label name: zInvalid labels: )r*indexlenr;rrr startswith) r rDZ sub_labelsZ value_startZ label_nameZ value_substriZ quote_endZ label_valueZ next_commar r r _parse_labelssR               rMc Csd}|d}|dks&||d|vrj|d}|d|}||dd}t|\}}}t|i|||S|d|}||vr|d} ||d| } t| } n$t||dd\} } | t|} || dd}t|\}}}t|| |||S)Nz # {rHrBr/r<r)findrI_parse_remaining_textrrindexrMrGrJ) r separator label_startZname_endnameZremaining_textr,r7exemplar label_endlabelrDrEr r r _parse_samples$       rXcCsr|dd}t|d}t|dkr.|ddfSg}g}g}d}d}|d}t|}|D]j} |dkr| dkrv|svd}n| dkrd}n || qV|dkr| dkrd}n td|qV|dkr| dkrd }n td|qV|d kr*| d kr|d |d } } t|| d| }d }n td|qV|d krD| d krd }qV|d krl| dkr^d}n td|qV|dkr| dkr|std|n| dkrd}n || qV|dkrV|| qV|dkr|std||dkr|std||dvrtd|t |} d} |durht dd| D}|dkrTtd|t |t|t |} || | fS)NrBr/rr7# exemplarspace exemplarhashr@exemplarstartoflabelsrNr<exemplarparsedlabelsZexemplarvaluespaceZ exemplarvalueZexemplartimestamp)r[rZr\r]css"|]\}}t|t|VqdSr)rJ).0kvr r r cz(_parse_remaining_text..zExemplar labels are too long: ) r2r-rJiterr"r*rIrQrMr:sumitemsr)r Z split_textvalr7Zexemplar_valueZexemplar_timestampZexemplar_labelsrCitr&rSrVr9rUZexemplar_lengthr r r rPs                        rPcCs~|dkr iS|dkr2|j|kr2|j}|d=|S|dkrN|j}||=|S|dvrx|j|dkrx|j}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)rTrDcopy)samplerTtypdr r r _group_for_sampleos   rvc sBd}d}fdd}|D]}|jtd}t|d}||ks\|j|kr|durj|ddddddd|}|j}|dkrt|jd}|dkrddur|krtd |jkrtd ||jq&|d vr|jq&|d vrdq&|d vr&d|jdkr&dq&|dur>|dS)Ncstdkrtddur4kr4tdrLdurLtdrddurdtdssdurtdrrtdsrtddS) 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*r ZbucketcountZhas_gsumZhas_negative_bucketsZhas_negative_gsumZhas_sumrTr,r r do_checkss         z#_check_histogram..do_checksrnFrrprqTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)rTrJrvr7rrDr*r,) samplesrTrr7ryrsuffixgbr rwr _check_histogramsL         rc#sdg}d}tddggdgdgddgd fd d }|D]n}|d d krd|dd }|rttd||std|dkrd}qF|dr|dd}t|dkrtd||dkr|rtd||dkr:dur|||| |V|dd} d}d}d} t} d} t} g}|dg}|ddkrl|dur^td|t|d}n|ddkr|durtd||d}|dkrtd|fd d!|d"gD}n:|dd#kr| durtd$||d} n td|qFt|}|j|vrjdur8|||| |V|jd}d} d%}g}d} d} t} t} |jg}|d&kr|j vrtd'|d(|jkr|j d)d*d*kst |j d)rtd+|d(|jkrt |j t s|j std,|d-|jks"d.|jkrHt |j t sH|j sHtd/||d0kr|jkrd1t|j d2d krdkrnnt |j d2rtd3|ttt||}| dur|| kr|| vrtd4|| durH|| krH|jdu| dukrtd5|| durN| |jkrN|d6krNtd7|nt} |jtt|j f}|j| ks||| vr||| ||} |j} | ||d&kr|j d8vrtd9||d6kr|j dkrtd:||d0kr|jkr|j d1krtd;||jtddvrx|j d1krxtd?||jrF|d@vr|jd(sF|dAvr|jdsFtdB|qFdur|||| |V|stdCdS)DzParse 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!rzr|r)rzr|rpr)r{r}rp_info)counterrjrnrorics|dur d}t|gdgD].}||vrBtd||||q"|dur^d}|durjd}|r|d|std||r|dvrtd||dvrt||t||||}||_|S) Nunknownr!zClashing name: r(z!Unit does not match metric name: )rirlz(Units not allowed for this metric type: rm)setgetr*addendswithrrr~)rT documentationrtunitr~rZmetric) seen_names type_suffixesr r build_metrics&     z0text_fd_to_metric_families..build_metricrHrzReceived line after # EOF: zReceived blank linez# EOFTrYrBr@rz!Received metadata after samples: r/ZHELPzMore than one HELP for metric: ZTYPEzMore than one TYPE for metric: ZuntypedzInvalid TYPE for metric: csg|] }|qSr r )r^r )rTr r rbz.text_fd_to_metric_families..r!ZUNITzMore than one UNIT for metric: rrlzStateset missing label: rprqNaNzInvalid le label: z!Bucket value must be an integer: rzr{z Count value must be an integer: rjrrkzInvalid quantile label: zInvalid metric grouping: z*Mix of timestamp presence within a group: riz*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: )rr|rzrpr{r}z$Counter-like samples cannot be NaN: )rr|rzrpr{z)Counter-like samples cannot be negative: rm)rzTInvalid line only histogram/gaugehistogram buckets and counters can have exemplars: zMissing # EOF at end)rr*rKr2rJr'rrXrTrDr isinstancer,r+ is_integerrtuplesortedrvrfr7r"rr4r5rUr)fdZ allowed_nameseofrliner8r~rrtrrZ seen_groupsZgroup_timestampZgroup_timestamp_samplesrsrZ series_idr )rTrrr r s                                           "  $    r )!ior r4reZ metrics_corerrr~rrrutilsrrrrrrrcompilerrr'r-r:r;rGrMrXrPrvrr r r r r s4    BDV;