fos-blog/study
01 / 홈02 / 카테고리03 / 시리즈
01 / 홈02 / 카테고리03 / 시리즈

카테고리

  • AI 페이지로 이동
    • RAG 페이지로 이동
    • agent 페이지로 이동
    • langgraph 페이지로 이동
    • 사람용 CLI와 AI 에이전트용 CLI는 설계가 다르다
    • agents.md
    • BMAD Method — AI 에이전트로 애자일 개발하는 방법론
    • Claude Code 메모리: CLAUDE.md와 .claude/rules를 규칙으로 쓰는 법
    • Claude Code의 Skill 시스템 - 개발자를 위한 AI 자동화의 새로운 차원
    • Claude Code를 5주 더 쓴 결과 — 스킬·CLAUDE.md를 키워가는 방식
    • Claude Code를 11일 동안 쓴 결과 — 데이터로 본 나의 사용 패턴
    • Claude Code 멀티 에이전트 — Teams
    • AI 에이전트와 디자인의 새 컨벤션 — DESIGN.md, Google Stitch, Claude Design
    • Docling — IBM Research 의 문서 파싱 toolkit 상세 정리
    • 하네스 엔지니어링 실전 — 4인 에이전트 팀으로 코딩 파이프라인 구축하기
    • 하네스 엔지니어링 — 오래 실행되는 AI 에이전트를 위한 설계
    • 멀티모달 LLM (Multimodal Large Language Model)
    • AI 에이전트와 함께 MVP 만들기 — dooray-cli 사례
    • OpenClaw는 context와 memory를 어떻게 관리하나 — 나만의 에이전트를 구성하는 법
    • OpenClaw vs Hermes Agent — 갈아탈까 고민하며 정리한 비교
    • 스킬 문서를 신경망처럼 학습시킨다 — Microsoft SkillOpt 분석
  • ai 페이지로 이동
    • agent 페이지로 이동
    • [초안] AI 제품 백엔드 안정성 — 지연·비용·권한·관측·도구 실패·폴백/재시도/사람 에스컬레이션
    • [초안] LLM 평가 프레임워크: 골든셋, 회귀 테스트, LLM-as-a-judge, 사람 피드백 루프
  • algorithm 페이지로 이동
    • live-coding 페이지로 이동
    • 분산 계산을 위한 알고리즘
  • apartment 페이지로 이동
    • 구리 럭키아파트 24평 인테리어 레퍼런스 모음
  • architecture 페이지로 이동
    • [초안] 시니어 백엔드를 위한 API 설계 실전 스터디 팩 — REST · 멱등성 · 페이지네이션 · 버전 전략
    • [초안] API Versioning과 Backward Compatibility: 시니어 백엔드 관점 정리
    • 캐시 설계 전략 총정리
    • [초안] 커머스 Spring 서비스에 Clean/Hexagonal Architecture를 실용적으로 적용하기
    • [초안] 커머스 도메인 모델링: 주문·재고·노출의 세 축을 분리해서 설계하기
    • 커머스 주문 상태와 데이터 정합성 기본기
    • [초안] 쿠폰/프로모션 동시성과 정합성 기본기 — 선착순·중복 사용 방지·발급/사용/복구
    • [초안] DDD와 도메인 모델링: 시니어 백엔드 관점의 전술/전략 패턴 실전 가이드
    • [초안] Decorator & Chain of Responsibility — 행동을 체인으로 조립하는 두 가지 방식
    • 디자인 패턴
    • [초안] 분산 아키텍처 완전 정복: Java 백엔드 시니어 인터뷰 대비 실전 가이드
    • [초안] 분산 트랜잭션과 Outbox 패턴 — 왜 2PC를 피하고 어떻게 대신할 것인가
    • 분산 트랜잭션
    • [초안] e-Commerce 주문·결제 도메인 모델링: 상태머신, 멱등성, Outbox/Saga 실전 정리
    • [초안] Event Sourcing과 CQRS — 상태가 아니라 변화를 저장한다는 발상
    • [초안] F&B 쿠폰·프로모션·멤버십·포인트 설계
    • [초안] F&B · e-Commerce 디지털 채널 도메인 한 장 정리
    • [초안] F&B 주문/매장/픽업 상태머신 설계
    • [초안] F&B 이커머스 결제·환불·정산 운영 가이드
    • [초안] Hexagonal / Clean Architecture를 Spring 백엔드에 적용하기
    • [초안] 대규모 커머스 트래픽 처리 패턴 — 대규모 회원과 메가 프로모션을 버티는 설계
    • [초안] 레거시 JSP/jQuery 화면과 신규 API가 공존하는 백엔드 운영 전략
    • [초안] MSA 서비스 간 통신: Redis [Cache-Aside](../database/redis/cache-aside.md) × Kafka 이벤트 하이브리드 설계
    • [초안] Observability 입문: 시니어 백엔드가 장애를 탐지하고 대응하는 방식
    • [초안] Outbox / Inbox Pattern 심화 — 분산 메시징의 정합성 문제를 DB 트랜잭션으로 풀어내기
    • [초안] 결제 도메인 멱등성과 트랜잭션 재시도 기본기
    • [초안] 시니어 백엔드를 위한 Resilience 패턴 실전 가이드 — Timeout, Retry, Circuit Breaker, Bulkhead, Backpressure
    • [초안] REST API 버저닝과 모바일 앱 하위 호환성 — 디지털 채널 백엔드 관점
    • [초안] Spring Batch vs Event-Driven — 같은 비동기처럼 보이지만 전혀 다른 두 패러다임
    • [초안] Strategy Pattern — 분기문을 없애는 설계, 시니어 백엔드 인터뷰 핵심 패턴
    • [초안] 시니어 백엔드를 위한 시스템 설계 입문 스터디 팩
    • [초안] 템플릿 메서드 패턴 - 백엔드 처리 골격을 강제하는 가장 오래되고 가장 위험한 패턴
    • [초안] 대규모 트래픽 중 무중단 마이그레이션 — Feature Flag + Shadow Mode 실전
  • database 페이지로 이동
    • milvus 페이지로 이동
    • mysql 페이지로 이동
    • opensearch 페이지로 이동
    • qdrant 페이지로 이동
    • redis 페이지로 이동
    • vespa 페이지로 이동
    • 김영한의-실전-데이터베이스-설계 페이지로 이동
    • [초안] DB Connection Pool Saturation과 Thread Pool 격리
    • 커넥션 풀 크기는 얼마나 조정해야 할까?
    • 인덱스 - DB 성능 최적화의 핵심
    • [초안] JPA N+1과 커머스 조회 모델: 주문/메뉴/쿠폰 도메인에서 살아남기
    • [초안] MyBatis 기본기 — XML Mapper, resultMap, 동적 SQL, 운영 패턴 정리
    • [초안] MyBatis와 JPA/Hibernate 트레이드오프 — 레거시 백엔드를 다루는 시니어 관점
    • 한국어 형태소 분석기 Nori vs Lindera — OpenSearch에서 Milvus로 갈 때 어휘 검색은 유지되나
    • 벡터 DB 5종, 아키텍처는 어떻게 다른가
    • 벡터 DB 5종을 실제로 벤치마크했다 — 같은 recall에서 QPS는 얼마나 갈리나
    • 벡터 DB 어떻게 고를까 — OpenSearch · Milvus · Qdrant · Vespa · pgvector 비교
    • 벡터 DB를 실제로 도입한 사례 — 빅테크 프로덕션
    • 역정규화 (Denormalization)
    • 데이터 베이스 정규화
  • devops 페이지로 이동
    • docker 페이지로 이동
    • k8s 페이지로 이동
    • k8s-in-action 페이지로 이동
    • observability 페이지로 이동
    • [초안] 커머스/F&B 채널 장애 첫 5분과 관측성 기본기
    • [초안] 운영 데이터 정합성 장애 대응 — 결제 취소 누락과 중복 적재 런북
    • Envoy Proxy
    • [초안] F&B / e-Commerce 운영 장애 대응과 모니터링 — 백엔드 관점 정리
    • Graceful Shutdown
    • [초안] 시니어 백엔드를 위한 SLO와 Error Budget 기반 장애 대응
  • http 페이지로 이동
    • HTTP Connection Pool
    • HTTPS는 어떻게 안전한가 — TLS, 인증서, 그리고 termination
  • interview 페이지로 이동
    • [초안] AI 서비스 팀 경험 기반 시니어 백엔드 면접 질문 뱅크 — Spring Batch RAG / gRPC graceful shutdown / 전략 패턴 / 12일 AI 웹툰 MVP
    • Observability — 면접 답변 프레임
    • [초안] 시니어 Java 백엔드 면접 마스터 플레이북 — 김병태
    • [초안] NSC 슬롯팀 경험 기반 질문 은행 — 도메인 모델링·동시성·성능·AI 협업
  • java 페이지로 이동
    • concurrency 페이지로 이동
    • jdbc 페이지로 이동
    • opentelemetry 페이지로 이동
    • spring 페이지로 이동
    • spring-batch 페이지로 이동
    • testing 페이지로 이동
    • 더_자바_코드를_조작하는_다양한_방법 페이지로 이동
    • [초안] Java 동시성 락 정리 — 커머스 메뉴/프로모션 정책 캐시 갱신 관점
    • [초안] JVM 튜닝 실전: 메모리 구조부터 Virtual Threads, GC 튜닝, 프로파일링까지
    • Java의 로깅 환경
    • MDC (Mapped Diagnostic Context)
    • Java StampedLock — 읽기 폭주에도 쓰기가 밀리지 않는 락
    • Virtual Thread와 Project Loom
  • javascript 페이지로 이동
    • typescript 페이지로 이동
    • AbortController
    • Async Iterator와 제너레이터
    • CommonJS와 ECMAScript Modules
    • 제너레이터(Generator)
    • Http Client
    • Node 백엔드 운영 패턴 — Streams 백프레셔, pipe/pipeline, 멱등성 vs 분산 락
    • Node.js
    • npm vs pnpm — 어떤 기준으로 선택했나
    • `setImmediate()`
  • kafka 페이지로 이동
    • [초안] Kafka 기본 개념 — 토픽, 파티션, 오프셋, 복제
    • Kafka를 사용하여 **데이터 정합성**은 어떻게 유지해야 할까?
    • [초안] Kafka 실전 설계: 파티션 전략, 컨슈머 그룹, 전달 보장, 재시도, 순서 보장 트레이드오프
    • 메시지 전송 신뢰성
    • [초안] Spring Kafka 컨슈머 오프셋 커밋과 트랜잭션 정렬: AckMode, manual ack, 멱등 처리
  • linux 페이지로 이동
    • fsync — 리눅스 파일 동기화 시스템 콜
    • tmux — Terminal Multiplexer
  • mlops 페이지로 이동
    • llm-serving 페이지로 이동
    • Python CUDA 버전 생태계 — nvidia-smi, nvcc, pip, conda가 다 다른 버전을 말하는 이유
    • GPU 컨테이너의 CUDA 버전 호환성 — nvidia-smi부터 이미지 다이어트까지
    • Kubernetes GPU 노드에서 /run tmpfs가 꽉 차서 Pod가 안 뜰 때
    • GPU·CUDA·MPS 기초 — 자바 백엔드 개발자가 처음 만나는 그림
    • Multi-process GPU 워크로드 — 자바 ThreadPool 사용자가 만나는 모델 차이
    • ML 서비스 성능 분석 워크플로 — 자바 백엔드 트러블슈팅과 다른 점
    • 한 GPU 를 여러 프로세스가 나눠 쓰기 — Time-Slicing 과 MPS
  • network 페이지로 이동
    • Connection reset by peer는 누가 보낸 걸까 — 리버스 프록시 홉마다 TCP 연결은 따로 논다
    • L2(스위치)와 L3(라우터)의 역할 차이
    • L4와 VIP(Virtual IP Address)
    • IP Subnet
  • python 페이지로 이동
    • Python async/await — CompletableFuture·Reactor 와 다른 점, 그리고 blocking I/O 함정
    • Python 의존성 관리 — Java Maven/Gradle 사용자가 만나는 첫 충격
    • FastAPI 기초 — Spring Boot 사용자가 빠르게 익히는 법
    • Java 개발자를 위한 Python 심화 — OOP·데코레이터·컨텍스트 매니저
    • PyTorch 기초 — 텐서, 디바이스, 그리고 모델 로딩이 무거운 이유
    • Java 개발자를 위한 Python 문법 핵심
    • ThreadLocal 에서 contextvars 로 — Python 의 요청 컨텍스트 전파
    • OCR 동작 원리 — Layout · Text · Post-process 3단계
    • Python 서버의 RSS 가 안 줄어드는 이유 — gc.collect 의 한계와 malloc_trim
  • rabbitmq 페이지로 이동
    • [초안] RabbitMQ Basics — 실전 백엔드 관점에서 정리하는 메시지 브로커 기본기
    • [초안] RabbitMQ vs Kafka — 백엔드 메시징 선택 기준과 실전 운영 관점
  • security 페이지로 이동
    • [초안] 시니어 백엔드를 위한 보안 / 인증 스터디 팩 — Spring Security, JWT, OAuth2, OWASP Top 10
    • [초안] Spring Security 6.x OAuth2 + JWT 상용 인증 설계 — Grant 선택, Resource Server, Refresh Rotation, 로그아웃
  • task 페이지로 이동
    • ai-service-team 페이지로 이동
    • nsc-slot 페이지로 이동
    • sb-dev-team 페이지로 이동
    • the-future-company 페이지로 이동
  • testing 페이지로 이동
    • [초안] 시니어 Java 백엔드를 위한 테스트 전략 완전 정리 — 피라미드부터 TestContainers, 마이크로벤치, Contract까지
  • travel 페이지로 이동
    • 오사카 3박 4일 일정표: 우메다 쇼핑, USJ, 난바·도톤보리, 오사카성
  • web 페이지로 이동
    • [초안] HTTP / Cookie / Session / Token 인증 기본기 — 레거시 JSP와 모바일 API가 공존하는 백엔드 관점
