|g tSrSSKrSSKrSSKJr SSKJr SSKJr \R"\ 5r "SS5r g) u Procesador base del sistema - MVP v1.0 Implementa la funcionalidad core para el procesamiento de datos, estableciendo la base para los procesadores específicos. N)datetime)connect) DB_CONFIGcH\rSrSrSrSrSrSrSrS Sjr S r S r S r g) BaseProcessorcXlSUlSUlSUlSUl[ R "5UlUR5 g)NFT) db_nameconnverbosedebugrunning threadingLocklock connect_db)selfr s 2/var/www/blue/EV-Temp_rev04/src/processors/base.py__init__BaseProcessor.__init__s;     NN$  c[UR5UlUR(a#[R SUR35 gg![ a"n[R SU35 SnAgSnAff=f)u(Establece conexión con la base de datoszConectado a base de datos: TuError de conexión: NF)rr r loggerinfo Exceptionerror)res rrBaseProcessor.connect_dbso 5 -DIyy 9$,,HI  5 LL/s3 4 4 5sA A A>A99A>cUR(aURR5(dUR5$g)u3Verifica y reestablece la conexión si es necesarioT)r is_connectedrrs rcheck_connectionBaseProcessor.check_connection%s+yy 6 6 8 8??$ $rc0UR(+UlUR(a[RO[Rn[R"5R U5 [ RSUR(aSOS35 g)zCambia el modo verbosezModo verbose: activado desactivadoN)r loggingDEBUGINFO getLoggersetLevelrr)rlevels rtoggle_verboseBaseProcessor.toggle_verbose+sX<<' !% 7<<$$U+ n4<B>> EAD> E!E>EEE c[RS5 SUlUR(aURR 5(asURR SS9nUR 5 URR5 URR 5 [RS5 ggg![a"n[RSU35 SnAgSnAff=f)z'Detiene el procesador y limpia recursoszDeteniendo el procesador...FT)bufferedu!Conexión a base de datos cerradauError cerrando conexión: N) rrrr r!r6r:r8rr)rr6rs rstopBaseProcessor.stop[s 12 99 ?99))++!YY--t-> ?sBC C/ C**C/c[S5e)uO Obtiene métricas del procesador. Debe ser implementado por las clases hijas. u)Método get_metrics debe ser implementado)NotImplementedErrorr"s r get_metricsBaseProcessor.get_metricsks ""MNNr)r r rrrr )NF) __name__ __module__ __qualname____firstlineno__rrr#r.r1r@rDrH__static_attributes__r5rrrrs.  VR "H? Orr) __doc__r(rr db.databaserconfig.settingsrr+rJrrr5rrrRs9!'   8 $`O`Or