rm oracle DB loggic

app.py

@@ -1,9 +1,7 @@
 import os
-import json
 from typing import List, Optional
 from fastapi import FastAPI, HTTPException
-from pydantic import BaseModel, Field, ConfigDict
-import oracledb
+from pydantic import BaseModel, Field
 from dotenv import load_dotenv
 import pandas as pd
 from datetime import datetime
@@ -12,46 +10,13 @@ from datasets import Dataset, DatasetDict, load_dataset
 # 로컬 개발: .env 파일 로드 (있으면)
 load_dotenv()
 
-# ----- 환경 변수 -----
-DB_USER = os.environ["DB_USER"]
-DB_PASSWORD = os.environ["DB_PASSWORD"]
-WALLET_DIR = os.environ["WALLET_DIR"]
-WALLET_PASSWORD = os.environ["WALLET_PASSWORD"]
-
-# tnsnames.ora 안의 alias 확인 (보통 *_high)
-TNS_ALIAS = os.environ["DB_TNS_ALIAS"]
-
 # Hugging Face 설정
 HF_DATA_REPO_ID = os.getenv("HF_DATA_REPO_ID")
 HF_DATA_TOKEN = os.getenv("HF_DATA_TOKEN")
 
-# ----- 연결 풀: Thin + mTLS (지갑) -----
-# 절대 호출하지 마세요: oracledb.init_oracle_client()  # (Thick로 빠져서 실패 가능)
-pool: oracledb.ConnectionPool = oracledb.create_pool(
-    user=DB_USER,
-    password=DB_PASSWORD,
-    dsn=TNS_ALIAS,                  # Wallet tnsnames.ora의 alias
-    config_dir=WALLET_DIR,
-    wallet_location=WALLET_DIR,
-    wallet_password=WALLET_PASSWORD,
-    min=1, max=4, increment=1,
-    homogeneous=True,
-    timeout=60,
-    retry_count=6, retry_delay=2
-)
-
-app = FastAPI(title="MuscleCare Hybrid Server (mTLS)")
+app = FastAPI(title="MuscleCare FastAPI Server")
 
 # ----- 모델 -----
-class StatePayload(BaseModel):
-    model_config = ConfigDict(protected_namespaces=())
-    
-    user_id: str
-    rms_base: Optional[float] = None
-    freq_base: Optional[float] = None
-    user_emb: Optional[List[float]] = Field(default=None, description="length=12")
-    model_version: Optional[str] = None
-
 class LogUploadPayload(BaseModel):
     user_id: str
     session_id: str
@@ -84,10 +49,6 @@ class BatchLogsPayload(BaseModel):
     batch_data: List[BatchLogItem]
 
 
-# ----- 유틸 -----
-def clob_json(obj) -> str:
-    return json.dumps(obj, separators=(",", ":"), ensure_ascii=False)
-
 # ----- 엔드포인트 -----
 @app.get("/")
 def root():
@@ -98,9 +59,7 @@ def root():
         "version": "1.0.0",
         "endpoints": {
             "health": "/health (빠른 체크)",
-            "health_db": "/health/db (DB 연결 체크)",
             "docs": "/docs",
-            "upload_state": "/upload_state",
             "upload_logs": "/upload_logs (개별 로그 데이터)",
             "user_dataset": "/user_dataset/{user_id}"
         }
@@ -119,61 +78,6 @@ def health():
     except Exception as e:
         return {"ok": False, "error": str(e)}
 
