U jj@sbddlmZddlmZmZddZeeddddZeeeefd d d Zedd d dZ dS)) Collection)DictAnycCs t|dS)N)print)textrd/var/www/itgmanager/itgmanager/Analytic/scapp_database/refactorization/db_cameras_refactorization.py main_loggersr N)parameters_collectionversionreturnc CsVz |jddidd|iiddWn0tk rP}ztd|W5d}~XYnXdS) uF # ? Actualiza o inserta el documento con _id 'ScappDBVersion' en la colección proporcionada, # ? estableciendo el campo 'version' con el valor recibido. Args: parameters_collection (Collection): Instancia de la colección de MongoDB. version (Any): Valor a establecer en el campo 'version'. _idScappDBVersionz$setr T)upsertz3Error al actualizar el documento 'ScappDBVersion': N) update_one Exception)r r errrupdate_scapp_db_version s  r)r r c CsVz |ddi}|dk r|niWStk rP}ztd|W5d}~XYnXdS)um # ? Busca y retorna el documento con _id 'ScappDBVersion' en la colección proporcionada. # ? Si el documento no existe, retorna un diccionario vacío. Args: parameters_collection (Collection): Instancia de la colección de MongoDB. Returns: Dict[str, Any]: El documento encontrado o un diccionario vacío si no se encuentra. r rNz/Error al buscar el documento 'ScappDBVersion': )find_oner)r documentrrrrget_scapp_db_versions r)cameras_collectionr c Csddddddddddddg}|D]}|d}|d }|d }||i}||}|r&td |d |d ||}|dd||d||d<z&||||td|Wq&tk r} ztd|d | W5d} ~ XYq&Xq&dS)a # ? Migra documentos de la estructura antigua a la nueva utilizando _id como identificador. Migraciones a realizar: - { "Cameras": "AllCameras" } => {_id: "Cameras", ... } - { "Historical_Index": "Cameras_Index" } => {_id: "HistoricalIndices", ... } - { "RespaldoCameras": "AllCameras" } => {_id: "RespaldoCameras", ... } CamerasZ AllCameras) old_field old_valuenew_idZHistorical_IndexZ Cameras_IndexZHistoricalIndicesZRespaldoCamerasrrrzDocumento encontrado con z: z. Migrando a _id: r Nz&Documento migrado exitosamente a _id: z!Error al migrar el documento con )rr copypop insert_one delete_oner) rZ migracionesZmigrrrquerydocZ nuevo_docrrrrrefactorice_indices_cameras2s@      (r") pymongo.collectionrtypingrrr rstrrr"rrrrs