-
이코에코(Eco²) Agent Skills: Chat Agent Architecture Reference이코에코(Eco²)/Skills 2026. 1. 19. 06:19
https://github.com/eco2-team/backend/pull/420 Eco² Chat Worker의 전체 아키텍처 및 컴포넌트 구조 (2026-01-19)
E2E 테스트 및 에이전트 온보딩에 활용System Architecture
┌─────────────────────────────────────────────────────────────────────────────┐ │ Chat Agent System Architecture │ ├─────────────────────────────────────────────────────────────────────────────┤ │ │ │ Client │ │ ┌─────────────────┐ │ │ │ Frontend/curl │ │ │ └────────┬────────┘ │ │ │ │ │ ─────────┼──────────────────────────────────────────────────────────────── │ │ │ │ │ Istio Gateway (api.growbin.app) │ │ ┌────────▼────────┐ │ │ │ eco2-gateway │ Cookie → Header 변환 (EnvoyFilter) │ │ └────────┬────────┘ │ │ │ │ │ ─────────┼──────────────────────────────────────────────────────────────── │ │ │ │ │ VirtualService Routing (chat-vs) │ │ ┌────────▼────────────────────────────────────────────────────┐ │ │ │ 1. [regex] /api/v1/chat/[^/]+/events → sse-gateway (SSE) │ │ │ │ 2. [prefix] /api/v1/chat → chat-api (REST) │ │ │ └────────┬───────────────────────────────────┬────────────────┘ │ │ │ │ │ │ ─────────┼───────────────────────────────────┼──────────────────────────── │ │ │ │ │ │ Services │ │ │ │ ┌────────▼────────┐ ┌────────▼─────────┐ │ │ │ chat-api │ │ sse-gateway │ │ │ │ (ns: chat) │ │ (ns: sse-consumer)│ │ │ └────────┬────────┘ └────────▲─────────┘ │ │ │ │ SUBSCRIBE │ │ ─────────┼───────────────────────────────────┼──────────────────────────── │ │ │ │ │ │ Message Queue Redis Pub/Sub (rfr-pubsub-redis) │ │ ┌────────▼────────┐ ┌────────┴─────────┐ │ │ │ RabbitMQ │ │ sse:events:* │ │ │ │ chat.process │ │ (ns: redis) │ │ │ │ (ns: rabbitmq) │ └────────▲─────────┘ │ │ └────────┬────────┘ │ PUBLISH │ │ │ │ │ │ ─────────┼───────────────────────────────────┼──────────────────────────── │ │ │ │ │ │ Worker │ ┌────────┴─────────┐ │ │ ┌────────▼────────┐ │ event-router │ │ │ │ chat-worker │ │ (ns: event-router)│ │ │ │ (LangGraph) │ └────────▲─────────┘ │ │ │ (ns: chat) │ │ XREADGROUP │ │ └────────┬────────┘ │ │ │ │ │ │ │ ─────────┼───────────────────────────────────┼──────────────────────────── │ │ │ │ │ │ │ XADD Redis Streams (rfr-streams-redis) │ │ │ ┌────────┴─────────┐ │ │ └─────────────────────────▶│ chat:events:{0-3}│ │ │ │ (ns: redis) │ │ │ └──────────────────┘ │ │ │ └─────────────────────────────────────────────────────────────────────────────┘ Redis Instances (namespace: redis) ┌──────────────────────┬──────────────────────┐ │ rfr-streams-redis │ rfr-pubsub-redis │ │ (Redis Streams) │ (Redis Pub/Sub) │ │ │ │ │ chat:events:{0-3} │ sse:events:{job} │ │ chat:tokens:{job} │ │ │ chat:published:* │ │ └──────────────────────┴──────────────────────┘LangGraph Pipeline
┌─────────────────────────────────────────────────────────────────────────────┐ │ LangGraph Chat Pipeline │ ├─────────────────────────────────────────────────────────────────────────────┤ │ │ │ [Entry] ──▶ [vision_node] ──▶ [intent_node] ──▶ [router_node] │ │ │ │ │ │ │ │ Intent 분류 Dynamic Router │ │ │ (LLM + Keyword) (Send API) │ │ 이미지 분류 │ │ │ │ (선택) ▼ ▼ │ │ ┌─────────────────────────────────┐ │ │ │ Parallel Execution │ │ │ │ ┌────────┐ ┌────────┐ ┌──────┐ │ │ │ │ │waste_ │ │collect │ │weath │ │ │ │ │ │ rag │ │ _point │ │ er │ │ │ │ │ └────┬───┘ └───┬────┘ └──┬───┘ │ │ │ │ │ │ │ │ │ │ │ └─────────┼─────────┘ │ │ │ │ │ │ │ │ └─────────────────┼────────────────┘ │ │ ▼ │ │ [aggregator_node] │ │ │ │ │ 컨텍스트 수집 │ │ │ │ │ ▼ │ │ [answer_node] │ │ │ │ │ LLM 답변 생성 │ │ (Token Streaming) │ │ │ │ │ ▼ │ │ [feedback_node] │ │ │ │ │ 품질 평가 │ │ (Fallback Loop) │ │ │ │ │ ▼ │ │ [END] │ │ │ └─────────────────────────────────────────────────────────────────────────────┘Node Details
Core Nodes
Node Purpose External API vision_node이미지 기반 폐기물 분류 OpenAI Vision API intent_nodeIntent 분류 (9개 카테고리) LLM (Structured Output) router_nodeDynamic Routing (Send API) - aggregator_node컨텍스트 수집 및 검증 - answer_node최종 답변 생성 (토큰 스트리밍) LLM feedback_node답변 품질 평가 LLM (Judge) Subagent Nodes
Node Purpose External API Timeout waste_rag분리배출 규칙 검색 Local JSON 8s character캐릭터 정보 조회 gRPC (character-grpc) 5s location장소 검색 Kakao Local API 5s bulk_waste대형폐기물 정보 행정안전부 API 8s recyclable_price재활용 시세 한국환경공단 API 5s collection_point수거함 위치 KECO API 8s web_search웹 검색 DuckDuckGo/Tavily 10s image_generation이미지 생성 OpenAI DALL-E / Gemini 30s weather날씨 정보 (enrichment) 기상청 API 8s general일반 대화 LLM Direct 5s Enrichment Rules
ENRICHMENT_RULES = { "waste": ("weather",), # 분리배출 → 날씨 팁 "bulk_waste": ("weather",), # 대형폐기물 → 날씨 팁 } # Conditional Enrichment if user_location is not None and intent not in {"weather", "general", "character"}: add("weather") # 위치 있으면 날씨 자동 추가Kubernetes Resources
Namespaces
Namespace Components chatchat-api, chat-worker sse-consumersse-gateway event-routerevent-router redisrfr-streams-redis, rfr-pubsub-redis rabbitmqeco2-rabbitmq Pod DNS Reference
# Redis Master (직접 연결) rfr-pubsub-redis-0.rfr-pubsub-redis.redis.svc.cluster.local:6379 # Redis Streams rfr-streams-redis-0.rfr-streams-redis.redis.svc.cluster.local:6379 # RabbitMQ eco2-rabbitmq.rabbitmq.svc.cluster.local:5672Event Flow
┌─────────────────────────────────────────────────────────────────────────────┐ │ Event Flow │ ├─────────────────────────────────────────────────────────────────────────────┤ │ │ │ chat-worker event-router sse-gateway │ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │ │ LangGraph│ │Lua Script│ │ Pub/Sub │ │ │ │ Pipeline │ │ │ │ Listener │ │ │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │ │ │ │ │ │ │ XADD chat:events:{id} │ │ │ │ ├─────────────────────────▶│ │ │ │ │ │ │ │ │ │ │ PUBLISH sse:events:{id}│ │ │ │ ├────────────────────────▶│ │ │ │ │ │ │ │ │ │ │ SSE Event │ │ │ │ ├────────────────▶│ │ │ │ │ Client │ │ │ └─────────────────────────────────────────────────────────────────────────────┘Configuration
Environment Variables (chat-worker)
Variable Description Example CHAT_WORKER_RABBITMQ_URLRabbitMQ 연결 amqp://...CHAT_WORKER_REDIS_URLRedis (캐시, 기타) redis://rfr-pubsub-redis-0...CHAT_WORKER_REDIS_STREAMS_URLRedis Streams (이벤트 발행) redis://rfr-streams-redis...CHAT_WORKER_OPENAI_API_KEYOpenAI API 키 sk-...CHAT_WORKER_GOOGLE_API_KEYGoogle API 키 - CHAT_WORKER_DEFAULT_PROVIDERLLM Provider openai/googleEnvironment Variables (event-router)
Variable Description Example REDIS_STREAMS_URLRedis Streams (이벤트 소비) redis://rfr-streams-redis...REDIS_PUBSUB_URLRedis Pub/Sub (SSE 브로드캐스트) redis://rfr-pubsub-redis...ExternalSecret Reference
# workloads/secrets/external-secrets/dev/chat-worker-secrets.yaml spec: secretStoreRef: name: aws-secrets-manager kind: ClusterSecretStore target: name: chat-worker-secrets data: - secretKey: OPENAI_API_KEY remoteRef: key: eco2/dev/openai property: api_key'이코에코(Eco²) > Skills' 카테고리의 다른 글
이코에코(Eco²) Agent Skills: Checkpointer Reference (0) 2026.01.19 이코에코(Eco²) Agent Skills: Chat Agent Persistence Guide (0) 2026.01.19 이코에코(Eco²) Agent Skills: Chat Agent Flow Guide (0) 2026.01.19 이코에코(Eco²) Agent Skills: Chat E2E Test Script Reference (0) 2026.01.19 Cursor에서 Claude Code로 컨택스트 마이그레이션 (0) 2026.01.16