.

.dockerignore

@@ -0,0 +1,8 @@
+__pycache__/
+*.pyc
+*.pyo
+*.pyd
+*.log
+.git
+.gitignore
+.venv/

.env

@@ -0,0 +1 @@
+POSTGRES_URL="postgres://postgres.hjgdlilnfccakdsmsypg:qBXsw226lYJabYgp@aws-1-ap-northeast-2.pooler.supabase.com:6543/postgres?sslmode=require"

.gitignore

@@ -0,0 +1,14 @@
+# Python Bytecode Files
+*.pyc
+__pycache__/
+
+# Dependencies
+venv/
+.venv/
+.mypy_cache/
+
+# ⭐️ 학습된 모델 및 결과 폴더 제외 ⭐️
+my_local_models/
+model_save/
+model_save_minilm/
+

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.13-slim
+
+WORKDIR /app
+
+# 패키지 설치
+COPY requirements.txt .
+
+RUN pip install --no-cache-dir --upgrade pip \
+    && pip install --no-cache-dir -r requirements.txt
+
+# 프로젝트 전체 복사
+COPY . .
+
+# Hugging Face Spaces 기본 포트
+EXPOSE 7860
+
+# FastAPI 실행
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app.py

@@ -0,0 +1,22 @@
+from fastapi import FastAPI
+from routers import test_router, testdb_router
+import uvicorn
+
+app = FastAPI()
+
+app.include_router(test_router.router)
+app.include_router(testdb_router.router)
+
+
+@app.get("/")
+def home():
+    return {"message": "FastAPI 실행 성공"}
+
+
+if __name__ == "__main__":
+    uvicorn.run(
+        "app:app",
+        host="127.0.0.1",
+        port=8000,
+        reload=True
+    )

readme.txt

@@ -0,0 +1,7 @@
+py -3.13 -m uv venv venv
+
+.\venv\Scripts\Activate.ps1
+
+uv pip install -r requirements.txt
+
+uv run python app.py

requirements.txt

@@ -0,0 +1,7 @@
+fastapi
+uvicorn[standard]
+python-multipart
+python-dotenv
+pydantic
+sqlalchemy
+psycopg[binary]

routers/test_router.py

