From ae59a27ff6efa68d91cb08b482c4c5348671b3c9 Mon Sep 17 00:00:00 2001 From: ChaJunWoo18 Date: Tue, 17 Jun 2025 17:09:52 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20publish=20=EB=A9=94=EC=8B=9C=EC=A7=80?= =?UTF-8?q?=EC=97=90=20=EB=B6=84=EC=84=9D=20=EC=84=B1=EA=B3=B5/=EC=8B=A4?= =?UTF-8?q?=ED=8C=A8=20=EC=BD=94=EB=93=9C=20=EC=B6=94=EA=B0=80=20-=20close?= =?UTF-8?q?=20#14?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/config/constants.py | 6 ++++++ src/rabbitmq/consume.py | 6 ++++-- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/src/config/constants.py b/src/config/constants.py index cbeafa4..359f9fc 100644 --- a/src/config/constants.py +++ b/src/config/constants.py @@ -16,3 +16,9 @@ class ERROR: FAILED_CREATE_SUBTITLE = "자막 파일 생성에 실패했습니다." FAILED_CONNECT_CHANNEL = "채널 연결에 실패했습니다." SERVER_ERROR = "서버 오류가 발생했습니다." + +class CODE: + class SUCCESSS: + ANALYZE = "SUCCESS_ANALYZE" + class FAILED: + ANALYZE = "FAILED_ANALYZE" diff --git a/src/rabbitmq/consume.py b/src/rabbitmq/consume.py index 3fbacae..312b042 100644 --- a/src/rabbitmq/consume.py +++ b/src/rabbitmq/consume.py @@ -2,7 +2,7 @@ import os from analyze_video import analyze_frame -from config.constants import MESSAGES +from config.constants import MESSAGES, CODE from gcs.generate_signed_url import generate_signed_url from gcs.read import get_video from gcs.write import upload_video @@ -48,6 +48,7 @@ def process_message(body): signed_url = generate_signed_url(file_name=file_name) message = { "email": email, + "code": CODE.SUCCESSS.ANALYZE, "message": MESSAGES.SUCCESS.ANALYZE, "url": signed_url } @@ -57,8 +58,9 @@ def process_message(body): except Exception as err: message = { "email": email, + "code": CODE.FAILED.ANALYZE, "message": str(err), - "url": "" + "url": None } return message