FOS-BLOG · FOOTERall systems normal·v0.1 · 2026.04.27·seoul, kr
Ffos-blog/study

개발 학습 기록을 정리하는 블로그입니다. 공부하면서 기록하고, 기록하면서 다시 배웁니다.

visitors
01site
  • Home↗
  • Posts↗
  • Categories↗
  • About↗
02policy
  • 소개/about
  • 개인정보처리방침/privacy
  • 연락처/contact
03categories
  • AI↗
  • Algorithm↗
  • DB↗
  • DevOps↗
  • Java/Spring↗
  • JS/TS↗
  • React↗
  • Next.js↗
  • System↗
04connect
  • GitHub@jon890↗
  • Source repositoryjon890/fos-study↗
  • RSS feed/rss.xml↗
  • Newsletter매주 1 회 · 한 편의 글→
© 2026 FOS Study. All posts MIT-licensed.
built with·Next.js·Tailwind v4·Geist·Pretendard·oklch
fos-blog/task/문서 파싱 서비스 관측성 체계 구축 — 초기…
system

문서 파싱 서비스 관측성 체계 구축 — 초기화 순서 함정과 지표 단일화

진행 기간: 2026.05 2026.07 문서 파싱 서비스(Playground의 OCR 기반 문서→markdown 변환 API)를 운영하면서 관측성(observability) 체계를 처음부터 만들었다. 다음 다섯 가지를 다뤘다. - /metrics 엔드포인트 신규 도입 - 운영 배포 직후 터진 메트릭 누락 사고 대응 - 무중단 컨테이너 교체를 위한 drai...