@@ -0,0 +1,64 @@
+from fastapi import APIRouter, Form, File, UploadFile
+from utils.common import CommonResponse
+
+router = APIRouter(
+    prefix="/test",
+    tags=["test"]
+)
+
+@router.get("/")
+def test_home():
+    try:
+        return CommonResponse(success=True)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.get("/info")
+def test_info(name: str = "", age: int = 0):
+    try:
+        # 비즈니스 로직 처리
+        data = {
+            "name": name,
+            "age": age
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.get("/mytest")
+def mytest(username: str = "", password: str=""):
+    try:
+        # 비즈니스 로직 처리
+        data = {
+            "username": username,
+            "password": password
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.post("/mytest")
+def post_mytest(username: str = Form(""), password: str = Form("")):
+    try:
+        # business logic
+        data = {
+            "username": username,
+            "password": password
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.post("/upload")
+async def upload_file(file: UploadFile = File(...)):
+    try:
+        # business logic
+        contents = await file.read()
+        data = {
+            "filename": file.filename,
+            "content_type": file.content_type,
+            "size": len(contents)
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))

routers/testdb_router.py

@@ -0,0 +1,106 @@
+from fastapi import APIRouter, Form, File, UploadFile
+from utils.common import CommonResponse
+from utils.db import get_connection
+
+router = APIRouter(
+    prefix="/testdb",
+    tags=["testdb"]
+)
+
+@router.get("/")
+def test_home():
+    try:
+        return CommonResponse(success=True)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.get("/now")
+def select_now():
+    try:
+        with get_connection() as conn:
+            with conn.cursor() as cur:
+                cur.execute("select now()")
+                row = cur.fetchone()
+
+        data = {
+            "now": row[0].isoformat() if row else None
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.get("/select_test")
+def select_now(id: int = 0):
+    try:
+        with get_connection() as conn:
+            with conn.cursor() as cur:
+                cur.execute("""
+                SELECT
+                *
+                FROM t_test
+                WHERE
+                    CASE
+                        WHEN %s != 0 THEN id = %s
+                        ELSE TRUE
+                    END
+                LIMIT 1000
+                """, [id, id])
+                row = cur.fetchall()
+
+        data = row
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.post("/upsert_test")
+def upsert_test(id: int = Form(0), name: str = Form("")):
+    try:
+        with get_connection() as conn:
+            with conn.cursor() as cur:
+                if id <= 0:
+                    cur.execute("""
+                    INSERT INTO t_test (name)
+                    VALUES (%s)
+                    RETURNING id, name
+                    """, [name])
+                else:
+                    cur.execute("""
+                    UPDATE t_test
+                    SET name = %s
+                    WHERE id = %s
+                    RETURNING id, name
+                    """, [name, id])
+
+                row = cur.fetchone()
+                if not row:
+                    conn.rollback()
+                    return CommonResponse(success=False, msg="data not found")
+
+                conn.commit()
+
+        data = {
+            "id": row[0],
+            "name": row[1]
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))
+
+@router.post("/delete_test")
+def delete_test(id: int = Form(0)):
+    try:
+        with get_connection() as conn:
+            with conn.cursor() as cur:
+                cur.execute("""
+                DELETE FROM t_test
+                WHERE id = %s
+                """, [id])
+
+                conn.commit()
+
+        data = {
+            "msg" : "delete success"
+        }
+        return CommonResponse(success=True, data=data)
+    except Exception as e:
+        return CommonResponse(success=False, msg=str(e))

utils/common.py

@@ -0,0 +1,10 @@
+from typing import Generic, TypeVar, Any, Optional
+from pydantic import BaseModel
+
+T = TypeVar("T")
+
+class CommonResponse(BaseModel, Generic[T]):
+    success: bool=True
+    data: Optional[T] = None
+    msg: str = ""
+

utils/db.py

@@ -0,0 +1,67 @@
+import os
+from urllib.parse import parse_qsl, urlencode, urlsplit, urlunsplit
+
+import psycopg
+from dotenv import load_dotenv
+
+load_dotenv()
+
+ALLOWED_POSTGRES_PARAMS = {
+    "application_name",
+    "connect_timeout",
+    "dbname",
+    "fallback_application_name",
+    "gssencmode",
+    "host",
+    "hostaddr",
+    "keepalives",
+    "keepalives_count",
+    "keepalives_idle",
+    "keepalives_interval",
+    "load_balance_hosts",
+    "options",
+    "passfile",
+    "password",
+    "port",
+    "replication",
+    "require_auth",
+    "requiressl",
+    "service",
+    "sslcert",
+    "sslcompression",
+    "sslcrl",
+    "sslcrldir",
+    "sslkey",
+    "sslmode",
+    "sslnegotiation",
+    "sslpassword",
+    "sslrootcert",
+    "sslsni",
+    "target_session_attrs",
+    "tcp_user_timeout",
+    "user",
+}
+
+
+def get_postgres_url():
+    postgres_url = os.getenv("POSTGRES_URL")
+    if not postgres_url:
+        raise ValueError("POSTGRES_URL is not set")
+
+    return clean_postgres_url(postgres_url)
+
+
+def clean_postgres_url(postgres_url):
+    parts = urlsplit(postgres_url.strip().strip("\"'"))
+    query = urlencode(
+        [
+            (key, value)
+            for key, value in parse_qsl(parts.query, keep_blank_values=True)
+            if key in ALLOWED_POSTGRES_PARAMS
+        ]
+    )
+    return urlunsplit((parts.scheme, parts.netloc, parts.path, query, parts.fragment))
+
+
+def get_connection():
+    return psycopg.connect(get_postgres_url())