MhD0 ddlZddlZddlZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZmZmZdedee fd Zd d d d ZdeedefdZejdZejdZdedefdZdedefdZdededefdZd'dededeeeffdZ dedede eeffdZ!d(dedededefdZ"dededefdZ#d(d Z$d!Z%dede e&e e&ffd"Z'd#Z(d$Z)d%e dee fd&Z*dS))N)DictIterableListMatchOptionalTextIOTuple)Metric)Sample)_is_valid_legacy_metric_name_validate_labelname_validate_metric_nametextreturnc#XKttj|Ed{VdS)z]Parse Prometheus text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)rs X/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/prometheus_client/parser.pytext_string_to_metric_familiesr s9 *(*;D*A*ABBBBBBBBBBB\ ")z\\z\nz\"matchcBt|dS)Nr)ESCAPE_SEQUENCESgroup)rs rreplace_escape_sequencers EKKNN ++rz\\[\\n]z\\[\\n"]scBtt|SN)HELP_ESCAPING_REsubrr s r_replace_help_escapingr&$s    7 ; ;;rcBtt|Sr") ESCAPING_REr$rr%s r_replace_escapingr)(s ??2A 6 66rcharposcd}||kr/||dz |z dkr|dz }||kr||dz |z dk|dzdkS)Nrr r)r r* num_bslashess r_is_character_escapedr/,skL \ ! !1|+,44  \ ! !1|+,44 ! q  rF labels_string openmetricsci}|}|r |r|ddkrtd|z |rt||\}}|s|rtd|z-d}t|d}|dkrd}d }n7t|d}t |d|\}}||d zd}|st |std |}|r |dd krtd } | t |krG|d | } t|d| | sn| d z } | t |kG| d z} | t |krtd |zt |d| \} } |d krt|nt|||vrtd|z| ||<||S#t$rtd|zwxYw)Nr,zleading comma: zempty term in line: F=T__name__r zunquoted UTF-8 metric namerzunexpected text after quote: z$invalid line, duplicate label name: zInvalid labels: ) strip ValueError _next_term_next_unquoted_char_unquote_unescaper lenindexr/rr) r0r1labels sub_labelsterm quoted_name operator_pos label_name value_starti quote_end label_value_s r parse_labelsrI4sF$$&&J>>::<>  Ac$ii--JJsA&&,T"1"Xq99Q c$ii--AICII%% !@=!PQQQ.tJYJ/?@@NKZ''%j1111#J///V## !G-!WXXX!,F: a0 -b ===+m;<<<=s F.G))HcV|ddkr)|dd}|sdS|ddkrtdt|d}|dkrt|}|d|}|s|rtd |||d}||fS) zExtract the next comma-separated label term from the text. Returns the stripped term and the stripped remainder of the string, including the comma. Raises ValueError if the term is empty and we're in openmetrics mode. rr3r N)rKzmultiple commasz,}r5z empty term:)r8r:r<r7)rr1splitposr@ sublabelss rr9r9ss Aw#~~ABBx 6 7c>>.// /"4..H2~~t99   ?D .K.---XYYI ::<<** **rchsstartidxc|}d}| tj}|t|krE||dkrt||s| }|s |||vr|S|dz }|t|kEdS)zReturn position of next unquoted character in tuple, or -1 if not found. It is always assumed that the first character being checked is not already inside quotes. FNrr r5)string whitespacer<r/)rrNrOrE in_quotess rr:r:s AI { c$ii-- 7c>>"7a"@"@>% I Aw#~~ Q c$ii-- 2rct|dz }d}| tj}|dkr8||dkrt||s| }|s |||vr|S|dz}|dk8dS)zGReturn position of last unquoted character in list, or -1 if not found.r FNrrr5)r<rQrRr/)rrNrErSs r_last_unquoted_charrUs D A AI { a%% 7c>>"7a"@"@>% I Aw#~~ Q a%% 2rc`dg}d}|t|krt|||}|dkr||d|d<t|}G|dkr!t||kr||d|d<n:||||d<|dz}|d|t|k|S)zfSplits on split_ch similarly to strings.split, skipping separators if they are inside quotes. rKrr5Nr )r<r:append)r separatormaxsplittokensx split_poss r _split_quotedr]s TF A c$ii--'i;; ??abbF2JD A  a<>T"X__233 3AbDz t|| && <rc*|}d}||vrd}d||D}|st|dfSt|d}t |dkrt|ddz nd}||fS)N  c^g|]*}||+Sr-)r7).0values r z._parse_value_and_timestamp..s- M M Mu{{}} Mekkmm M M Mrrr r5i)lstripsplitfloat _parse_valuer<)r rXvaluesre timestamps r_parse_value_and_timestamprms  AI M M);); M M MF Qxx~  # #E58[[1__fRj))D00$I ) rcd|}||ksd|vrtd| t|S#t$rt |cYSwxYw)NrKrHzInvalid value: )joinr7r8intri)res rrjrjs GGENNE  45445555zz U||sAA0/A0cd}t|d}|dks ||d|vr~t|d}|d|}t|std|z||dzd}t |\}}t |i||S|d|}t|d}t ||dz|d} |sd | vrt| d }| d =nd | vrtd ||dzd}t |\}}t || ||S) Nz # {r5z zinvalid metric name:r }Fr6z$metric name specified more than once)r:r7r r8rmr rI) rrX label_startname_endnameremaining_textrerl label_endr>s r _parse_samplerysI%dC00KbIl{l);;;&tU33IXI$$&&+D11 <3d:;; ;hlmm,5nEEydBy111    # # % %D#D#..I ${Qy895 A AF A V # # j! :   v  ?@@@)a-..)N1.AAE9 $y 1 11rfdc # Kd d}d}g}g}dtdtdtdttdtf d}|D]}|}|d rgt |d d }t|d krRd \}} t|d krI|ddkr |ddkrt|d \}} | st|st|ddkrS| kr dkr| |||V| d}g}|g}t|dkrt|d }d}|ddkrtt|dkrt| kr dkr| |||V| d}g}|d }dgdggdgdd |dg} fd|D}|dkrt|} | j|vr9 dkr| |||Vd d}d}g}g}|| d||| gV||  dkr| |||Vd Sd S)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. rKuntypedrv documentationtypsamplesrc |dkrZ|dr |dd}n:g}|D]5}|t|ddzg|ddR|}6t|||}||_|S)Ncounter_totalirr )endswithrWr r r)rvr}r~r new_samplesr metrics r build_metricz0text_fd_to_metric_families..build_metrics )  }}X&& *CRCy  **A&&vadXo'F!""'F'F'FGGG)GGmS11  r#Nr,)rKFr TYPEHELP)_count_sumrK)rr_bucket)rgaugesummary histogramcg|]}|zSr-r-)rdnrvs rrfz.text_fd_to_metric_families..[s A A Aa A A Arr)strrr r r7 startswithr]r<r;r r8r&getryrvrW) rzr}r~r allowed_namesrlinepartscandidate_namer_samplervs @rrrs4 DM CGM 3 s  tF| X^    >'>'zz|| ??3  ; '!$a00E5zzA~~%. "NF5zzA~~8v%%%(f*<*<):58)D)D&%&B>&R&R%$$Qx6!!!T))rzz*l4WMMMMM)D#C G%3$4Mu::??$:58$D$DMM$&MMqV##u::>>$$!T))rzz*l4WMMMMM)D$&M GAh "t T555!>!>!> !! #cB4..  !B A A A= A A A RZZ "4((F{-//2::&,t]CIIIII "  " "l6!9mS6(KKKKKKv&&&& rzzl4W=======zr)F)r)+iorrerQtypingrrrrrrr metrics_corer rr validationr rrrrrrcompiler#r(r&r)rpboolr/rIr9r:rUr]r;rirmrjryrr-rrrs GGGGGGGGGGGGGGGGGG  CC&1ACCCC   ,5:,#,,,,2:j))bj%% <=<=<=<=~+S+t+c3h++++6cs3(c",   " # %x0F*G    222>_>6_>hv.>_>_>_>_>_>_>r