diff --git a/rag/src/services/eventhub_consumer.py b/rag/src/services/eventhub_consumer.py index 2b784ab6..dddc17f 100644 --- a/rag/src/services/eventhub_consumer.py +++ b/rag/src/services/eventhub_consumer.py @@ -294,7 +294,7 @@ class EventHubConsumer: # 7. SSE를 통해 결과 전송 # Event Hub 메시지에서 sessionId 추출 (여러 필드 확인) - session_id = event_data.get("sessionId") + session_id = event_data.get("meetingId") # front 요청(회의 주최자만 확인 가능 이슈)으로 이벤트의 sessionId 기준이 아닌 meetingId 기준으로 SSE 연동 # session_id = event_data.get("sessionId") or event_data.get("session_id") or event_data.get("meetingId") or meeting_id logger.info(f"SSE 전송 시도: sessionId={session_id}, meetingId={meeting_id}")