
    pi
                     X    d Z ddlZddlmZ  ej                  e      Zd Zd Zd Zd Z	y)zK
Job de sincronizacion de datos.
Se ejecuta automaticamente cada 1 minuto.
    N)datetimec            	        K   t        j                         j                  d      } t        dd        t        d|         t        d d       t        j                  d|  d       	 t        j                  d|  d       t        d|  d	       y# t        $ rD}t        j                  d
|  dt        |              t        d
|  dt        |               d}~ww xY ww)a_  
    Tarea de sincronizacion de datos.

    Esta funcion se ejecuta automaticamente cada 1 minuto.
    Modifica el contenido segun tus necesidades de sincronizacion.

    Ejemplos de uso:
    - Sincronizar productos con API externa
    - Actualizar precios desde un servicio
    - Sincronizar inventario
    - Enviar metricas a un sistema externo
    z%Y-%m-%d %H:%M:%S
z<============================================================u   🔄 SYNC JOB EJECUTADO: u   🔄 [z'] Ejecutando sincronizacion de datos...u   ✅ [z(] Sincronizacion completada exitosamentez] Sincronizacion completadau   ❌ [z] Error en sincronizacion: z	] Error: N)	r   nowstrftimeprintloggerinfo	Exceptionerrorstr)	timestampes     `/home/jorge/Escritorio/DESARRROLLO TWS/LHIA-MARCI-V3/lhiav3-retail-agent/tasks/jobs/sync_data.pysync_data_jobr      s      ''(;<I 
Bvh-	%i[
12	VHB-
KK&#JKL& 	eI;&NOPi[ ;<= uYK'B3q6(KLi[	#a&23s*   A'C#*(B C#	C ?CC  C#c                    K   ddl } | j                         4 d{   }|j                  d      4 d{   }|j                  dk(  r:|j	                          d{   }t
        j                  dt        |       d       ddd      d{    ddd      d{    y7 7 p7 K7 # 1 d{  7  sw Y   +xY w7 "# 1 d{  7  sw Y   yxY ww)z.Ejemplo: Sincroniza datos con una API externa.r   Nz https://api.ejemplo.com/products   u   📥 Recibidos z registros de API externa)aiohttpClientSessiongetstatusjsonr	   r
   len)r   sessionresponsedatas       r   sync_with_external_apir   A   s     $$& T T';;AB 	T 	Th#%%]]_,oc$i[8QRS		T 	TT T T	T,	T 	T 	T 	TT T T Ts   CB$CCB&C#B,B(&B,CB*CCCC&C(B,*C,B>	2B53B>	:CCC	C
CCc                     K   yw)z-Ejemplo: Limpia registros de cache expirados.N r       r   cleanup_expired_cacher!   M         	   c                     K   yw)z0Ejemplo: Envia metricas al sistema de monitoreo.Nr   r   r    r   send_metrics_to_monitoringr%   S   r"   r#   )
__doc__loggingr   	getLogger__name__r	   r   r   r!   r%   r   r    r   <module>r*      s:     			8	$/l	T		r    