船舶消防法规聊天机器人

# 의존성 설치
pip install -r requirements.txt

# 환경변수 설정
cp .env.example .env
# .env 파일에서 AWS 자격증명 설정

streamlit run app.py

shi-graphrag-chatbot/
├── agents/                    # 에이전트 모듈
│   └── plan_execute_agent/
│       ├── agent.py          # 기존 동기 버전
│       └── streaming_agent.py # 새로운 스트리밍 버전
├── config/
│   └── agents.yaml           # 에이전트 설정
├── core/
│   └── agent_manager.py      # 에이전트 관리자
├── ui/                       # UI 컴포넌트
│   ├── chat_interface.py
│   ├── reference_display.py
│   └── sidebar.py
└── app.py                    # 메인 애플리케이션

agents:
  plan_execute:
    display_name: "Plan-Execute Agent (스트리밍)"
    streaming_enabled: true
    streaming_config:
      chunk_size: 50
      timeout: 30
      fallback_to_sync: true
    bedrock_model_id: "anthropic.claude-3-5-sonnet-20240620-v1:0"

graph TD
    A[사용자 질문] --> B[1단계: 계획 수립]
    B --> C[2단계: KB 검색]
    C --> D[3단계: 답변 생성]
    D --> E[참조 문서 표시]
    
    B -.-> F[실시간 스트리밍]
    C -.-> F
    D -.-> F

async def process_message_stream(self, message: str, session_id: str):
    """스트리밍 메서드 구현"""
    yield "### 1단계: 처리 시작\n\n"
    # 처리 로직...
    async for chunk in self._stream_process():
        yield chunk

# 기본 테스트
python test_simple.py

# 스트리밍 테스트
python test_streaming.py

# 실시간 모니터링
python live_test_monitor.py