gSrSSKrSSKJrJr SSKJrJr SSKrSSKrSSK J r J r \R"\ 5rSrSrS S jrS rS rg) uL Módulo de acceso a datos - MVP v1.0 Implementa todas las operaciones de base de datos del sistema: - Conexión y gestión de sesiones - Consultas de mediciones y sensores - Operaciones de actualización - Gestión de transacciones Este módulo centraliza el acceso a datos para mantener consistencia y facilitar optimizaciones. N)Errorconnect)datetime timedelta) DB_CONFIG BATCH_SIZEcSnU[S:a}[RR[S[S[S[SUS9nUR 5(a[ R SU35 U$U[S:aM}[ RS5 g ![aJn[ RS US -S U35 US - n[R"[S 5 S nANtS nAff=f)u Establece conexión con la base de datos con reintentos. Args: db_name (str): Nombre de la base de datos Returns: Connection: Objeto de conexión o None si falla rretry_attemptshostportuserpassword)r r rrdatabasezConectado a la base de datos: zIntento z fallido: retry_delayNu2No se pudo establecer conexión a la base de datos) rmysql connectorr is_connectedloggerinforerrortimesleep)db_name retry_count connectiones ./var/www/blue/EV-Temp_rev04/src/db/database.pyrrsK  "23 3 100v&v&v&":. 1J&&(( ?     s/2A B B1B 2BB  BB!cU(d/$SnU(a;[RS5 [RSUR535 URSS9nU(a[RS5 UR 5 U(a[RS5 UR 5 U(a[RS 5 S nU(aUS U3- nU(a[RS U35 URU5 UR5nU(a![RS [U535 U(azUVs/sHowSPM nnSRSRS/[U5-55n U(a"[RS[U5S35 URX5 UR5 U(a[RS5 UU(a.UR5 U(a[RS5 $$$![ a*nU(a[RSU35 SnAGNSnAff=fs snf![an[RSU35 U(a[RSSS9 UR 5 U(a[RS5 O#! U(a[RS5 O=f/sSnAU(a.UR5 U(a[RS5 $$$SnAff=f!U(a.UR5 U(a[RS5 fff=f)u Obtiene mediciones no procesadas. Args: conn: Conexión a la base de datos debug (bool): Flag para modo debug limit (int, opcional): Límite de registros a obtener Nz&Iniciando get_unprocessed_measurementsuEstado conexión: Tbufferedz Cursor creadozRollback previo ejecutadozError en rollback previo: uNueva transacción iniciadaaf SELECT b.id, b.dmac, b.temp/10.0 as temp, b.fecha, e.idEntrada FROM bandeja_blue b JOIN modbus m ON b.dmac = m.dmac JOIN entradas e ON e.idModbus = m.idModBus WHERE b.procesado_el IS NULL AND b.temp IS NOT NULL ORDER BY b.fecha ASC z LIMIT zEjecutando query: zResultados obtenidos: rz UPDATE bandeja_blue SET procesado_el = NOW() WHERE id IN ({}) AND procesado_el IS NULL ,%sz Ejecutando marca de procesados: z registroszCommit ejecutado exitosamentezCursor cerradozError obteniendo mediciones: zStack trace completo:)exc_infou$Rollback ejecutado después de errorz$Error ejecutando rollback post-error)rdebugrr!rollback Exceptionstart_transactionr"r#lenformatjoincommitr$rr) r%r.limitr!rr&resultsrowids mark_querys rget_unprocessed_measurementsr;Us  FV/  LLA B LL-d.?.?.A-BC Dd+  LL ) ? MMO 89   LL6 7    wug& &E  LL-eW5 6u//#  LL1#g,@ A %,-Wcq6WC- sxxS 123  ?CzTU NN: +  LL8 9  LLN -. K ? 9!=> ?J.&   4QC89  LL04L @ E MMO CD E CD  LLN -.    LLN -. sA-I,;,H0'B0I, I'$BI,0 I$:II,I$$I,, L;63L6*,KL6K75L6;L;<L>6L;;L>>7M5c U(aU(dgSnURSS9nUR5 SRS/[U5-5nSUS3nUR XA5 UR 5 U(aUR 5 gg![aJnUR5 [RS U35 SnAU(aUR 5 ggSnAff=f!U(aUR 5 ff=f) z. Marca un lote de mediciones como procesadas. FNTr)r+r,zT UPDATE bandeja_blue SET procesado_el = NOW() WHERE id IN (z+) AND procesado_el IS NULL z*Error marcando registros como procesados: ) r!r1r4r2r"r5r$rr/rr)r%r9r! placeholdersr&rs rmark_as_processed_batchr>s s Fd+  xxS 12 #^$   u"   LLN    A!EF  LLN    LLN s*A$B C%(C C( C%%C((DctU(aU(dgUR5nSnURX15 UR5 UR5 g![aBn[ R SU35 UR5 SnAWR5 gSnAff=f!WR5 f=f)u Inserta lote de registros estadísticos. Args: conn: Conexión a base de datos registros (list): Lista de tuplas (idSistema, idEntrada, fecha, ...) Returns: bool: True si la operación fue exitosa Fz INSERT INTO registros (idSistema, idEntrada, fecha, medio, maximo, minimo, desvio) VALUES (%s, %s, %s, %s, %s, %s, %s) Tu*Error insertando registros estadísticos: N)r! executemanyr5r$rrrr/)r% registrosr!r&rs rinsert_registros_batchrBs y  5,     A!EF     s)3A B" (BB%B""B%%B7)FN)__doc__mysql.connectorrrrrrrloggingconfig.settingsrr getLogger__name__rr'r;r>rBrrKsI *( 3   8 $>