U jR/@sddlmZddlZddlZddlmZmZddlmZmZm Z m Z m Z ddl m Z ddlmZdd Zd d Zed d ZdddddddZeedZeedZeedZeedZeedZeedZdZdddZd%ddZd&ddZdd Zd!d"Zd#d$Z e Z!dS)') MongoClientN)datetimetimezone)update_scapp_db_versionget_scapp_db_versionrefactorice_indices_camerastransform_to_timeseriesensure_data_compose_index)ensure_data_analytic_collection)ensure_visitas_coll_and_indexcCs t|dSNprinttextrG/var/www/itgmanager/itgmanager/Analytic/scapp_database/load_scapp_db.py main_loggersrcCs t|dSr rrrrrdatabase_loggersrzmongodb://localhost/iiScappDBcamerasdata data_analyticZ data_visitas parameters)databaserr analyticsvisitasrrrrF)cameras_collectiondata_collectionTc CsRi}t}zd||di}ddi}t||dd}d} |D]r} | d} | |kr\g|| <|rd| krt| dtr| djtjd| d<| d | d<| d7} ||  | q@Wn:t k r} zt d| j jd | W5d } ~ XYnX|rN|D]"\} } t d t| d | qtt d | dt|ddd|S)u Retorna un diccionario que contiene toda la información de BD entre los días start_of_day y end_of_day El diccionario utiliza como llave los indices de las cámaras, teniendo como value un array con todos los datos de la BD Cada dato es un diccionario: { timestamp: 2024-06-27T12:03:26.000+00:00, camera_id = "1-A", # metadata: { -> Versión Obsoleta, ya no existe el campo # Dia: "2024-06-27", # Jaula: "1-A", # }, Detecciones: { perdidos: 0, detectados: 0, nivel_actividad: 26.04, umbral_alarma: 3, perdidos_propios: 0, }, Alimentacion: { use_feeding_api: false, detection_active: false, Comida_entregada: 0, Meta_dia: 0, Porc_entregado: 0, Tasa: 0, Dia: 0, Feeding_active: false, Unidad_Medida: "kg/min", Metodo_alimentacion: "Saciedad", feeding_api_type: "AkvaControl", }, Posicion: { x_pos: "-", y_pos: "-", winche_connected: false, }, Sensores: { temp: "-" } } @Params - start_of_day (datetime): Fecha en formato datetime ( Puede obtenerse mediante datetime.now() ) - end_of_day (datetime): Fecha en formato datetime ( Puede obtenerse mediante start_of_day + timedelta(days=1) ) - verbose (bool): Flag para imprimir información adicional por consola timestamp)z$gtez$lt_idrr camera_id)tzinfou(Error leyendo documentos de día de hoy z : Nz Cargados z Datos para el canal z Se han convertido a formato iso z elementos, tardando g@@z.2fz ms.)timerfindsort isinstancerreplacerutc isoformatappend Exceptionr __traceback__ tb_linenoitemslenr) start_of_day end_of_dayverboseconvert_to_isoZdocuments_by_jaulat1query projectioncursorZ parsed_tsdocjaulaerrrrfetch_data_collection9s6.*$r<c Csz|d}td|i}i}|D]}|d}|dg}|r"|sFq"|r|D]P}d|krxt|dtrx|d|d<d|krNt|dtrN|d|d<qN|||<q"|WStk r} ztd|d| W5d } ~ XYnXiS) u ### ? Obtiene las visitas de todas las jaulas para una fecha dada en la colección data_visitas. @param datetime_day (datetime): Fecha para la cual recopilar datos @return: Diccionario con la estructura { 'jaula1': visitas_jaula1, 'jaula2': visitas_jaula2, ... } Donde cada visita tiene el formato: [ { duracion: 75.04, racion: 0, inicio: 2024-10-17T17:23:05.000+00:00, final: 2024-10-17T17:24:20.000+00:00 }, ... ] z%Y-%m-%ddayr"Visitasiniciofinalu&Error obteniendo visitas para el día : N) strftimevisitas_collectionr%getr'rr*r,r) Z datetime_dayr4Zdiar8Zvisitas_por_jaular9r:rZvisitar;rrrfetch_visitas_collections(     &rEc Cs@z*t|ddd}t|}W5QRX|WSiYSXdS)Nrzutf-8)encoding)openyamlZ safe_load)filenamefilerrrr read_yamls rLc Cs\z ||td|dWn6tk rV}ztd|d|W5d}~XYnXdS)Nu Colección z eliminada satisfactoriamente. uError eliminando colección: rA)droprr,)dbcollection_namer;rrrdrop_collections  rPc Cstd}|didd}|rsB           [ ??