o 3gB&@sXdZddlmZddlZddlZddlmZddlmZm Z ddl m Z ddl m Z m Z ddlmZdd lmZddlZdd lmZmZmZmZmZmZmZdd lmZdd lmZmZdd l m!Z!GdddeZ"d,ddZ#ee$Z%d-ddZ&e'Z(e'Z)e'Z*e GdddZ+d.ddZ,ee&dd/dd Z-d0d"d#Z.d1d%d&Z/d2d(d)Z0d2d*d+Z1dS)3z [[https://bluemaestro.com/products/product-details/bluetooth-environmental-monitor-and-logger][Bluemaestro]] temperature/humidity/pressure monitor ) annotationsN)abstractmethod)IterableSequence) dataclass)datetime timedelta)Path)Protocol)PathsResStats get_files make_loggerstatunwrap)mcachew) DataFrameT as_dataframe)sqlite_connect_immutablec@s,eZdZeed ddZed ddZdS) configreturnr cCstN)NotImplementedErrorselfr(/home/garg/my-data/HPI/my/bluemaestro.py export_path"szconfig.export_pathpytz.BaseTzInfocCs tdS)Nz Europe/London)pytztimezonerrrrtz's z config.tzN)rr )rr)__name__ __module__ __qualname__propertyrrr"rrrrr!s rrcCs$ddlm}Gddd|t}|S)Nr) bluemaestroc@s eZdZdS)z$make_config..combined_configN)r#r$r%rrrrcombined_config2s r() my.configr'r) user_configr(rrr make_config/s r+Sequence[Path]cCst}t|jSr)r+rr)cfgrrrinputs:s r.c@s6eZdZUded<ded<ded<ded<ded <d S) MeasurementrdtCelsiustempPercenthumiditymBarpressuredewpointN)r#r$r%__annotations__rrrrr/Ds  r/namestrboolcCs ttdd}|dur dS||S)N is_bad_tableF)getattrr)r9delegaterrrr<Ms r<) depends_onIterable[Res[Measurement]]c #sDt}|j}t}t|}tt|}d}tt|D]\}}td|d|d|d|d|d}d} t |Hd} z3 d|j d} d} d \\} | d krdWWdq| d rm| d 7} | t| d } WnKtjydd dD}fdd|D}t|Ofdd|D}ddd|D}t|dkrd|d} |} d} d} Ynw| D]\}}}}}}t|rq| r|dddd}t|d}| |}| dusJn%td|}|dusJt|d}tj|d |d!} tj|d |d!}td"d#}td$d#}| ||kr2| td$d#ks=ntd%||| |Vq||||fd&krLtd'Vqd(|krXd)ks`nJ|||f|d7}|duro||kroq|}| d7} t|||||d*}|VqWdn 1swYt|d+| d|qdS),Nz processing [>/z] rSELECT "zW" as name, Time, Temperature, Humidity, Pressure, Dewpoint FROM data ORDER BY log_indexTzSELECT last_download FROM infozN/A:00z%Y-%m-%d %H:%M:%ScSsg|]}|dqS)rr).0crrr sz measurements..z8SELECT name FROM sqlite_sequence WHERE name LIKE "%_log"csg|]}|vr|qSrrrFt)processed_tablesrrrHsc s0g|]}td|ddddqS)zSELECT interval from _log_metar)listexecutereplacerI)dbrrrHs0z UNION css |] }d|d|VqdS)rCzj" AS name, unix, tempReadings / 10.0, humiReadings / 10.0, pressReadings / 10.0, dewpReadings / 10.0 FROM NrrIrrr s  zmeasurements..zSELECT * FROM (z) ORDER BY name, unixFJuliJulzAug.Augz%Y-%b-%d %H:%Mz_(\d+)_i)r"g@o@)days ztimestamp too far out)33333bgY@g@rYzthe weird sensor bugi<)r0r2r6r4r7z: new )r+r"r.lenr:set enumerateloggerinforrOr9endswithlocalizerstrptimesqlite3OperationalErrorjoinr<rPresearchintgroup fromtimestampr RuntimeErrorr/debug)r-r"pathstotalwidthlastidxpathtotnewdb_dtdatasoldfmtdb_dts log_tables frequenciesqueryr9tscr2humpresdewptssr0m export_tslowerupperpr)rQrKr measurementsSs ,        *      ( (irr cCsttSr)rrrrrrstatssrrcCstttd}|dS)zY %matplotlib gtk from my.bluemaestro import dataframe dataframe().plot() )schemar0)rrr/ set_index)dfrrr dataframes rNonecCs ddlm}|jttddS)Nrinfluxdb) measurement)my.corerfillrr#rrrr fill_influxdbs rc Cstt}|dd}t|dj}t|dj}d}d}||}|d|}t}||t|ddks=Jd|||td d ksOJd ||||j} dS) NiprZi)hoursz old backup! )minuteszbad interval! )rNrrr0rnowrseconds) tempslatestprevrp POINTS_STOREDFREQ_SEC SECS_STORED HOURS_STOREDNOWsinglerrrchecks   $$r)rr)rr,)r9r:rr;)rr@)rr )rr)rr)2__doc__ __future__rrfrcabcrcollections.abcrr dataclassesrrrpathlibr typingr r rr r r rrrrmy.core.cachewrmy.core.pandasrrmy.core.sqliterrr+r#r^r.floatr1r3r5r/r<rrrrrrrrrs@     $