2026.07.13·7 min read·0 views·SERIES · AI 서비스 실전 구축·운영 · 3/8

진행 기간: 2026.05 ~ 2026.07

문서 파싱 서비스(Playground의 OCR 기반 문서→markdown 변환 API)를 운영하면서 관측성(observability) 체계를 처음부터 만들었다. 다음 다섯 가지를 다뤘다.

  • /metrics 엔드포인트 신규 도입
  • 운영 배포 직후 터진 메트릭 누락 사고 대응
  • 무중단 컨테이너 교체를 위한 drain 모드
  • 대시보드 31패널까지의 점진적 확장
  • 지표·로그·조회 API로 흩어져 있던 관측 경로의 단일화

전체 흐름을 시간순으로 정리한다.

처리량·지연 실시간 관측 체계 구축

운영 중인 서비스의 Throughput(처리량)·Latency(지연)·워커 상태를 볼 수단이 처음엔 아예 없었다. 성능 문제가 생기면 로그를 뒤져 사후에 추정하는 게 전부였다.

그래서 메트릭 노출부터 붙였다. prometheus-fastapi-instrumentator로 HTTP 기본 메트릭을, prometheus_client로 도메인 메트릭(워커 워밍업·OCR 호출·거부 등)을 직접 정의해 같은 registry에 등록했다. 이 서비스는 uvicorn을 다중 워커로 띄우고, 문서 변환 자체도 ProcessPoolExecutor로 별도 OS 프로세스에서 처리한다. 프로세스가 여러 개라 메트릭도 프로세스마다 따로 쌓이는데, PROMETHEUS_MULTIPROC_DIR 환경변수 기반의 MultiProcessCollector가 각 프로세스의 .db 파일을 모아 메인 프로세스의 /metrics 응답 하나로 합쳐준다.

  • Pushgateway 방식(워커가 직접 push)이나 메인 프로세스만 계측하는 방식은 기각했다 — 워밍업 시간·OCR 호출 지연 같은 핵심 신호가 워커 프로세스 안에서만 발생하기 때문이다.
  • 사내 메트릭 수집 시스템과 연동된 Prometheus·Grafana 대시보드를 13패널로 처음 만들었다.
  • scripts/swap-container.sh로 컨테이너를 새 이미지로 교체하는 과정을 스크립트화했다. 기존 컨테이너의 환경변수(OCR 키·워커 설정 등)를 자동 보존하고, 교체 후 /health 200 응답을 최대 5분 폴링해 확인한다.