-@app.get("/health/db")
-def health_db():
-    """DB 연결을 포함한 상세 health 체크"""
-    try:
-        with pool.acquire() as conn:
-            with conn.cursor() as cur:
-                cur.execute("SELECT 1 FROM DUAL")
-                v = cur.fetchone()[0]
-        return {"ok": True, "db": v, "server": "running"}
-    except Exception as e:
-        return {"ok": False, "db": "error", "error": str(e)}
-
-@app.post("/upload_state")
-def upload_state(p: StatePayload):
-    # MERGE INTO MuscleCare.user_state
-    try:
-        emb_json = None
-        if p.user_emb is not None:
-            if len(p.user_emb) != 12:
-                raise HTTPException(400, "user_emb must have length=12")
-            emb_json = clob_json(p.user_emb)
-
-        with pool.acquire() as conn:
-            with conn.cursor() as cur:
-                cur.execute("""
-                    MERGE INTO user_state t
-                    USING (
-                        SELECT :user_id AS user_id FROM dual
-                    ) s
-                    ON (t.user_id = s.user_id)
-                    WHEN MATCHED THEN UPDATE SET
-                        rms_base      = :rms_base,
-                        freq_base     = :freq_base,
-                        user_emb      = :user_emb,
-                        model_version = :model_version,
-                        last_sync     = CURRENT_TIMESTAMP
-                    WHEN NOT MATCHED THEN INSERT
-                        (user_id, rms_base, freq_base, user_emb, model_version, last_sync)
-                    VALUES
-                        (:user_id, :rms_base, :freq_base, :user_emb, :model_version, CURRENT_TIMESTAMP)
-                """, dict(
-                    user_id=p.user_id,
-                    rms_base=p.rms_base,
-                    freq_base=p.freq_base,
-                    user_emb=emb_json,
-                    model_version=p.model_version
-                ))
-                conn.commit()
-        return {"ok": True}
-    except HTTPException:
-        raise
-    except Exception as e:
-        raise HTTPException(500, f"upload_state failed: {e}")
-
-
 @app.post("/upload_logs")
 async def upload_logs(payload: LogUploadPayload):
     """개별 로그 데이터를 Hugging Face Hub로 푸시"""

requirements.txt

@@ -1,7 +1,6 @@
 fastapi
 uvicorn
 python-multipart
-oracledb>=2.3
 pydantic
 python-dotenv
 datasets

start.py

@@ -1,5 +1,6 @@
-import os, base64, zipfile, io, sys, tempfile, subprocess
-from pathlib import Path
+import os
+import sys
+import subprocess
 from dotenv import load_dotenv
 
 # .env 파일 로드 (로컬 개발용)
