g#SrSSKJrJr SSKrSSKJr SSKJr SSKJ r J r J r J r SS K Jr SS KJrJr \R$"\5r"S S \5rg) uV Procesador de datos en tiempo real - MVP v1.0 Gestiona el procesamiento continuo de nuevas mediciones, manteniendo estadísticas actualizadas por períodos de 15 minutos. Este módulo implementa: - Monitoreo continuo de nuevas mediciones - Procesamiento en períodos de 15 minutos - Gestión de períodos incompletos - Control de timeouts )datetime timedeltaN)Error) BaseProcessor)get_unprocessed_measurementsget_active_sensorsmark_as_processed_batchinsert_registros_batch)Entrada)PROCESS_INTERVAL BATCH_SIZEcL^\rSrSrU4SjrSrSrSrSrSr Sr S r U=r $) RealtimeProcessorc|>[TU]U5 0UlSUl0Ul0UlUR 5 g)N)super__init__entradaslast_process_timeperiod_measurementsclosed_periodsinitialize_entradas)selfdb_name __class__s ?/var/www/blue/EV-Temp_rev04/src/processors/realtime/realtime.pyrRealtimeProcessor.__init__s; ! !%#%     "cUR5(dg[UR5n[R"5nUR UR [-[-SSS9nUH]upEn[XeU5URU'SURU'UR(dMA[RSUSUS35 M_ [RS[UR5S35 g) u: Inicializa las entradas activas para el período actual. Nr)minutesecond microsecondzEntrada u inicializada para período %Y-%m-%d %H:%MzInicializadas z entradas activas)check_connectionr connrnowreplacer"rr rrdebugloggerinfolen)ractive_sensorsr(periodo_actual sensor_iddmac id_entradas rr%RealtimeProcessor.initialize_entradas's$$&& +DII6llnJJ"226FF%  ,: 'IZ")*N"KDMM$ -.D $ $T *zzz xv-I.YgIhij ,:  nS%7$88IJKr c 8UR5(dg[R"5nUR(a[RSU35 [ UR UR5nUR(a+[RSU(a [U5OSS35 UGHup4pVnX@R;a+UR(a[RSU35 MBURUnXhR:ayUR(a7[RSUSURS S URS S U35 URU5 URU5 SURU'URXV5(dMURRUS5S -URU'GM XlUR#U5 g![$a!n [R'S U 3SS9 Sn A gSn A ff=f)z/ Procesa las nuevas mediciones en tiempo real. NzIniciando process_new_data en z Obtenidas rz mediciones sin procesaru(Medición para entrada no inicializada: uNueva medición u fuera del período actual (r% - z) para entrada zError procesando nuevos datos: Texc_info)r&rr(r*r+r r'r-r periodo_finperiodo_inicio _close_periodreiniciar_periodoragregar_mediciongetr_check_periods Exceptionerror) rr( measurementsm_idr1tempfechar2entradaes rprocess_new_data"RealtimeProcessor.process_new_dataAs, O((**,,.Czz =cUCD7 4::NLzz z|#l*;QR)SSklm8D3D}},zz 'OPTv%VW---///zz .ug6 ' 6 6~Fc'J]J]^lImn,,063 &&w/--e456D,,T2++D88595M5M5Q5QRVXY5Z]^5^D,,T2-8D0&) "    $ O LL:1#>L N Os$G.F G.%AG.. H8HHc[S5 [URR55n[SU35 URR 5Hup#URR US5nUS:dM)UR5nU(dMB[SUS35 [SU35 [SUSS 35 [S US S US S 35 M g)z- Muestra el estado actual de las mediciones. z === Mediciones Actuales ===uTotal mediciones período: rz Entrada :z Mediciones: u Última temperatura: promedio°Cu Máx/Min: maximo°C / minimoN)printsumrvaluesritemsr>get_estadisticas)rtotalr1rFcountstatss rshow_measurement_status)RealtimeProcessor.show_measurement_statusss -.D,,3356 +E734!]]002MD,,00q9Eqy0025JtfA./N5'233E*4E3FcJKLx(9h?PPSTU3r c UR(a[RSU35 URR5Hup#XR:dMUR(a4[RSUSUR SSURS35 UR U5 URUR5 SURU'M g)u1 Verifica y cierra períodos que hayan expirado. uVerificando períodos en: Cerrando período para entrada u - período actual: r%r5rN) r*r+rrTr9r:r;r<r)r current_timer1rFs rr? RealtimeProcessor._check_periodss :: LL5l^D E!]]002MD222::LL9$@,,3,B,B>+RRUV]ViVijxUy{""7+))'*=*=>12((.3r ctUR5nU(a USS:Xa4UR(a"[RSUR35 gUR(aI[RSURSUSSS US SS USS US SUSSUSS35 SnURR 5nSUR URUS USUSUS4nSnUR(a#[RSURS35 URXT5 URR5 UR(a"[RSUR35 U(aUR5 gg![annURR5 [RSURSU35 UR(a[RSSS9 SnANSnAff=f!U(aUR5 ff=f)u& Cierra un período para una entrada. cantidad_medicionesru5No hay estadísticas para cerrar período de entrada Nr\u: Período: r:r%r5r9z Mediciones: z Promedio: rLu°C Min/Max: rPrOrNrMdesvioz INSERT IGNORE INTO registros (idSistema, idEntrada, fecha, medio, maximo, minimo, desvio) VALUES (%s, %s, %s, %s, %s, %s, %s) uEjecutando query para período z-Registro insertado exitosamente para entrada z'Error insertando registro para entrada z: zError detallado:Tr7)rUr*r+r1r'cursorr2r9r:executecommitrrollbackrAclose)rrFrXrbregistroqueryrGs rr;RealtimeProcessor._close_periods((*349zz TU\UaUaTbcd  :: LL1',,@$%56~Fc%P]J^_mIno!!&'?$Z012#Ho.fU8_4ES J % YY%%'F""##j!hhhHEzz >w?U?UVd>efg NN5 + II   zz LW\\N[\   @ II   LLB7<<.PRSTRUV Wzz /$ ?  @  s,2CF"" H,A$HHHHH7c<[RS5 SUlUR(aURR 5(avURR SS9nUR 5 URR5 URR 5 [RS5 OSUlgg! NZ=f! NF=f! N=f![a"n[RSU35 SnANESnAff=f!SUlf=f)z* Detiene el procesador y limpia recursos. zDeteniendo el procesador...FT)bufferedu!Conexión a base de datos cerradauError cerrando conexión: N) r+r,runningr' is_connectedrbrfrdr@rA)rrbrGs rstopRealtimeProcessor.stops  12 99 !99))++!%!1!14!1!@  ((* ) $GH,*! /   ? 9!=>> ?! sqC#)C9C/CDCC#CC#C C#D C## D-D D DD D)rr'rrrrl) __name__ __module__ __qualname____firstlineno__rrrHrYr?r;rn__static_attributes__ __classcell__)rs@rrrs0#L40OdV$3$9x!!r r)__doc__rrloggingmysql.connectorrbaser db.databaser r r r models.entradar config.settingsrr getLoggerrpr+rr rrsH )!  &;   8 $S! S!r