이렇게 처리량·지연·OCR 호출·워커 라이프사이클을 실시간으로 볼 수 있게 됐고, 이후 이어진 모든 성능·메모리 개선 작업의 효과 측정 기준이 됐다.

운영 배포 직후 메트릭 4종 누락 사고

체계를 배포한 직후 운영에서 핵심 메트릭 4종(parse_requests_total, parse_processing_seconds, worker_restart_total, requests_rejected_total)이 /metrics 응답에서 통째로 빠지는 걸 발견했다. 워커 프로세스가 기록하는 메트릭(worker_alive, OCR 호출 관련)은 정상 노출됐는데, 메인 프로세스가 직접 기록하는 메트릭만 누락됐다.

묻혀버린 실패부터 걷어냈다

원인을 찾으려 해도 단서가 없었다. 메트릭 기록 코드 8곳이 전부 try/except로 감싸져 있었고, 실패해도 logging.debug 또는 except: pass로 조용히 삼켜지고 있었다. 실패 이유를 보려면 먼저 로그부터 드러내야 했다 — debug를 warning + exc_info=True로 바꿔 다음 요청에서 실제 예외 traceback이 로그에 남게 했다.

근본 원인 — multiproc 모드는 import 시점에 딱 한 번 결정된다

로그를 받은 뒤 원인을 확인했다. prometheus_client는 모듈이 처음 import되는 시점에 PROMETHEUS_MULTIPROC_DIR 환경변수 존재 여부를 딱 한 번 검사해서, 이후 모든 메트릭 객체가 단일 프로세스 모드로 갈지 멀티 프로세스 모드로 갈지를 그 자리에서 고정해버린다. 나중에 환경변수를 설정해도 이미 결정된 모드는 바뀌지 않는다.