@@ -12,88 +13,21 @@ def setup_environment():
     - Hugging Face Space: 환경변수에서 자동 설정
     """
     print("🔧 환경변수 설정 중...")
-    
-    # Hugging Face Dataset 설정 (기본값 설정)
-    if not os.getenv("HF_DATA_REPO_ID"):
-        os.environ["HF_DATA_REPO_ID"] = os.getenv("HF_DATA_REPO_ID")
-        print("📝 HF_DATA_REPO_ID 기본값 설정")
-    
-    if not os.getenv("HF_DATA_TOKEN"):
-        os.environ["HF_DATA_TOKEN"] = os.getenv("HF_DATA_TOKEN")
-        print("📝 HF_DATA_TOKEN 기본값 설정")
-    
-    # Oracle DB 설정 확인
-    required_vars = ["DB_USER", "DB_PASSWORD", "WALLET_DIR", "WALLET_PASSWORD"]
-    missing_vars = []
-    
-    for var in required_vars:
-        if not os.getenv(var):
-            missing_vars.append(var)
-    
-    if missing_vars:
-        print(f"⚠️  누락된 환경변수: {', '.join(missing_vars)}")
-        print("💡 .env 파일을 확인하거나 환경변수를 설정해주세요.")
-        
-        # 로컬 개발을 위한 기본값 설정 (경고와 함께)
-        if not os.getenv("DB_USER"):
-            os.environ["DB_USER"] = "ADMIN"
-            print("📝 DB_USER 기본값 설정: ADMIN")
-        if not os.getenv("DB_PASSWORD"):
-            os.environ["DB_PASSWORD"] = "YourDBPassword123!"
-            print("📝 DB_PASSWORD 기본값 설정: YourDBPassword123!")
-        if not os.getenv("WALLET_PASSWORD"):
-            os.environ["WALLET_PASSWORD"] = "YourWalletPassword123!"
-            print("📝 WALLET_PASSWORD 기본값 설정: YourWalletPassword123!")
+
+    hf_repo = os.getenv("HF_DATA_REPO_ID")
+    hf_token = os.getenv("HF_DATA_TOKEN")
+
+    if hf_repo:
+        print("✅ HF_DATA_REPO_ID 설정 완료")
     else:
-        print("✅ 모든 필수 환경변수가 설정되었습니다")
-    
-    print("🔧 환경변수 설정 완료")
+        print("ℹ️ HF_DATA_REPO_ID가 설정되지 않았습니다. Hugging Face 업로드 기능이 제한될 수 있습니다.")
 
-def prepare_wallet_dir():
-    """
-    Wallet 준비:
-    - 배포 환경: WALLET_ZIP_B64에서 디코딩
-    - 로컬 환경: WALLET_DIR 경로 사용
-    """
-    # 로컬 개발: WALLET_DIR이 이미 설정되어 있는 경우
-    if "WALLET_DIR" in os.environ:
-        wallet_dir = os.environ["WALLET_DIR"]
-        if Path(wallet_dir).exists():
-            print(f"📁 로컬 Wallet 사용: {wallet_dir}")
-            return wallet_dir
-    
-    # 배포 환경: WALLET_ZIP_B64에서 디코딩
-    if "WALLET_ZIP_B64" not in os.environ:
-        raise RuntimeError(
-            "❌ WALLET_ZIP_B64 또는 WALLET_DIR 환경 변수가 필요합니다.\n"
-            "   로컬: .env 파일에 WALLET_DIR 설정\n"
-            "   배포: Hugging Face Secrets에 WALLET_ZIP_B64 설정"
-        )
-    
-    print("🔐 Wallet Base64 디코딩 시작...")
-    b64 = os.environ["WALLET_ZIP_B64"]
-    wallet_password = os.environ["WALLET_PASSWORD"]
-    
-    # wallet을 메모리->임시디렉토리로 복원
-    wallet_dir = tempfile.mkdtemp(prefix="wallet_")
-    print(f"📁 임시 디렉토리: {wallet_dir}")
-    
-    zip_bytes = base64.b64decode(b64)
-    with zipfile.ZipFile(io.BytesIO(zip_bytes)) as z:
-        z.extractall(wallet_dir)
-    
-    # 안전을 위해 권한 축소
-    for root, _, files in os.walk(wallet_dir):
-        for f in files:
-            os.chmod(os.path.join(root, f), 0o600)
-    
-    print("✅ Wallet 압축 해제 완료")
-    
-    # 지갑 비밀번호는 oracledb에서 사용
-    os.environ["WALLET_DIR"] = wallet_dir
-    os.environ["WALLET_PASSWORD"] = wallet_password
-    
-    return wallet_dir
+    if hf_token:
+        print("✅ HF_DATA_TOKEN 설정 완료")
+    else:
+        print("ℹ️ HF_DATA_TOKEN이 설정되지 않았습니다. Hugging Face 업로드 기능이 제한될 수 있습니다.")
+
+    print("🔧 환경변수 설정 완료")
 
 if __name__ == "__main__":
     print("=" * 60)
@@ -103,13 +37,6 @@ if __name__ == "__main__":
     # 환경변수 자동 설정
     setup_environment()
     
-    # Wallet 준비
-    try:
-        prepare_wallet_dir()
-    except Exception as e:
-        print(f"❌ Wallet 준비 실패: {e}")
-        sys.exit(1)
-    
     # Uvicorn 기동
     print("\n🌐 FastAPI 서버 실행...")
     print("=" * 60)

start_server.sh

@@ -19,7 +19,7 @@ echo "🔧 환경변수는 start.py에서 자동으로 설정됩니다."
 
 # Python 의존성 확인 및 설치
 echo "📦 Python 의존성 확인 중..."
-if ! python3 -c "import fastapi, uvicorn, oracledb" 2>/dev/null; then
+if ! python3 -c "import fastapi, uvicorn" 2>/dev/null; then
     echo "❌ 필수 Python 패키지가 설치되지 않았습니다."
     echo "🔧 자동 설치를 시작합니다..."
     
@@ -38,7 +38,7 @@ if ! python3 -c "import fastapi, uvicorn, oracledb" 2>/dev/null; then
     fi
     
     # 설치 후 다시 확인
-    if ! python3 -c "import fastapi, uvicorn, oracledb" 2>/dev/null; then
+    if ! python3 -c "import fastapi, uvicorn" 2>/dev/null; then
         echo "❌ 패키지 설치에 실패했습니다."
         echo "💡 수동으로 설치해주세요:"
         echo "   pip3 install -r requirements.txt"