Skip to content

Commit c9ac432

Browse files
committed
refactor: publish 메시지에 분석 성공/실패 코드 추가 - close #14
1 parent 86cf3fe commit c9ac432

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

src/config/constants.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,3 +16,9 @@ class ERROR:
1616
FAILED_CREATE_SUBTITLE = "자막 파일 생성에 실패했습니다."
1717
FAILED_CONNECT_CHANNEL = "채널 연결에 실패했습니다."
1818
SERVER_ERROR = "서버 오류가 발생했습니다."
19+
20+
class CODE:
21+
class SUCCESSS:
22+
ANALYZE = "SUCCESS_ANALYZE"
23+
class FAILED:
24+
ANALYZE = "FAILED_ANALYZE"

src/rabbitmq/consume.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
import os
33

44
from analyze_video import analyze_frame
5-
from config.constants import MESSAGES
5+
from config.constants import MESSAGES, CODE
66
from gcs.generate_signed_url import generate_signed_url
77
from gcs.read import get_video
88
from gcs.write import upload_video
@@ -48,6 +48,7 @@ def process_message(body):
4848
signed_url = generate_signed_url(file_name=file_name)
4949
message = {
5050
"email": email,
51+
"code": CODE.SUCCESSS.ANALYZE,
5152
"message": MESSAGES.SUCCESS.ANALYZE,
5253
"url": signed_url
5354
}
@@ -57,8 +58,9 @@ def process_message(body):
5758
except Exception as err:
5859
message = {
5960
"email": email,
61+
"code": CODE.FAILED.ANALYZE,
6062
"message": str(err),
61-
"url": ""
63+
"url": None
6264
}
6365

6466
return message

0 commit comments

Comments
 (0)