B .l\>@sddlmZddlZddlmZmZddlmZmZm Z ddl m Z y ddl Z Wne k rlddlZ YnXddZd d Zd d Zd dZddZddZddZddZddZdS))unicode_literalsN)MetricMETRIC_LABEL_NAME_RE)ExemplarSample Timestamp)floatToGoStringccs"xtt|D] }|VqWdS)z^Parse Openmetrics text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)textZ metric_familyr Clib/python3.7/site-packages/prometheus_client/openmetrics/parser.pytext_string_to_metric_familiessrcCsg}d}xx|D]p}|rf|dkr*|dn6|dkr>|dn"|dkrR|dn|d|d}q|dkrtd}q||qW|r|dd|S)NF\"n T)appendjoin)r resultZslashcharr r r_unescape_helps$     rcCsJd|}||kr$td|yt|Stk rDt|SXdS)NrzInvalid value: {0!r})rstrip ValueErrorformatintfloat)valuer r r _parse_value7s  r c Csd|}|sdS||kr,td|ytt|dStk ry6|dd}tt|dt|dddddStk rt|}t |st |rtd||SXYnXdS)NrzInvalid timestamp: {0!r}r. 0) rrrrrrsplitljustrmathisnanZisinf) timestamppartstsr r r_parse_timestampAs    *r,cCsd}g}g}i}x|D]}|dkrD|dkr4d}nd}||q|dkrf|dkrZd}n ||q|dkr|dkr|d}n td |q|dkr|d krd }nP|dkrtd |std |d ||d |<g}g}d }n ||q|d kr*|dkr d}n|dkrd}n td |q|d krd}|d krN|d n:|dkrd|dn$|dkrz|dn|d |q|dkr|dkrPqtd |qW|S)NZstartoflabelname}Z endoflabels labelname=Zlabelvaluequoter labelvaluezInvalid line: rZlabelvalueslashrZendoflabelvalue,rr )rrrmatchr)itr stater.r0labelsrr r r _parse_labelsWsb               r7cCsbg}g}g}i}g}g}d}d}t|} xT| D]J} |dkrp| dkrVt| |}d}n| dkrdd}n || q0|dkr| dkrd}n || q0|dkr| dkr|sd}n| dkrd}n || q0|dkr| dkrd}n td |q0|dkr| dkrd }n td |q0|d krD| dkr6t| |}d }n td |q0|d krj| dkr^d }n || q0|d kr0|| q0W|dkr|std ||d kr|std ||d krtd ||std |d|}t|} t|} d} |dk rLtdd|Dd}|dkr8td|t |t|t|} t d||| | | S)Nname{rr2r)# exemplarspace exemplarhashzInvalid line: exemplarstartoflabelsZ exemplarvalueZexemplartimestamp)r<r;r=rcSs$g|]\}}t|t|dqS))len).0kvr r r sz!_parse_sample..r@zExmplar labels are too long: ) iterr7rrrr r,sumitemsrr)r r8rr)r6Zexemplar_valueZexemplar_timestampZexemplar_labelsr5r4rvalr+exemplarZexemplar_lengthr r r _parse_samples                       rJcCs~|dkr iS|dkr2|j|kr2|j}|d=|S|dkrN|j}||=|S|dkrx|j|dkrx|j}|d=|S|jS)Ninfosummaryquantilestateset) histogramgaugehistogram_bucketle)r8r6copy)sampler8typdr r r_group_for_samples   rWc sd}d}fdd}x|D]}|jtd}t|d}||ksT|j|krn|dk rb|ddd|}|j}|dkrt|jd}|krtd|jkrtd ||jq |d kr |jq W|dk r|dS) Ncs8tdkrtddk r4kr4tddS)Nz+Infz+Inf bucket missing: z!Count does not match +Inf value: )rrr )bucketcountr8rr r do_checkss  z#_check_histogram..do_checksrOrrQrRzBuckets out of order: zBucket values out of order: )_count_gcount)r8r?rWr)rr6rr) samplesr8groupr)rZssuffixgbr )rXrYr8rr_check_histograms4      rdc#sdg}d}tfdd}xP|D]F}|ddkrD|dd}|rTtd||dkrbd }q&|d r0|d d }t|d krtd||dkr|rtd||dkr dk r|||| |V|dd} d}d}d} t} d} t} g}|dg}|ddkrh|dk r0td|t|d krLt|d }nt|d kr.td|n|ddkr|dk rtd||d }|dkrtd|ddgddddgddddgdddgd gd!|dg}fd"d#|D}n:|dd$kr"| dk rtd%||d } n td|q&t|}|j|krdk r`|||| |V|jd}d} d&}g}d} d} t} t} |jg}|d'kr|j krtd(||d)kr d|jkr t |j d*dd+ks|j d*t |j d*kr td,||d-krr|jkrrd+t |j d.dkrHdkrfnn|j d.t |j d.krrtd/|t t t||}| dk r|| kr|| krtd0|| dk r|| kr|jdk| dkkrtd1|| dk r| |jkr|d2krtd3|nt} |jt t |j f}|j| ksJ|| krT||| ||} |j} | ||d'kr|jd4krtd5||d2kr|jdkrtd6||d-kr|jkr|jd+krtd7||jtdd8krt|jrtd9||jtdd8krF|jd+krFtd:||jr&|d)krb|jds&td;|q&Wdk r|||| |V|std<dS)=zParse 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. NFcs|krtd|||dkr*d}|dkr6d}|dkrBd}|r`|d|s`td||rx|dkrxtd||dkrt||t||||}||_|S) NzDuplicate metric: unknownr_z!Unit does not match metric name: )rKrNz(Units not allowed for this metric type: )rOrP)raddendswithrdrr^)r8 documentationrUunitr^Zmetric) seen_metricsr r build_metric4s$      z0text_fd_to_metric_families..build_metricr[rzReceived line after # EOF: z# EOFTr:r2r>zInvalid line: rz!Received metadata after samples: r"ZHELPzMore than one HELP for metric: ZTYPEzMore than one TYPE for metric: ZuntypedzInvalid TYPE for metric: _totalZ_createdr\_sumrrQr]_gsumZ_info)ZcounterrLrOrPrKcsg|] }|qSr r )r@r)r8r rrC{sz.text_fd_to_metric_families..ZUNITzMore than one UNIT for metric: rerNzStateset missing label: )rOrPrRrzInvalid le label: rLrMzInvalid quantile label: zInvalid metric grouping: z*Mix of timestamp presence within a group: rKz*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: )rnror\rQr]rpz$Counter-like samples cannot be NaN: z)Counter-like samples cannot be negative: zGInvalid line only histogram/gaugehistogram buckets can have exemplars: zMissing # EOF at end)setr startswithr%r?rgetrJr8r6rr tuplesortedrWrGr)rrgrr'r(rIrh)fdZ allowed_nameseofrlliner*r^rirUrjr_Z seen_groupsZgroup_timestampZgroup_timestamp_samplesrTrbZ series_idr )r8rkrr %s                            *         " & $    r )Z __future__rr'Z metrics_corerrr^rrrZutilsr r ImportErroriorrr r,r7rJrWrdr r r r rs"     =Z$