EventHub 재설정 및 Redis 읽기 전용 문제 해결

- EventHub 공유 액세스 정책 재설정 (send-policy, listen-policy) - STT 서비스: send-policy 연결 문자열 업데이트 - AI-Python 서비스: listen-policy 연결 문자열 업데이트 - Meeting 서비스: listen-policy 연결 문자열 업데이트 - Redis DB 2번 Slave → Master 승격 - STT 테스트 페이지 추가 (stt-test-wav.html) - EventHub 재설정 가이드 문서 추가 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
2025-12-06 05:36:23 +00:00 · 2025-10-29 15:56:52 +09:00 · 2025-10-29 15:56:52 +09:00 · 3e411eb8d5
commit 3e411eb8d5
parent 90e31451a5
4 changed files with 636 additions and 3 deletions
--- a/docs/eventhub-setup-guide.md
+++ b/docs/eventhub-setup-guide.md
@ -0,0 +1,210 @@
+# EventHub 재설정 가이드
+
+## 📋 개요
+EventHub 공유 액세스 정책이 초기화되어 재설정이 필요합니다.
+
+### 현재 EventHub 정보
+- **EventHub 이름**: `hgzero-eventhub-name`
+- **네임스페이스**: `hgzero-eventhub-ns.servicebus.windows.net`
+- **소비자 그룹**: `$Default`
+- **상태**: 공유 액세스 정책 없음 (재생성 필요)
+
+---
+
+## 🔐 1단계: Azure Portal에서 공유 액세스 정책 생성
+
+### 1.1 send-policy 생성 (STT 서비스용)
+
+1. Azure Portal → EventHubs → `hgzero-eventhub-ns` → `hgzero-eventhub-name`
+2. 좌측 메뉴에서 **"공유 액세스 정책"** 클릭
+3. **"+ 추가"** 버튼 클릭
+4. 다음 정보 입력:
+   - **정책 이름**: `send-policy`
+   - **권한**: ☑️ Send (보내기만 체크)
+5. **"만들기"** 클릭
+
+### 1.2 listen-policy 생성 (AI, Meeting 서비스용)
+
+1. 동일한 공유 액세스 정책 화면에서 **"+ 추가"** 클릭
+2. 다음 정보 입력:
+   - **정책 이름**: `listen-policy`
+   - **권한**: ☑️ Listen (수신 대기만 체크)
+3. **"만들기"** 클릭
+
+---
+
+## 📝 2단계: 연결 문자열 복사
+
+### 2.1 send-policy 연결 문자열
+
+1. 생성된 `send-policy` 클릭
+2. **"연결 문자열-기본 키"** 복사
+3. ⚠️ **중요**: EntityPath 제거 필요
+
+```
+원본:
+Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=send-policy;SharedAccessKey=xxxxx;EntityPath=hgzero-eventhub-name
+
+수정 후 (EntityPath 제거):
+Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=send-policy;SharedAccessKey=xxxxx
+```
+
+### 2.2 listen-policy 연결 문자열
+
+1. 생성된 `listen-policy` 클릭
+2. **"연결 문자열-기본 키"** 복사
+3. ⚠️ **중요**: EntityPath 제거 필요
+
+```
+수정 후:
+Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=listen-policy;SharedAccessKey=xxxxx
+```
+
+---
+
+## 🔧 3단계: 서비스별 설정 업데이트
+
+### 3.1 STT 서비스 (.env 파일)
+
+**파일**: `stt/src/main/resources/.env`
+
+```env
+# Azure Event Hub (send-policy - Send 권한, EntityPath 제거)
+EVENTHUB_CONNECTION_STRING=Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=send-policy;SharedAccessKey=[YOUR_SEND_KEY]
+EVENTHUB_NAME=hgzero-eventhub-name
+```
+
+### 3.2 AI-Python 서비스 (.env 파일)
+
+**파일**: `ai-python/.env`
+
+```env
+# Azure Event Hub (listen-policy - Listen 권한, EntityPath 제거)
+EVENTHUB_CONNECTION_STRING=Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=listen-policy;SharedAccessKey=[YOUR_LISTEN_KEY]
+EVENTHUB_NAME=hgzero-eventhub-name
+EVENTHUB_CONSUMER_GROUP=$Default
+```
+
+### 3.3 Meeting 서비스 (IntelliJ 실행 프로파일)
+
+**파일**: `meeting/.run/MeetingApplication.run.xml`
+
+`<option name="env">` 섹션에 다음 환경 변수 추가:
+
+```xml
+<env name="EVENTHUB_CONNECTION_STRING" value="Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=listen-policy;SharedAccessKey=[YOUR_LISTEN_KEY]" />
+<env name="EVENTHUB_NAME" value="hgzero-eventhub-name" />
+```
+
+---
+
+## 🚀 4단계: 서비스 재시작
+
+### 4.1 STT 서비스
+```bash
+cd /Users/jominseo/HGZero/stt
+./restart.sh
+```
+
+### 4.2 AI-Python 서비스
+```bash
+cd /Users/jominseo/HGZero/ai-python
+./restart.sh
+```
+
+### 4.3 Meeting 서비스
+IntelliJ에서 `MeetingApplication` 실행 프로파일 재시작
+
+---
+
+## ✅ 5단계: 연결 확인
+
+### 5.1 STT 서비스 로그 확인
+```bash
+tail -f /Users/jominseo/HGZero/logs/stt-service.log | grep -i eventhub
+```
+
+**성공 메시지 예시**:
+```
+EventHub 연결 성공
+EventHub Producer 초기화 완료
+```
+
+### 5.2 AI-Python 서비스 로그 확인
+```bash
+tail -f /Users/jominseo/HGZero/logs/ai-python.log | grep -i eventhub
+```
+
+**성공 메시지 예시**:
+```
+Event Hub 리스너 시작 성공
+EventProcessor 연결 완료
+```
+
+**실패 메시지 (이전)**:
+```
+AuthenticationError('CBS Token authentication failed')
+Event Hub 리스너 오류: 'NoneType' object has no attribute 'eventhub_name'
+```
+
+### 5.3 Meeting 서비스 로그 확인
+IntelliJ 콘솔에서 확인:
+```
+EventHub 연결 초기화 완료
+EventHub Consumer 시작
+```
+
+---
+
+## 🔍 트러블슈팅
+
+### 문제 1: 인증 실패 (Authentication Error)
+**원인**: 연결 문자열이 잘못되었거나 권한이 부족
+**해결**:
+1. 연결 문자열에 EntityPath가 포함되지 않았는지 확인
+2. 정책 권한 확인 (STT: Send, AI/Meeting: Listen)
+3. SharedAccessKey가 정확한지 확인
+
+### 문제 2: EventHub 이름 오류
+**원인**: EVENTHUB_NAME 환경 변수 누락 또는 오타
+**해결**:
+1. `.env` 파일 또는 실행 프로파일에 `EVENTHUB_NAME=hgzero-eventhub-name` 확인
+2. 오타 체크: `hgzero-eventhub-name` (정확히 일치해야 함)
+
+### 문제 3: 소비자 그룹 오류
+**원인**: EVENTHUB_CONSUMER_GROUP 잘못 설정
+**해결**:
+```env
+# 올바른 형식 (작은따옴표 제거)
+EVENTHUB_CONSUMER_GROUP=$Default
+```
+
+---
+
+## 📌 체크리스트
+
+- [ ] Azure Portal에서 `send-policy` 생성 (Send 권한)
+- [ ] Azure Portal에서 `listen-policy` 생성 (Listen 권한)
+- [ ] `send-policy` 연결 문자열 복사 (EntityPath 제거)
+- [ ] `listen-policy` 연결 문자열 복사 (EntityPath 제거)
+- [ ] STT 서비스 `.env` 파일 업데이트
+- [ ] AI-Python 서비스 `.env` 파일 업데이트
+- [ ] Meeting 서비스 실행 프로파일 업데이트
+- [ ] STT 서비스 재시작
+- [ ] AI-Python 서비스 재시작
+- [ ] Meeting 서비스 재시작
+- [ ] 모든 서비스 로그에서 EventHub 연결 성공 확인
+
+---
+
+## 🎯 다음 단계
+
+설정 완료 후:
+1. STT 테스트 페이지로 음성 녹음 테스트
+2. AI 서비스가 EventHub에서 메시지 수신 확인
+3. Meeting 서비스가 회의록 업데이트 수신 확인
+
+---
+
+**작성일**: 2025-10-29
+**작성자**: 준호 (Backend Developer)
--- a/meeting/.run/meeting-service.run.xml
+++ b/meeting/.run/meeting-service.run.xml
@ -43,7 +43,7 @@
          <entry key="KAKAO_API_URL" value="https://dapi.kakao.com" />

          <!-- Azure EventHub Configuration -->