기존 코드는 FastAPI의 lifespan startup 블록 안에서 PROMETHEUS_MULTIPROC_DIR을 setdefault하고 있었는데, 이 코드가 실행되는 시점은 prometheus_client를 최상단에서 import한 한참 뒤였다. 그래서 메인 프로세스의 Counter·Histogram은 이미 단일 프로세스 모드로 굳어진 채 생성됐고, inc()를 호출해도 메모리에만 반영될 뿐 MultiProcessCollector가 읽는 .db 파일이 생성되지 않았다. 반대로 워커 프로세스는 매번 새 인터프리터로 spawn되면서, 워커 초기화 코드 안의 setdefault 이후에 메트릭 모듈을 처음 import했기 때문에 우연히 멀티 프로세스 모드로 정상 동작했다.

python
# 모듈 최상단 — prometheus_client/instrumentator import 보다 반드시 먼저
os.environ.setdefault("PROMETHEUS_MULTIPROC_DIR", "/tmp/prom_multiproc")
Path(os.environ["PROMETHEUS_MULTIPROC_DIR"]).mkdir(parents=True, exist_ok=True)
 
from prometheus_fastapi_instrumentator import Instrumentator
from prometheus_client import CollectorRegistry, generate_latest, CONTENT_TYPE_LATEST

이 한 줄을 최상단으로 옮기고 나니 두 번째 함정이 나왔다. prometheus-fastapi-instrumentator의 Instrumentator(...)도 모듈 로드 시점에 PROMETHEUS_MULTIPROC_DIR 디렉터리가 실제로 존재하는지 검증한다. setdefault만 하고 디렉터리를 안 만들면 부팅 자체가 ValueError: not a directory로 죽는다. mkdir을 setdefault 바로 옆에 붙여야 했다.

세 번째 함정 — main 프로세스의 multiproc Histogram이 lazy create 안 된다

