U Tg  @sddlZddlZddlZddlZddlZddlZddlZz ddlZWnek r`e dYnXeej ej e eZ ejddZejdddddejd dd d d ejdejd ddddejdddddejddddejdddde\ZZeedkr*eededZejesbejdeeedeeZddeddDZedZej d d!d"d#ej!dkred$Z"nej!Z"ej#dkred%Z#nej#Z#e$d&eD]e3d2dZ:dZ;eZ?e>e:kre=Z;q,qe3e8e;d7Z3ne3e87Z3qe39e5e@d3d!e3ZAe5e@d4d!e3ZBe$d5eA[3ee+ZCeCdZeD]Z%e%d(ZDe e%d'e eDZ&e e eDeDZ'e$d6e&e'eDfe7e&e'eDZEe$d7eEgZFe6eEdd2eEddD]ZGeHeAeGdZIejHeAeGdeId8ZJeBeIeJZKeKre5eLd9d!eKZMeMrd:eeMeeKe"kreFNeGde2e#eMeKgqeOe+eFqnHe$d;eD]:Z%e%d)\Z)Z*e6e7e)e*ZPeLdeQeReeQze$d?eeRe,eWn<eSk reTe$d@eReQeedYnXejUre$dAeQe-eQdS)BNz6[ERROR] Please make sure whisper is installed properlya%prog path timePerPoint:timeToStore [timePerPoint:timeToStore]* timePerPoint and timeToStore specify lengths of time, for example: 60:1440 60 seconds per datapoint, 1440 datapoints = 1 day of retention 15m:8 15 minutes per datapoint, 8 datapoints = 2 hours of retention 1h:7d 1 hour per datapoint, 7 days of retention 12h:2y 12 hours per datapoint, 2 years of retention )usagez--xFilesFactorfloatzChange the xFilesFactor)defaulttypehelpz--aggregationMethodstringz$Change the aggregation function (%s)z, z--forceF store_truezPerform a destructive change)ractionrz --newfilestorezDsrZarchivescCs|dSNsecondsPerPointr )ar r rIrT)keyreverse xFilesFactoraggregationMethodz%Retrieving all data from the archivesZ retentionrdataz.tmpz-Removing previous temporary database file: %sz!Creating new whisper database: %s)rrzCreated: %s (%d bytes)z"Migrating data with aggregation...cCs|dSrr xr r rrnr)rcCs|dS)Nrr pr r rrrcCs|dSNr r rr r rrrzoldtimestamps: %sz (%s,%s,%s)ztimepoints_to_update: %s)locCs|dk S)Nr rr r rrrg?z%Migrating data without aggregation...cCs |ddk Sr!r rr r rrrz.bakzRenaming old database to: %szRenaming new database to: %sz# Operation failed, restoring backupzUnlinking backup: %s)Vossystimebisectsignaloptparse tracebackr ImportError SystemExitSIGPIPESIG_DFLintnow OptionParserZ option_parser add_optionjoinZaggregationMethods parse_argsoptionsargslen print_helpexitpathexistsstderrwriteinfoZ new_archivesZ old_archivessortrZxffrprintarchiveZfromTimeZ untilTimefetchZtimeinfovaluesnewfileZtmpfileunlinkcreatestatst_sizesizeZ aggregateZall_datapointssortedlistziprangeZnew_datapointsrZlast_timestampZ slice_end enumeratei timestampvaluemapZ oldtimestampsZ oldvaluesZnew_infostepZtimepoints_to_updateZ newdatapointsZ tinterval bisect_leftZleftiZrightiZ newvaluesfilterZnon_noneappendZ update_manyZ datapointsbackuprenameOSError print_excZnobackupr r r rs8