a 9ahV@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 Clib/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 resultZslashcharr 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*splitljustrmathisnanZisinf) timestamppartstsr r r _parse_timestampVs    0 r8cCs6d}||kr*||d|dkr*|d7}q|ddkS)Nrr.rrr )rZcharposZ num_bslashesr r r _is_character_escapedls  r9cCsd}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%Zlnr r r _parse_labels_with_state_machinetsl                      rDc 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.rrr?rzinvalid line, bad label name: z$invalid line, duplicate label name: zInvalid labels: )r)indexlenr9rrr startswith) r rBZ sub_labelsZ value_startZ label_nameZ value_substriZ quote_endZ label_valueZ next_commar r r _parse_labelssR               rJc 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 # {rEr@r.r:r)findrF_parse_remaining_textrrindexrJrDrG) r separator label_startZname_endnameZremaining_textr+r5exemplar label_endZlabelrBrCr r r _parse_samples$       rTcCsr|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)Nr@r.rr5# exemplarspace exemplarhashr>exemplarstartoflabelsrKr:exemplarparsedlabelsZexemplarvaluespaceZ exemplarvalueZexemplartimestamp)rWrVrXrYcss"|]\}}t|t|VqdSr)rG).0kvr r r cz(_parse_remaining_text..zExmplar labels are too long: ) r1r,rGiterr"r)rFrNrJr8sumitemsr)r Z split_textvalr5Zexemplar_valueZexemplar_timestampZexemplar_labelsrAitr%rPrSr7rRZexemplar_lengthr r r rMs                        rMcCs~|dkr iS|dkr2|j|kr2|j}|d=|S|dkrN|j}||=|S|dvrx|j|dkrx|j}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)rQrBcopy)samplerQtypdr r r _group_for_sampleos   rrc 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_sumrQr+r r do_checkss         z#_check_histogram..do_checksrjFrrlrmTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)rQrGrrr5rrBr)r+) samplesrQrr5rursuffixgbr rsr _check_histogramsL         r~c#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!rvrxr)rvrxrlr)rwryrl_info)counterrfrjrkrecs|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: )rerhz(Units not allowed for this metric type: ri)setgetr)addendswithr~rrz)rQ documentationrpunitrzr{Zmetric) seen_names type_suffixesr r build_metrics&     z0text_fd_to_metric_families..build_metricrErzReceived line after # EOF: zReceived blank linez# EOFTrUr@r>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 )rZr )rQr r r^z.text_fd_to_metric_families..r!ZUNITzMore than one UNIT for metric: rrhzStateset missing label: rlrmZNaNzInvalid le label: z!Bucket value must be an integer: rvrwz Count value must be an integer: rfrrgzInvalid quantile label: zInvalid metric grouping: z*Mix of timestamp presence within a group: rez*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: )rrxrvrlrwryz$Counter-like samples cannot be NaN: )rrxrvrlrwz)Counter-like samples cannot be negative: ri)rzTInvalid line only histogram/gaugehistogram buckets and counters can have exemplars: zMissing # EOF at end)rr)rHr1rGr&rrTrQrBr isinstancer+r* is_integerrtuplesortedrrrbr5r"rr3r4rRr)fdZ allowed_nameseofrliner6rzrrprrZ seen_groupsZgroup_timestampZgroup_timestamp_samplesror|Z series_idr )rQrrr r s                                           "  $    r )!ior r3reZ metrics_corerrrzrrrZutilsrrrrrrrcompilerrr&r,r8r9rDrJrTrMrrr~r r r r r s4    BDV;