Update app.py

app.py

@@ -1,4 +1,4 @@
-From fastapi import FastAPI, HTTPException, Query
+from fastapi import FastAPI, HTTPException, Query
 import duckdb
 from contextlib import asynccontextmanager
 
@@ -9,17 +9,22 @@ con = duckdb.connect()
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     print("DuckDB extensions load ho rahi hain aur View ban raha hai...")
-    con.execute("INSTALL httpfs; LOAD httpfs;")
-    
-    # Parquet file ka correct URL
-    PARQUET_URL = "https://huggingface.co/datasets/tfqdeadlo/Inddatainonefile/resolve/main/users_data.parquet"
-    
-    # Startup par hi Ek baar View bana kar metadata cache kar lete hain
-    # Isse har API request par network par load nahi padega
-    con.execute(f"CREATE OR REPLACE VIEW users_view AS SELECT * FROM read_parquet('{PARQUET_URL}')")
-    print("View taiyar hai! API requests ke liye taiyar hai.")
+    try:
+        con.execute("INSTALL httpfs; LOAD httpfs;")
+        
+        # Parquet file ka correct URL
+        PARQUET_URL = "https://huggingface.co/datasets/tfqdeadlo/Inddatainonefile/resolve/main/users_data.parquet"
+        
+        # Startup par hi Ek baar View bana kar metadata cache kar lete hain
+        con.execute(f"CREATE OR REPLACE VIEW users_view AS SELECT * FROM read_parquet('{PARQUET_URL}')")
+        print("View taiyar hai! API requests ke liye taiyar hai.")
+    except Exception as e:
+        print(f"❌ Startup Initialization me error aaya: {e}")
     yield
-    con.close()
+    try:
+        con.close()
+    except Exception:
+        pass
 
 app = FastAPI(title="Super Fast Search API", lifespan=lifespan)
 
@@ -30,7 +35,7 @@ def home():
 @app.get("/search")
 async def search_mobile(mobile: str = Query(..., description="Enter mobile number to search")):
     try:
-        # Ab hum direct cache kiye hue 'users_view' se data nikalenge
+        # Cache kiye hue 'users_view' se data nikalenge
         query = """
             SELECT mobile, name, fname, address, alt, circle, id, email 
             FROM users_view 
@@ -56,6 +61,7 @@ async def search_mobile(mobile: str = Query(..., description="Enter mobile numbe
         }
         
     except Exception as e:
+        print(f"❌ Query execute karne me error: {e}")
         # Internal error ko secure rakhne ke liye mask kiya hai
         raise HTTPException(status_code=500, detail="Query timeout ya process nahi ho payi.")