앞선 두 수정 뒤에도 parse_processing_seconds 하나만 계속 비어 있었다. 운영 8대 인스턴스에서 직접 확인해보니, 같은 프로세스가 만드는 counter_<pid>.db·summary_<pid>.db는 정상 생성되는데 histogram_<pid>.db만 메인 프로세스에서 생성되지 않았다. observe() 자체는 예외 없이 정상 실행되는데도 파일만 안 만들어지는 라이브러리 차원의 동작으로 보였고, 정확한 메커니즘은 더 파고들지 않고 우회로 대응했다.

회피책은 lifespan startup에서 가능한 라벨 조합(endpoint × ja_doc, 4개 조합)을 observe(0)으로 한 번씩 미리 호출해 .db 파일을 강제로 만들어두는 것이었다. 이후 실제 요청의 observe()는 정상 동작했다. 노이즈로 count=1, sum=0이 한 번 더 잡히지만 대시보드에는 영향이 없다.

세 함정을 다 걷어내고 나서야 전 메트릭이 정상 노출되고 대시보드가 복구됐다. 이 사고로 원칙 하나를 얻었다 — multiproc 환경변수·디렉터리 준비는 항상 해당 라이브러리의 최초 import보다 앞서야 하고, lifespan 안에서의 설정은 "이미 늦은" 시점일 수 있다.

drain 모드 도입

컨테이너를 교체하거나 인스턴스 하나를 점검하려면 처리 중인 요청이 끊기거나, 로드밸런서(LB)에서 그 인스턴스를 수동으로 빼야 했다. 서버 프로세스 종료 자체를 다루는 Graceful Shutdown과는 다른 층위다 — drain은 종료 전에 LB 라우팅에서 미리 빠지는 단계이고, graceful shutdown은 종료 신호를 받은 뒤 처리 중인 요청을 마저 끝내는 단계다.