-          <entry key="EVENTHUB_CONNECTION_STRING" value="Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=VUqZ9vFgu35E3c6RiUzoOGVUP8IZpFvlV+AEhC6sUpo=" />
+          <entry key="EVENTHUB_CONNECTION_STRING" value="Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=listen-policy;SharedAccessKey=gl4IA2jQYGTMHCTiNdyarvl1nvtY615v5+AEhHnw1a4=" />
          <entry key="EVENTHUB_NAME" value="hgzero-eventhub-name" />
          <entry key="EVENTHUB_CONSUMER_GROUP" value="$Default" />

--- a/stt/.run/stt-service.run.xml
+++ b/stt/.run/stt-service.run.xml
@ -42,8 +42,8 @@
          <entry key="AZURE_BLOB_CONTAINER_NAME" value="recordings" />

          <!-- Azure EventHub Configuration -->
-          <entry key="EVENTHUB_CONNECTION_STRING" value="Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=VUqZ9vFgu35E3c6RiUzoOGVUP8IZpFvlV+AEhC6sUpo=" />
-          <entry key="EVENTHUB_NAME" value="transcription-events" />
+          <entry key="EVENTHUB_CONNECTION_STRING" value="Endpoint=sb://hgzero-eventhub-ns.servicebus.windows.net/;SharedAccessKeyName=send-policy;SharedAccessKey=e0HwWeJ1f3L6QMejI05K6KVmQ1AdgkVon+AEhPnpZJ0=" />
+          <entry key="EVENTHUB_NAME" value="hgzero-eventhub-name" />
          <entry key="AZURE_EVENTHUB_CONSUMER_GROUP" value="$Default" />

          <!-- Logging Configuration -->
