g"dZddlmZmZddlZddlmZddlmZddlm Z m Z m Z m Z dd l mZdd lmZmZej$eZGd d eZy) 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_SIZEcBeZdZfdZdZdZdZdZdZdZ xZ S)RealtimeProcessorc|t||i|_d|_i|_i|_|j y)N)super__init__entradaslast_process_timeperiod_measurementsclosed_periodsinitialize_entradas)selfdb_name __class__s >/Users/jma/desarrollo/EV-Temp_rev04/src/processors/realtime.pyrzRealtimeProcessor.__init__s; ! !%#%     "c|jsyt|j}tj}|j |j tztzdd}|D]X\}}}t||||j|<d|j|<|js=tjd|d|dZtjdt|jdy) uJ 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 rrz%RealtimeProcessor.initialize_entradas's$$& +DII6llnJJ"226FF%  ,: k 'ItZ")*dN"KDMM$ -.D $ $T *zz xv-I.YgIhij  k  nS%7$88IJKrc  |jsytj}|jrtjd|t |j |j}|jr&tjd|r t|ndd|D] \}}}}}||jvr%|jrtjd|=|j|}||jk\rt|jr7tjd|d|jd d |jd d ||j||j|d|j|<|j||s|jj|dd z|j|<||_|j#|y#t$$r$} tj'd | dYd} ~ yd} ~ wwxYw)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 rzError 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_idr/tempfechar0entradaes rprocess_new_dataz"RealtimeProcessor.process_new_dataAs, O((*,,.Czz =cUCD7 4::NLzz z|#l*;QR)SSklm8D _3dD%t}},zz 'OPTv%VW---G///zz .ug6 ' 6 6~Fc'J]J]^lImn,,063 &&w/--e456D,,T2++D%8595M5M5Q5QRVXY5Z]^5^D,,T2- _0&)D "    $ O LL:1#>L N N Os$G E-G AG G6G11G6ctdt|jj}td||jj D]\}}|jj |d}|dkDs(|j}|s;td|dtd|td|dd td |d d |d d y)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)rtotalr/rBcountstatss rshow_measurement_statusz)RealtimeProcessor.show_measurement_statusss -.D,,3356 +E734!]]002 VMD',,00q9Eqy002JtfA./N5'233E*4E3FcJKLx(9h?PPSTU Vrc |jrtjd||jjD]\}}||jk\s|jr4tjd|d|j dd|jd|j ||j|jd|j|<y)uA Verifica y cierra períodos que hayan expirado. uVerificando períodos en: Cerrando período para entrada u - período actual: r#r2rN) r(r)rrOr5r6r7r8r)r current_timer/rBs rr;z RealtimeProcessor._check_periodss :: LL5l^D E!]]002 3MD'w222::LL9$@,,3,B,B>+RRUV]ViVijxUy{""7+))'*=*=>12((. 3rc(|j}|r|ddk(r/|jr"tjd|jy|jrItjd|jd|ddd |d dd |dd |d d|dd|ddd} |jj }d|j |j|d |d|d|df}d}|jr#tjd|jd|j|||jj|jr"tjd|j|r|jyy#t$rl}|jjtjd|jd||jrtjddYd}~d}~wwxYw#|r|jwwxYw)u6 Cierra un período para una entrada. cantidad_medicionesru5No hay estadísticas para cerrar período de entrada NrVu: Período: r6r#r2r5z Mediciones: z Promedio: rGu°C Min/Max: rKrJrIrHdesvioz 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:Tr3)rPr(r)r/r%cursorr0r5r6executecommitrrollbackr=close)rrBrSr[registroqueryrCs rr7zRealtimeProcessor._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,"CF G9 A"G4/G<4G99G<<Hc(tjdd|_|jr |jj rx |jj d}|j  |jj |jj tjdd|_yy#YXxYw#YDxYw#YxYw#t$r"}tjd|Yd}~Dd}~wwxYw#d|_wxYw)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_connectedr[r_r]r<r=)rr[rCs rstopzRealtimeProcessor.stops  12 99 !99))+!%!1!14!1!@  ((* ) $GH ! /   ? 9!=>> ?! s_C,C2C /CC C CCCC D#D;DDD D) __name__ __module__ __qualname__rrrDrTr;r7rf __classcell__)rs@rrrs+#L40OdV$3$9x!rr)__doc__rrloggingmysql.connectorrbaser db.databaser r r r models.entradar config.settingsrr getLoggerrgr)rrrrtsJ )! %:   8 $S! S!r