Update app.py

app.py

@@ -49,42 +49,35 @@ except Exception as e:
 #mongo_connection_string = os.environ.get("MONGODB_CONNECTION_STRING")
 cosmos_mongodb_connection_string = os.getenv("MONGODB_CONNECTION_STRING")
 
-if not cosmos_mongodb_connection_string:
-    raise ValueError("La variable de entorno MONGODB_CONNECTION_STRING debe estar configurada")
+# Variable global para el cliente de MongoDB
+mongo_client = None
+db = None
+analysis_collection = None
 
-try:
-    #Crear el cliente de MongoDB
-    client = MongoClient(cosmos_mongodb_connection_string,
-                         tls=True,
-                         tlsCAFile=certifi.where(),
-                         retryWrites=False,
-                         serverSelectionTimeoutMS=5000,
-                         connectTimeoutMS=10000,
-                         socketTimeoutMS=10000)
-    
-    #Forzar una conexión para verificar
-    mongo_client.admin.command('ping')
-    
-    #Seleccionar la base de datos
-    client.admin.command('ismaster')
-    
-    #Seleccionar la base de datos
-    db = client['aideatext_db']
-    analysis_collection = db['text_analysis']
-    
-    # Prueba de conexión
-    mongo_client.server_info()
-    print("Conexión a MongoDB API exitosa")
-
-    # Verificar que la colección existe
-    if 'text_analysis' in mongo_db.list_collection_names():
-        print("Colección 'text_analysis' encontrada")
-    else:
-        print("Advertencia: La colección 'text_analysis' no existe. Se creará automáticamente al insertar el primer documento.")
-    
-except Exception as e:
-    logger.error(f"Error al conectar con Cosmos DB MongoDB API: {str(e)}", exc_info=True)
-    raise
+def initialize_mongodb_connection():
+    global mongo_client, db, analysis_collection
+    try:
+        # Crear el cliente de MongoDB con configuración TLS
+        mongo_client = MongoClient(cosmos_mongodb_connection_string,
+                                   tls=True,
+                                   tlsCAFile=certifi.where(),
+                                   retryWrites=False,
+                                   serverSelectionTimeoutMS=5000,
+                                   connectTimeoutMS=10000,
+                                   socketTimeoutMS=10000)
+
+        # Forzar una conexión para verificar
+        mongo_client.admin.command('ping')
+        
+        # Seleccionar la base de datos y la colección
+        db = mongo_client['aideatext_db']
+        analysis_collection = db['text_analysis']
+        
+        logger.info("Conexión a Cosmos DB MongoDB API exitosa")
+        return True
+    except Exception as e:
+        logger.error(f"Error al conectar con Cosmos DB MongoDB API: {str(e)}", exc_info=True)
+        return False
 
 # Función para insertar un documento
 def insert_document(document):