이를 위해 app.state.drain_mode라는 메모리 플래그와 POST /admin/drain / POST /admin/undrain API를 추가했다. 인증은 X-Admin-Key 헤더를 hmac.compare_digest로 비교하는 방식이고, 키 미설정 시엔 503으로 막아 실수로 열리는 걸 방지한다. drain이 켜지면 L4 LB가 헬스체크로 쓰는 GET /health가 503을 반환해 그 인스턴스로 신규 트래픽이 안 들어오게 되고, /health/detailed·/status/*는 200 + drain: true 필드로 상태를 노출한다. /parse/* 같은 실제 처리 엔드포인트는 drain 중에도 정상 동작한다.

파일 마커나 호스트 볼륨 마운트 같은 대안은 원격 토글이 번거롭거나 배포 절차 변경이 필요해 기각했다. 메모리 플래그를 쓴 이유는 컨테이너가 재기동되면 자동으로 drain이 풀리는 것도 의도한 fail-safe이기 때문이다.

결과적으로 처리 중이던 요청은 그대로 마저 처리되면서 LB가 자동으로 신규 트래픽만 차단하는 흐름을 확보했다. 컨테이너 교체·점검을 사람이 LB를 직접 조작하지 않고 처리할 수 있게 됐다.

문서 처리 실패 가시화

이 무렵 대시보드도 함께 다듬었다. 패널 종류가 늘어날수록 heatmap은 한눈에 추세를 보기 어려워져서, 시계열이 늘어난 heatmap 패널 일부를 timeseries로 바꿨다. 처리 시간 히스토그램(parse_processing_seconds)의 bucket 상한도 실제 운영 분포에 맞춰 늘렸다 — 최대 10분(600초)까지만 있던 걸 900·1200초까지 추가했다.

정작 큰 구멍은 실패가 안 보인다는 것이었다. 문서 처리 중 예외가 나도 클라이언트는 HTTP 200과 빈 markdown을 받아서, 정상적인 빈 문서와 처리 실패를 구분할 수 없었다. 실패가 얼마나·어떤 원인으로 일어나는지 볼 운영 지표도 없었다.

처음에는 응답 계약을 건드리지 않는 선에서 시작했다. document_parse_failures_total{format, reason} 카운터와 실패 로그만 추가해 운영 가시성을 먼저 확보하고, 응답 구조 변경은 클라이언트 영향 조사가 끝난 뒤로 미뤘다. reason 라벨에 예외 메시지를 그대로 넣으면 라벨 조합이 무한히 늘어나므로, 예외 타입을 고정된 reason 집합으로 매핑했다. 이후 클라이언트 영향을 확인한 다음 단계에서 DocumentResponse에 reason 필드(status="error" 시)를 추가해 응답에서도 실패 사유를 확인할 수 있게 확장했다.

대시보드에는 처리 에러율 KPI, 실패 사유별 패널을 추가했다. 워커 재시작 패널도 하나로 뭉쳐 보던 걸 "정상 재활용(reason=unknown, max_tasks 도달 등)"과 "강제 종료(reason=timeout_kill, 처리 시간 초과로 인한 CPU 과점유 방어)"로 나눴다. 둘을 섞어 보면 정상적인 워커 순환과 장애성 강제 종료 추세가 서로 가려지기 때문이다.

이제 실패가 지표·로그 양쪽에서 드러나고, 워커 재시작이 "정상"인지 "장애 신호"인지 대시보드에서 바로 구분된다.

관측 경로 단일화

요청 하나가 처리되는 동안 같은 수치가 메트릭·로그·조회 API(/status/requests, /status/gpu) 세 곳에 동시에 기록되고 있었다. 요청마다 로그가 여러 줄 쌓였고, 운영자는 같은 값을 세 창구에서 확인해야 했다. /status/gpu는 메인 프로세스의 GPU 컨텍스트만 측정해 별도 프로세스인 워커의 실제 VRAM 점유를 반영하지도 못했다.

요청 현황의 단일 기준을 Prometheus 메트릭(Grafana)으로 정하고, 중복되던 요청 추적 객체와 /status/requests·/status/gpu 조회 API 2종을 제거했다. 캐시 조합·GPU별 워커 배치처럼 메트릭 라벨로는 표현할 수 없는 디버깅 정보만 /status/converters에 남겼다.

  • 준비 단계(pending, 워커 제출 전) 가시성은 메트릭에 없는 채로 사라졌다 — 짧은 구간이고 구조화 로그로 추적 가능해 수용했다.
  • status 도메인을 통째로 없애는 안은 기각했다. 캐시 조합·GPU 배치는 메트릭에 없는 유일한 디버깅 창구였다.

이렇게 운영 확인 기준이 Grafana 하나로 통일됐다.

metrics·로그 관측성 개선 — 고아 db 스윕과 로그 정리

multiproc Gauge는 livesum 모드로 각 프로세스의 .db 파일 값을 합산한다. 워커가 정상 종료되면 mark_process_dead(pid)가 그 파일을 지워 합산에서 빠지지만, SIGKILL이나 OOM으로 강제 종료되면 이 정리 경로를 안 타서 죽은 워커의 값이 합산에 영구히 남는다. 운영 Grafana에서 worker_alive·glibc 지표가 계속 우상향하는 현상으로 확인했다.

  • 고아 db 스윕: worker_death_monitor 루프가 매 주기 PROMETHEUS_MULTIPROC_DIR 안의 *_<pid>.db 파일에서 PID를 뽑아 psutil.pid_exists(pid)로 생존 여부를 확인하고, 죽은 PID면 mark_process_dead로 정리한다. 종료 경로(정상/SIGKILL/OOM)와 무관하게 청소되는 게 핵심이다. 같은 감시 루프가 시간 초과 워커를 강제 종료하는 역할도 겸한다 — 그 쪽 이야기는 문서 파싱 서비스, 리소스가 새는 자리를 하나씩 틀어막은 기록에서 다룬다.
  • 호스트 RAM 지표 3종 (system_memory_usage_percent/used_bytes/total_bytes) 을 추가했다 — malloc_trim이 OS에 메모리를 실제로 반환하는지 확인할 관측 창구가 없었기 때문이다.
  • 변환 로그를 이모지·영어 위주에서 한국어 자연어 + 파일 정보 중심으로 정리하고, 메트릭과 중복되던 로그(예: malloc_trim 호출당 INFO 로그)를 제거했다. 같은 정보가 glibc Gauge·STW 시간 Histogram으로 이미 노출되고 있어서, 로그는 호출 빈도가 높을수록 운영 로그 노이즈만 키웠다.
  • 대시보드는 31패널 전체에 설명(description)을 보강해 처음 보는 사람도 각 패널이 뭘 보여주는지 알 수 있게 했다.

회고

관측성 체계는 그 자체가 목적이 아니라, 이후 이어진 워커 메모리 누수 대응(Python 서버 RSS malloc_trim 적용기)을 포함한 모든 성능·메모리 개선 작업의 "효과를 측정하는 기준"이 됐다. 개선 전후를 숫자로 비교할 수 없으면 그 개선이 실제로 효과가 있었는지 주장할 근거가 없다.

가장 크게 배운 건 멀티 프로세스 메트릭 통합의 함정이다. PROMETHEUS_MULTIPROC_DIR은 "설정만 해두면 되는" 값이 아니라 "해당 라이브러리를 import하기 전에" 설정돼야 하는 값이었고, lifespan 같은 애플리케이션 생명주기 훅 안의 코드는 생각보다 늦은 시점일 수 있다는 걸 사고를 겪고서야 체감했다.

지표·로그·조회 API로 흩어졌던 관측 경로를 하나로 줄여나가는 과정도 반복된 주제였다. 같은 정보를 여러 곳에 중복해서 남기면 그 정보들이 서로 어긋나기 시작하는 순간 어느 쪽을 믿어야 할지 알 수 없어진다. 메트릭이 답할 수 있는 질문은 메트릭에 맡기고, 로그·조회 API는 메트릭이 답하지 못하는 것만 남기는 원칙으로 정리했다.

on this page
  • 01처리량·지연 실시간 관측 체계 구축
  • 02운영 배포 직후 메트릭 4종 누락 사고
  • 묻혀버린 실패부터 걷어냈다
  • 근본 원인 — multiproc 모드는 import 시점에 딱 한 번 결정된다
  • 세 번째 함정 — main 프로세스의 multiproc Histogram이 lazy create 안 된다
  • 03drain 모드 도입
  • 04문서 처리 실패 가시화
  • 05관측 경로 단일화
  • 06metrics·로그 관측성 개선 — 고아 db 스윕과 로그 정리
  • 07회고
tags
📚 AI 서비스 실전 구축·운영
← PREVIOUSPlayground 문서 파싱 파이프라인 — 기여 개요NEXT →문서 파싱 서비스 성능 최적화 — OCR 병렬화부터 GPU 직렬 추론 실측까지

이런 글도

  • 문서 파싱 서비스 — 코드 구조 정리와 파싱 품질 회귀 검증
    진행 기간: 2026.05 \ 2026.07 모놀리식 파서 서비스 하나를 두 달 동안 도메인별로 쪼개고, 그 과정에서 파싱 결과가 안 깨졌는지 확인할 방법을 처음부터 다시 설계한 기록이다. 문서 파싱 서비스(Playground의 OCR 기반 문서→markdown 변환 API)는 PDF·이미지·오피스 문서를 마크다운으로 변환하는 FastAPI 서비스다. 이...
    📁 system
    system
    2026.07.13
  • 문서 파싱 서비스 성능 최적화 — OCR 병렬화부터 GPU 직렬 추론 실측까지
    진행 기간: 2026.05 2026.07 문서 파싱 서비스(Playground 문서 파싱 파이프라인 — 기여 개요에서 전체 맥락을 다뤘다)의 처리 속도를 여섯 차례에 걸쳐 손봤다. OCR 호출 구조를 병렬로 바꾸고, 안 쓰는 렌더링을 지우고, PPTX 이미지 처리 방식을 통째로 갈아엎었다. 그리고 마지막 최적화에서는 로컬 벤치에서 30% 빨라진 것을 운영...
    📁 system
    system
    2026.07.13
  • 문서 파싱 서비스, 리소스가 새는 자리를 하나씩 틀어막은 기록
    진행 기간: 2026.05 2026.07 > 기여 전체 개요는 Playground 문서 파싱 파이프라인 — 기여 개요 참고. 본 글은 그중 메모리·프로세스·이미지 크기 안정화만 모은 기록이다. 문서 파싱 서비스를 운영하면서 겪은 리소스 문제 다섯 건을 정리한다. 다룬 문제는 다음과 같다. - 워커 강제 종료 - 대용량 엑셀 메모리 - 컨테이너 좀비 프로세스...
    📁 system
    system
    2026.07.13
  • Playground 문서 파싱 파이프라인 — 기여 개요
    진행 기간: 2026.05 (진행 중) AI 서비스 개발팀의 사내 LLM 워크플로 제품 Playground는 다양한 형식의 문서를 입력으로 받는다. 이 입력을 LLM이 다룰 수 있는 markdown으로 정규화하는 문서 파싱 서비스를 맡아 운영·개선했다. OCR 제품을 만드는 게 아니라, OCR을 활용해 문서를 markdown으로 변환하는 서비스다. - 스택...
    📁 system
    system
    2026.06.17

댓글 (0)