o pfmV@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 ]/home/ertert/spirit/venv/lib/python3.10/site-packages/prometheus_client/openmetrics/parser.pytext_string_to_metric_families srinfcCs t|}|tvr dS|t|kS)NF)float_CANONICAL_NUMBERSr)sfr r r _isUncanonicalNumbers r\ ")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-s rcCsg}d}|D]8}|r2|dkr|dn|dkr|dn|dkr(|dn|d|d}q|dkr9d}q||q|rF|dd|S)NFrrnrT)appendjoin)r resultslashcharr r r _unescape_help1s$      r'cCsRd|}||ksd|vrtd|zt|WSty(t|YSw)Nr!_zInvalid value: )r#strip ValueErrorintr)valuer r r _parse_valueLs    r-c Csd|}|s dS||ksd|vrtd|ztt|dWStyjz|dd}tt|dt|dddddWYStyit|}t |s\t |rctd||YYSww) Nr!r(zInvalid timestamp: r. 0) r#r)r*rr+splitljustrmathisnanisinf) timestamppartstsr r r _parse_timestampVs$   0  r:cCsPd}||kr"||d|dkr"|d7}||kr"||d|dks|ddkS)Nrr/rrr )rcharpos num_bslashesr r r _is_character_escapedls r=cCsd}g}g}i}d}|D]}|dkr!|dkrd}nd}||n|dkr2|dkr,d}n||n|dkrC|dkr=d }ntd ||d kr|d krNd }n|dkrzd |}t|sbtd|||vrltd|d |||<g}g}d}n]||nW|dkr|dkrd}nL|dkrd}nEtd ||d krd }|d kr|d n/|dkr|dn%|dkr|dn|d |n|dkr|dkr||fStd ||d7}q ||fS)Nstartoflabelnamer} endoflabels labelname=labelvaluequoter labelvalueInvalid line: rlabelvalueslashr!zInvalid line, bad label name: z$Invalid line, duplicate label name: endoflabelvalue,r r r/)r"r*r#rr)r staterArDlabels labels_lenr&lnr r r _parse_labels_with_state_machinetsn             rNc Csi}|r d|vr t|}z|r|d}|d|}||dd}|r*|ddkr,t|dd}|r:|ddkrcs"z(_parse_remaining_text..zExemplar labels are too long: ) r2r-rQiterr"r*rPr_r[r:sumitemsr)r split_textvalr7exemplar_valueexemplar_timestampexemplar_labelsrJitr&rarfr9reexemplar_lengthr r r r^s                       r^cCs~|dkriS|dkr|j|kr|j}|d=|S|dkr'|j}||=|S|dvr<|j|dkr<|j}|d=|S|jS)Ninfosummaryquantilestateset histogramgaugehistogram_bucketle)rcrKcopy)samplerctypdr r r _group_for_sampleos   rc s>d}d}fdd}|D]}|jtd}t|d}||ks-|j|krB|dur4|ddddddd|}|j}|dkrwt|jd}|dkrXddurf|krftd |jkrqtd ||jq|d vr|jq|d vrdq|d vrd|jdkrdq|dur|dSdS)Ncstdkr tddurkrtdr&dur&tdr2dur2tds@s@dur@tdrJrJtdsTrVtddSdS) 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 bucketcounthas_gsumhas_negative_bucketshas_negative_gsumhas_sumrcr,r r do_checkss          z#_check_histogram..do_checksrFrrrTzBuckets out of order: zBucket values out of order: )_count_gcount)_sum)_gsum)rcrQrr7rrKr*r,) samplesrcrr7rrsuffixgbr rr _check_histogramsP      rc#sdg}d}tddggdgdgddgd fd d }|D]}|d d kr3|dd }|r;td||sAtd|dkrHd}q$|dr|dd}t|dkr_td||dkrm|rmtd||dkrdur|||| |V|dd} d}d}d} t} d} t} g}|dg}|ddkr|durtd|t|d}q$|ddkr|durtd||d}|dkrtd|fd d!|d"gD}q$|dd#kr| durtd$||d} q$td|t|}|j|vr+dur|||| |V|jd}d} d%}g}d} d} t} t} |jg}|d&kr<|j vrvr|j d1krtd?||jr|d@vr|jd(s|dAvr|jdstdB|q$dur|||| |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!rrr)rrrr)rrr_info)counterrrrrcs|durd}t|gdgD]}||vr!td||||q|dur/d}|dur5d}|rD|d|sDtd||rP|dvrPtd||dvrYt||t||||}||_|S) Nunknownr!zClashing name: r(z!Unit does not match metric name: )rrz(Units not allowed for this metric type: r)setgetr*addendswithrrr)rc documentationrunitrrmetric) seen_names type_suffixesr r build_metrics&     z0text_fd_to_metric_families..build_metricrOrzReceived line after # EOF: zReceived blank linez# EOFTrirIrErz!Received metadata after samples: r/HELPzMore than one HELP for metric: TYPEzMore than one TYPE for metric: untypedzInvalid TYPE for metric: csg|]}|qSr r )rqr )rcr r sz.text_fd_to_metric_families..r!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: )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*rRr2rQr'rrhrcrKr isinstancer,r+ is_integerrtuplesortedrrxr7r"rr4r5rer)fd allowed_nameseofrliner8rrrrr seen_groupsgroup_timestampgroup_timestamp_samplesrr series_idr )rcrrr r s                                *           "  $   r )!ior r4re metrics_corerrrrrrutilsrrrrrrrcompilerrr'r-r:r=rNr[rhr^rrr r r r r s6    BDV ;