--- a/stt/stt-test-wav.html
+++ b/stt/stt-test-wav.html
@ -0,0 +1,423 @@
+<!DOCTYPE html>
+<html lang="ko">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>STT WebSocket 테스트</title>
+    <style>
+        body {
+            font-family: Arial, sans-serif;
+            max-width: 1200px;
+            margin: 0 auto;
+            padding: 20px;
+            background-color: #f5f5f5;
+        }
+        .container {
+            background: white;
+            border-radius: 8px;
+            padding: 20px;
+            box-shadow: 0 2px 4px rgba(0,0,0,0.1);
+            margin-bottom: 20px;
+        }
+        h2 {
+            color: #333;
+            border-bottom: 2px solid #4CAF50;
+            padding-bottom: 10px;
+        }
+        .controls {
+            display: flex;
+            gap: 10px;
+            margin-bottom: 20px;
+            flex-wrap: wrap;
+        }
+        button {
+            padding: 10px 20px;
+            font-size: 14px;
+            border: none;
+            border-radius: 4px;
+            cursor: pointer;
+            transition: background-color 0.3s;
+        }
+        button:disabled {
+            opacity: 0.5;
+            cursor: not-allowed;
+        }
+        .btn-connect {
+            background-color: #4CAF50;
+            color: white;
+        }
+        .btn-connect:hover:not(:disabled) {
+            background-color: #45a049;
+        }
+        .btn-disconnect {
+            background-color: #f44336;
+            color: white;
+        }
+        .btn-disconnect:hover:not(:disabled) {
+            background-color: #da190b;
+        }
+        .btn-record {
+            background-color: #2196F3;
+            color: white;
+        }
+        .btn-record:hover:not(:disabled) {
+            background-color: #0b7dda;
+        }
+        .btn-stop {
+            background-color: #ff9800;
+            color: white;
+        }
+        .btn-stop:hover:not(:disabled) {
+            background-color: #e68900;
+        }
+        .btn-clear {
+            background-color: #9E9E9E;
+            color: white;
+        }
+        .status {
+            padding: 10px;
+            border-radius: 4px;
+            margin-bottom: 10px;
+            font-weight: bold;
+        }
+        .status-connected {
+            background-color: #dff0d8;
+            color: #3c763d;
+        }
+        .status-disconnected {
+            background-color: #f2dede;
+            color: #a94442;
+        }
+        .status-recording {
+            background-color: #d9edf7;
+            color: #31708f;
+        }
+        .log-container {
+            background-color: #f9f9f9;
+            border: 1px solid #ddd;
+            border-radius: 4px;
+            padding: 10px;
+            max-height: 300px;
+            overflow-y: auto;
+            font-family: 'Courier New', monospace;
+            font-size: 12px;
+        }
+        .log-entry {
+            padding: 5px;
+            margin: 2px 0;
+            border-radius: 3px;
+        }
+        .log-info {
+            background-color: #e7f4ff;
+        }
+        .log-success {
+            background-color: #d4edda;
+        }
+        .log-error {
+            background-color: #f8d7da;
+            color: #721c24;
+        }
+        .log-data {
+            background-color: #fff3cd;
+        }
+        .transcript {
+            padding: 15px;
+            background-color: #f0f8ff;
+            border-left: 4px solid #2196F3;
+            margin: 10px 0;
+            border-radius: 4px;
+        }
+        .transcript-text {
+            font-size: 16px;
+            color: #333;
+            margin-bottom: 5px;
+        }
+        .transcript-meta {
+            font-size: 12px;
+            color: #666;
+        }
+        input {
+            padding: 8px;
+            border: 1px solid #ddd;
+            border-radius: 4px;
+            font-size: 14px;
+        }
+        .stats {
+            display: grid;
+            grid-template-columns: repeat(auto-fit, minmax(200px, 1fr));
+            gap: 10px;
+            margin-top: 10px;
+        }
+        .stat-box {
+            background-color: #f9f9f9;
+            padding: 10px;
+            border-radius: 4px;
+            text-align: center;
+        }
+        .stat-label {
+            font-size: 12px;
+            color: #666;
+        }
+        .stat-value {
+            font-size: 24px;
+            font-weight: bold;
+            color: #333;
+        }
+    </style>
+</head>
+<body>
+    <h1>🎤 STT WebSocket 테스트 도구</h1>
+
+    <div class="container">
+        <h2>연결 설정</h2>
+        <div class="controls">
+            <input type="text" id="wsUrl" value="ws://localhost:8084/ws/audio" placeholder="WebSocket URL" style="width: 300px;">
+            <input type="text" id="meetingId" value="test-mtg-001" placeholder="Meeting ID" style="width: 200px;">
+            <button class="btn-connect" id="connectBtn" onclick="connect()">연결</button>
+            <button class="btn-disconnect" id="disconnectBtn" onclick="disconnect()" disabled>연결 해제</button>
+        </div>
+        <div id="status" class="status status-disconnected">연결 안 됨</div>
+    </div>
+
+    <div class="container">
+        <h2>녹음 제어</h2>
+        <div class="controls">
+            <button class="btn-record" id="recordBtn" onclick="startRecording()" disabled>녹음 시작</button>
+            <button class="btn-stop" id="stopBtn" onclick="stopRecording()" disabled>녹음 중지</button>
+            <button class="btn-clear" onclick="clearLogs()">로그 지우기</button>
+        </div>
+        <div class="stats">
+            <div class="stat-box">
+                <div class="stat-label">전송된 청크</div>
+                <div class="stat-value" id="chunkCount">0</div>
+            </div>
+            <div class="stat-box">
+                <div class="stat-label">전송 데이터</div>
+                <div class="stat-value" id="dataSize">0 KB</div>
+            </div>
+            <div class="stat-box">
+                <div class="stat-label">녹음 시간</div>
+                <div class="stat-value" id="recordTime">0초</div>
+            </div>
+        </div>
+    </div>
+
+    <div class="container">
+        <h2>STT 결과</h2>
+        <div id="transcripts"></div>
+    </div>
+
+    <div class="container">
+        <h2>통신 로그</h2>
+        <div class="log-container" id="logContainer"></div>
+    </div>
+
+    <script>
+        let ws = null;
+        let mediaRecorder = null;
+        let audioStream = null;
+        let chunkCounter = 0;
+        let totalDataSize = 0;
+        let recordStartTime = null;
+        let recordTimer = null;
+
+        function addLog(message, type = 'info') {
+            const logContainer = document.getElementById('logContainer');
+            const timestamp = new Date().toLocaleTimeString('ko-KR', { hour12: false });
+            const logEntry = document.createElement('div');
+            logEntry.className = `log-entry log-${type}`;
+            logEntry.textContent = `[${timestamp}] ${message}`;
+            logContainer.appendChild(logEntry);
+            logContainer.scrollTop = logContainer.scrollHeight;
+        }
+
+        function updateStatus(message, isConnected, isRecording = false) {
+            const statusEl = document.getElementById('status');
+            statusEl.textContent = message;
+            statusEl.className = 'status ' +
+                (isRecording ? 'status-recording' : (isConnected ? 'status-connected' : 'status-disconnected'));
+        }
+
+        function updateStats() {
+            if (recordStartTime) {
+                const elapsed = Math.floor((Date.now() - recordStartTime) / 1000);
+                document.getElementById('recordTime').textContent = `${elapsed}초`;
+            }
+        }
+
+        function connect() {
+            const wsUrl = document.getElementById('wsUrl').value;
+            const meetingId = document.getElementById('meetingId').value;
+
+            addLog(`WebSocket 연결 시도: ${wsUrl}`, 'info');
+
+            ws = new WebSocket(wsUrl);
+
+            ws.onopen = () => {
+                addLog('WebSocket 연결 성공!', 'success');
+                updateStatus('연결됨', true);
+
+                // 녹음 시작 메시지 전송
+                const startMsg = {
+                    type: 'start',
+                    meetingId: meetingId
+                };
+                ws.send(JSON.stringify(startMsg));
+                addLog(`START 메시지 전송: ${JSON.stringify(startMsg)}`, 'data');
+
+                document.getElementById('connectBtn').disabled = true;
+                document.getElementById('disconnectBtn').disabled = false;
+                document.getElementById('recordBtn').disabled = false;
+            };
+
+            ws.onmessage = (event) => {
+                try {
+                    const data = JSON.parse(event.data);
+                    addLog(`메시지 수신: ${JSON.stringify(data)}`, 'success');
+
+                    if (data.transcript) {
+                        // STT 결과 표시
+                        const transcriptsEl = document.getElementById('transcripts');
+                        const transcriptDiv = document.createElement('div');
+                        transcriptDiv.className = 'transcript';
+                        transcriptDiv.innerHTML = `
+                            <div class="transcript-text">${data.transcript}</div>
+                            <div class="transcript-meta">
+                                신뢰도: ${(data.confidence * 100).toFixed(1)}% |
+                                화자: ${data.speaker} |
+                                시간: ${new Date(data.timestamp).toLocaleTimeString('ko-KR')}
+                            </div>
+                        `;
+                        transcriptsEl.insertBefore(transcriptDiv, transcriptsEl.firstChild);
+                    }
+                } catch (e) {
+                    addLog(`메시지 파싱 오류: ${e.message}`, 'error');
+                }
+            };
+
+            ws.onerror = (error) => {
+                addLog(`WebSocket 오류: ${error}`, 'error');
+            };
+
+            ws.onclose = () => {
+                addLog('WebSocket 연결 종료', 'info');
+                updateStatus('연결 안 됨', false);
+                document.getElementById('connectBtn').disabled = false;
+                document.getElementById('disconnectBtn').disabled = true;
+                document.getElementById('recordBtn').disabled = true;
+                document.getElementById('stopBtn').disabled = true;
+            };
+        }
+
+        function disconnect() {
+            if (ws) {
+                const stopMsg = { type: 'stop' };
+                ws.send(JSON.stringify(stopMsg));
+                addLog(`STOP 메시지 전송: ${JSON.stringify(stopMsg)}`, 'data');
+                ws.close();
+                ws = null;
+            }
+            if (mediaRecorder && mediaRecorder.state === 'recording') {
+                stopRecording();
+            }
+        }
+
+        async function startRecording() {
+            try {
+                audioStream = await navigator.mediaDevices.getUserMedia({
+                    audio: {
+                        channelCount: 1,
+                        sampleRate: 16000,
+                        echoCancellation: true,
+                        noiseSuppression: true
+                    }
+                });
+
+                addLog('마이크 접근 허용됨', 'success');
+
+                mediaRecorder = new MediaRecorder(audioStream, {
+                    mimeType: 'audio/webm;codecs=opus',
+                    audioBitsPerSecond: 16000
+                });
+
+                chunkCounter = 0;
+                totalDataSize = 0;
+                recordStartTime = Date.now();
+                recordTimer = setInterval(updateStats, 1000);
+
+                mediaRecorder.ondataavailable = (event) => {
+                    if (event.data.size > 0 && ws && ws.readyState === WebSocket.OPEN) {
+                        const reader = new FileReader();
+                        reader.readAsDataURL(event.data);
+                        reader.onloadend = () => {
+                            const base64Audio = reader.result.split(',')[1];
+                            const meetingId = document.getElementById('meetingId').value;
+
+                            const chunkMsg = {
+                                type: 'chunk',
+                                meetingId: meetingId,
+                                audioData: base64Audio,
+                                timestamp: Date.now(),
+                                chunkIndex: chunkCounter++,
+                                format: 'audio/webm',
+                                sampleRate: 16000
+                            };
+
+                            ws.send(JSON.stringify(chunkMsg));
+
+                            totalDataSize += event.data.size;
+                            document.getElementById('chunkCount').textContent = chunkCounter;
+                            document.getElementById('dataSize').textContent = (totalDataSize / 1024).toFixed(2) + ' KB';
+
+                            addLog(`청크 #${chunkCounter} 전송: ${(event.data.size / 1024).toFixed(2)} KB`, 'data');
+                        };
+                    }
+                };
+
+                mediaRecorder.start(1000); // 1초마다 청크 전송
+                addLog('녹음 시작 (1초 간격)', 'success');
+                updateStatus('녹음 중', true, true);
+
+                document.getElementById('recordBtn').disabled = true;
+                document.getElementById('stopBtn').disabled = false;
+
+            } catch (error) {
+                addLog(`마이크 접근 실패: ${error.message}`, 'error');
+            }
+        }
+
+        function stopRecording() {
+            if (mediaRecorder && mediaRecorder.state === 'recording') {
+                mediaRecorder.stop();
+                mediaRecorder = null;
+                addLog('녹음 중지', 'info');
+            }
+
+            if (audioStream) {
+                audioStream.getTracks().forEach(track => track.stop());
+                audioStream = null;
+            }
+
+            if (recordTimer) {
+                clearInterval(recordTimer);
+                recordTimer = null;
+            }
+
+            updateStatus('연결됨', true, false);
+            document.getElementById('recordBtn').disabled = false;
+            document.getElementById('stopBtn').disabled = true;
+        }
+
+        function clearLogs() {
+            document.getElementById('logContainer').innerHTML = '';
+            document.getElementById('transcripts').innerHTML = '';
+            chunkCounter = 0;
+            totalDataSize = 0;
+            recordStartTime = null;
+            document.getElementById('chunkCount').textContent = '0';
+            document.getElementById('dataSize').textContent = '0 KB';
+            document.getElementById('recordTime').textContent = '0초';
+        }
+    </script>
+</body>
+</html>