fix: RDB loging execution_type TASK로 통일

apps/pre-processing-service/app/api/endpoints/product.py

@@ -1,5 +1,4 @@
 from fastapi import APIRouter, Request, HTTPException
-from app.decorators.logging import log_api_call
 from ...errors.CustomException import (
     InvalidItemDataException,
     ItemNotFoundException,

apps/pre-processing-service/app/api/endpoints/test.py

@@ -5,14 +5,12 @@
 from fastapi import APIRouter
 from sqlalchemy import text
 
-from app.decorators.logging import log_api_call
 from ...errors.CustomException import *
 from fastapi import APIRouter
 from typing import Mapping, Any, Dict
 from ...model.schemas import *
 from ...service.blog.blog_create_service import BlogContentService
 from ...service.blog.naver_blog_post_service import NaverBlogPostService
-from ...service.blog.tistory_blog_post_service import TistoryBlogPostService
 from ...service.crawl_service import CrawlService
 from ...service.keyword_service import keyword_search
 from ...service.match_service import MatchService
@@ -27,7 +25,6 @@
 
 
 @router.get("/hello/{name}", tags=["hello"])
-# @log_api_call
 async def say_hello(name: str):
     return {"message": f"Hello {name}"}
 
@@ -122,8 +119,6 @@ async def processing_tester():
     # tistory_service = TistoryBlogPostService()
     naverblogPostService = NaverBlogPostService()
     result = naverblogPostService.post_content(
-        # blog_id="wtecho331",
-        # blog_pw="wt505033@#",
         title=data.get("title"),
         content=data.get("content"),
         tags=data.get("tags"),

apps/pre-processing-service/app/api/router.py

@@ -1,6 +1,6 @@
 # app/api/router.py
 from fastapi import APIRouter
-from .endpoints import keywords, blog, product, test, sample
+from .endpoints import keywords, blog, product, test
 from ..core.config import settings
 
 api_router = APIRouter()
@@ -15,19 +15,9 @@
 api_router.include_router(product.router, prefix="/products", tags=["product"])
 
 # 모듈 테스터를 위한 endpoint -> 추후 삭제 예정
-api_router.include_router(test.router, prefix="/tests", tags=["Test"])
-
-api_router.include_router(sample.router, prefix="/v0", tags=["Sample"])
+# api_router.include_router(test.router, prefix="/tests", tags=["Test"])
 
 
 @api_router.get("/ping")
 async def root():
     return {"message": "서버 실행중입니다."}
-
-
-@api_router.get("/db")
-def get_settings():
-    """
-    환경 변수가 올바르게 로드되었는지 확인하는 엔드포인트
-    """
-    return {"환경": settings.env_name, "데이터베이스 URL": settings.db_url}

apps/pre-processing-service/app/errors/handlers.py

@@ -57,8 +57,8 @@ async def validation_exception_handler(request: Request, exc: RequestValidationE
     """
     # 변경점: ErrorBaseModel을 기본 구조로 사용하고, 추가 정보를 더함
     base_error = ErrorBaseModel(
-        status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
-        detail=ERROR_MESSAGES[status.HTTP_422_UNPROCESSABLE_ENTITY],
+        status_code=status.HTTP_422_UNPROCESSABLE_CONTENT,
+        detail=ERROR_MESSAGES[status.HTTP_422_UNPROCESSABLE_CONTENT],
         code="VALIDATION_ERROR",
     )
 
@@ -67,7 +67,7 @@ async def validation_exception_handler(request: Request, exc: RequestValidationE
     response_content["details"] = exc.errors()
 
     return JSONResponse(
-        status_code=status.HTTP_422_UNPROCESSABLE_ENTITY,
+        status_code=status.HTTP_422_UNPROCESSABLE_CONTENT,
         content=response_content,
     )
 

apps/pre-processing-service/app/errors/messages.py

@@ -6,7 +6,7 @@
     status.HTTP_401_UNAUTHORIZED: "인증이 필요합니다.",
     status.HTTP_403_FORBIDDEN: "접근 권한이 없습니다.",
     status.HTTP_404_NOT_FOUND: "요청하신 리소스를 찾을 수 없습니다.",
-    status.HTTP_422_UNPROCESSABLE_ENTITY: "입력 데이터가 유효하지 않습니다.",
+    status.HTTP_422_UNPROCESSABLE_CONTENT: "입력 데이터가 유효하지 않습니다.",
     status.HTTP_500_INTERNAL_SERVER_ERROR: "서버 내부 오류가 발생했습니다.",
 }