feat: add v3 API using AwslBlobV2 table

Add new v3 API endpoints that query AwslBlobV2 table directly without CDN URL replacement. Also upgrade dependencies and simplify docker requirements.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: dreamhunter2333

docker/dockerfile

@@ -1,6 +1,6 @@
 FROM python:3.13-slim
 
-COPY requirements.docker.txt requirements.txt
+COPY requirements.txt requirements.txt
 RUN python3 -m pip install -r requirements.txt
 
 COPY . /app

main.py

@@ -7,6 +7,7 @@
 
 from src.awsl_producers import router as producer_router
 from src.awsl_blob import router as blob_router
+from src.awsl_blob_v3 import router as blob_v3_router
 from src.awsl_pic import router as pic_router
 from src.health_check import router as health_check_router
 
@@ -36,6 +37,7 @@ def filter(self, record: logging.LogRecord) -> bool:
 
 app.include_router(producer_router, prefix="")
 app.include_router(blob_router, prefix="")
+app.include_router(blob_v3_router, prefix="")
 app.include_router(pic_router, prefix="")
 app.include_router(health_check_router, prefix="")
 

requirements.docker.txt

@@ -1,8 +1,7 @@
-fastapi==0.116.1
-fastapi-cli==0.0.8
-mysql-connector-python==9.4.0
-pydantic==2.11.7
-pydantic-settings==2.10.1
-pydantic_core==2.33.2
-requests==2.32.4
-SQLAlchemy==2.0.41
+fastapi==0.124.4
+mysql-connector-python==9.5.0
+pydantic==2.12.5
+pydantic-settings==2.12.0
+requests==2.32.5
+SQLAlchemy==2.0.45
+uvicorn==0.38.0

requirements.txt

@@ -0,0 +1,36 @@
+import logging
+
+from typing import List, Optional
+from fastapi import APIRouter
+from fastapi.responses import JSONResponse
+
+from .response_models import BlobItem, Message
+from src.db.base import DBClientBase
+
+router = APIRouter()
+_logger = logging.getLogger(__name__)
+
+
+@router.get("/v3/list", response_model=List[BlobItem], responses={404: {"model": Message}}, tags=["AwslV3"])
+def awsl_v3_list(uid: Optional[str] = "", limit: Optional[int] = 10, offset: Optional[int] = 0):
+    if limit > 1000:
+        return JSONResponse(
+            status_code=404,
+            content=Message(message="to large limit = {}".format(limit))
+        )
+    return DBClientBase.get_client().awsl_v3_list(uid, limit, offset)
+
+
+@router.get("/v3/list_count", response_model=int, tags=["AwslV3"])
+def awsl_v3_list_count(uid: Optional[str] = "") -> int:
+    return DBClientBase.get_client().awsl_v3_list_count(uid)
+
+
+@router.get("/v3/random", response_model=str, tags=["AwslV3"])
+def awsl_v3_random(uid: Optional[str] = "") -> str:
+    return DBClientBase.get_client().awsl_v3_random(uid)
+
+
+@router.get("/v3/random_json", response_model=BlobItem, tags=["AwslV3"])
+def awsl_v3_random_json(uid: Optional[str] = "") -> BlobItem:
+    return DBClientBase.get_client().awsl_v3_random_json(uid)

src/awsl_blob_v3.py

@@ -79,3 +79,20 @@ def awsl_pic_random(cls, uid: str) -> str:
     @classmethod
     def awsl_pic_random_json(cls, uid: str) -> str:
         ...
+
+    # V3 API methods using AwslBlobV2
+    @classmethod
+    def awsl_v3_list(cls, uid: str, limit: int, offset: int) -> List[BlobItem]:
+        ...
+
+    @classmethod
+    def awsl_v3_list_count(cls, uid: str) -> int:
+        ...
+
+    @classmethod
+    def awsl_v3_random(cls, uid: str) -> str:
+        ...
+
+    @classmethod
+    def awsl_v3_random_json(cls, uid: str) -> BlobItem:
+        ...

src/db/base.py

@@ -7,7 +7,7 @@
 from sqlalchemy.orm import sessionmaker
 
 from config import WB_URL_PREFIX, settings
-from src.models.models import AwslBlob, AwslProducer, Mblog, Pic
+from src.models.models import AwslBlob, AwslBlobV2, AwslProducer, Mblog, Pic
 from src.models.pydantic_models import Blob, Blobs
 from src.response_models import BlobItem, PicInfo, ProducerItem, ProducerRes
 
@@ -257,3 +257,66 @@ def awsl_pic_random_json(cls, uid: str) -> str:
                 pic_id=blob.pic_id,
                 pic_info=PicInfo.model_validate_json(blob.pic_info).root
             )
+
+    # V3 API methods using AwslBlobV2
+    @classmethod
+    def awsl_v3_list(cls, uid: str, limit: int, offset: int) -> List[BlobItem]:
+        with cls.DBSession() as session:
+            blobs = session.query(AwslBlobV2).join(
+                Mblog, AwslBlobV2.awsl_id == Mblog.id
+            ).filter(
+                Mblog.uid == uid
+            ).order_by(
+                AwslBlobV2.awsl_id.desc()
+            ).limit(limit).offset(offset).all() if uid else session.query(
+                AwslBlobV2
+            ).join(
+                Mblog, AwslBlobV2.awsl_id == Mblog.id
+            ).order_by(
+                AwslBlobV2.awsl_id.desc()
+            ).limit(limit).offset(offset).all()
+            res = [BlobItem(
+                wb_url=WB_URL_PREFIX.format(
+                    blob.awsl_mblog.re_user_id, blob.awsl_mblog.re_mblogid),
+                pic_id=blob.pic_id,
+                pic_info=Blobs.model_validate_json(blob.pic_info).blobs
+            ) for blob in blobs if blob.awsl_mblog]
+            return res
+
+    @classmethod
+    def awsl_v3_list_count(cls, uid: str) -> int:
+        with cls.DBSession() as session:
+            res = session.query(func.count(AwslBlobV2.id)).join(Mblog, AwslBlobV2.awsl_id == Mblog.id).filter(
+                Mblog.uid == uid
+            ).one() if uid else session.query(func.count(AwslBlobV2.id)).one()
+            return int(res[0]) if res else 0
+
+    @classmethod
+    def awsl_v3_random(cls, uid: str) -> str:
+        with cls.DBSession() as session:
+            blob = session.query(AwslBlobV2).join(Mblog, AwslBlobV2.awsl_id == Mblog.id).filter(
+                Mblog.uid == uid
+            ).order_by(
+                func.rand()
+            ).limit(1).one() if uid else session.query(AwslBlobV2).order_by(
+                func.rand()
+            ).limit(1).one()
+            url_dict = Blobs.model_validate_json(blob.pic_info).blobs
+            return url_dict["original"].url
+
+    @classmethod
+    def awsl_v3_random_json(cls, uid: str) -> BlobItem:
+        with cls.DBSession() as session:
+            blob = session.query(AwslBlobV2).join(Mblog, AwslBlobV2.awsl_id == Mblog.id).filter(
+                Mblog.uid == uid
+            ).order_by(
+                func.rand()
+            ).limit(1).one() if uid else session.query(AwslBlobV2).order_by(
+                func.rand()
+            ).limit(1).one()
+            return BlobItem(
+                wb_url=WB_URL_PREFIX.format(
+                    blob.awsl_mblog.re_user_id, blob.awsl_mblog.re_mblogid),
+                pic_id=blob.pic_id,
+                pic_info=Blobs.model_validate_json(blob.pic_info).blobs
+            )