
    #wgc                        d dl Z d dlZd dlZd dlZd dlZd dlZ	 d dlZ	 d dlZ ej                  ej                  ej                          eej                        Zej!                  d       ej!                  d       ej!                  d        ej"                  d      Zej'                  d	d
dd       ej'                  ddddj)                  e      z  z   dd       ej'                  dddd       ej+                         \  ZZ ee      dk  r"ej3                           ej4                  d       ed    Z	  ej8                  e      Zed   Zdev red   Z ng Z!eD ]Q  Z"e"jG                  d      s e$e"jK                  d      d   jK                  d      d          Z&e!jO                  e&       S  e(e!      dz   Z)g Z  e*e)      D ]A  Z+i Z,ede+z     e,d<   ede+z     e,d<   ed e+z     e,d!<   ed"e+z     e,d#<   e jO                  e,       C d$ev red$   j[                         Z.n7eD  cg c]  } | jG                  d%      s|  c} Z/ e e0d& e/D                    Z.g Z1e D ]4  Z2e2d!   ejf                  ji                         k(  s$e1jO                  e2       6 e1s%d'ejf                  ji                         z  Z5 e	e5      g Z6ejn                  Z7e1D ])  Z2e2d   ez  Z8e2d   Z9e7se2d#   Z7e6jO                  e8e9f       + e.D ]+  Z: e$ ej                               Z; ee.      dkD  rd(e:z  nd)Z<ejz                  rqejz                  Z>ej~                  j                  e>      s	  ej                  e>       ej~                  j                  e      j                  d*d+e<z        ZFe>d,z   eFz   Z?nej                  d*d+e<z        Z?	  ej                  e?e6e7-        ej                  e?      j                  ZLd.j)                  e6D cg c]  }d/|z  	 c}      ZM eNd0e?eLeMfz          eNd1        ee6      dz
  ZO ePe6      D ]  \  Z8Z9e8e9z  ZQe;e;e8z  z
  ZReReQz
  ZS ej                  eejf                  ji                         d2 e
e8      d3 e
eS      d4 e
eR            \  ZUZVZW eeV      jM                  e:      ZXeWj                          eWD cg c]  }|eX   	 c}ZZ e e*eU       Z[ e\e[eZ      Z]e]D cg c]
  }|d   	| c}Z] eNd5 ee]      eOfz         eOdz  ZO ej                  e?e]        . y# e$ rZ e	d e
e      z        dZ[ww xY w# e$ r	  e	d      w xY w# ej<                  $ rZ e	d e
e      z        dZ[ww xY wc c} w # eB$ rAZej                   e j                  k(  rej~                  j                  e>      rn Y dZ[ZdZ[ww xY w# ej                  $ rZI e	d e
eI      z        dZI[Iww xY wc c}w c c}w c c}w )6    Nz[ERROR] Missing dependency: %sz6[ERROR] Please make sure whisper is installed properlysumabsmaxabsminz%prog rrd_path)usagez--xFilesFactorzTThe xFilesFactor to use in the output file. Defaults to the input RRD's xFilesFactorfloat)helpdefaulttypez--aggregationMethodz6The consolidation function to fetch from on input and z.aggregationMethod to set on output. One of: %sz, averagestringz--destinationPathzKPath to place created whisper file. Defaults to the RRD file's source path.   z
[ERROR] %ssteprrazrra[[]zrra[%d].pdp_per_rowpdp_per_rowzrra[%d].rowsrowsz
rra[%d].cfcfzrra[%d].xffxffdszds[c              #   J   K   | ]  }|d d j                  d      d     yw)   Nr   r   )split).0keys     ]/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/../../../bin/rrd2whisper.py	<genexpr>r   ]   s$     B3QRs+A.Bs   !#z?[ERROR] Unable to find any RRAs with consolidation function: %sz_%s z.rrdz%s.wsp/)xFilesFactor,z%d:%dz(Created: %s (%d bytes) with archives: %szMigrating dataz-rz-sz-ez( migrating %d datapoints from archive %d)_errnoossystimesignaloptparserrdtoolImportErrorexc
SystemExitstrwhisperSIGPIPESIG_DFLlistaggregationMethodsremoveOptionParseroption_parser
add_optionjoin
parse_argsoptionsargslen
print_helpexitrrd_pathinforrd_infoerrorseconds_per_pdprrasrra_indicesr   
startswithintr   indexappendmax	rra_countrangeirra_infokeysdatasourcesds_keyssetrelevant_rrasr   aggregationMethoduppererrarchivesr    	precisionpoints
datasourcenowsuffixdestinationPathdestination_pathpathisdirmakedirsOSErrorEEXISTbasenamereplacerrd_filecreateInvalidConfigurationestatst_sizesizearchiveConfigprintarchiveNumberreversed	retentionendTime	startTimefetch	time_infocolumnsr   column_indexpopvalues
timestampszip
datapointsupdate_many)r   arrow	datapoints   0000r   <module>r      s    	 
   @M
 fnnfnn -'445    %     ( #   ( #%%%,@A   
/	     	A4II !"
" 	     
	    **,$t9q=
#((1+7,W\\(#( 6" 	H	%$+  c
~~f#))C.#))#.q12e 
 +")	$ aH&'<q'@AH] 23HVlQ./HTN}q01HUOKK 8##%+$>Su(=S>'SB'BBC+  CY'++1133 I!!'')	*#3## 'C- ?2)v;&	u:L
//9f%&'  0*JIDIIK#!$[!1A!55:2&..77==)*$% ww)11&(V:KLHc!H,DFHv$56D,GNN4= 
		$((8<RGbL<=-2dD-5PPQh-!#-#H- *iF"IC)O#G)#I!.%%'
C	N
C	N
CL"Y =&&z2LHHJ+/0Cc,0FeY'(JZ(J-7T	9Q<;S)TJ	
4J7W
WXQMGj)'*;0*O  @3c#h>??@
  MKLLM\ }} ,<#c(*++,: ?@  99$7G)H

  
	%	% ,
\CF*
++, =$ 1 Us   T- U <U *VVV	=W=W:
W?*
X5X-U2UUUV+U<<V	W6W

WW7!W22W7