hyungi
daf6a0ade9
plan ds-s1-backend-1 잔여 구현 (A·C-1 은 16b0fe1):
- B 중복검사: services/dedup.py (OFF-list law_monitor 공용) + 업로드 채움(B-1)
+ GET /documents/duplicates(B-2) + post-upload near-dup 비동기(B-3)
+ backfill_dedup.py(B-4) + 야간 dedup_reconcile 잡(03:30 KST 멱등 재계산)
- C MD-first: marker_worker office/hwp 분기 _process_office(C-2) + md_status
상태머신 postcondition success|failed(C-5) + backfill_nonpdf_markdown.py(C-4)
+ requirements markitdown
- D 스토리지: services/storage ABC+Range 계약 / LocalBackend / NasApiBackend 503
(D-1) + /file resolver 경유, 로컬 동작 불변(D-2)
- E 운영: pre-change pg_dump + rollback_287.sql + apply runbook(E-3) + 테스트(E-1)
비파괴 불변식 유지(기존 응답 shape 무변경, md_status success→completed read-time 매핑).
어드버서리얼 리뷰 확정 1건(soft-delete canonical 승격 시 stale duplicate_of) → B-1
승격 정규화 + 야간 재계산으로 정합.
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
40 lines
1.4 KiB
Python
40 lines
1.4 KiB
Python
"""스토리지 계층 추상화 패키지 (plan ds-s1-backend-1 D 그룹, scaffold-first).
|
|
|
|
활성 백엔드 선택 = get_storage_backend():
|
|
- env DS_STORAGE_BACKEND (기본 'local') 로 결정 — config.yaml storage 섹션 편집 없이도
|
|
동작(검색실험 Soft Lock 동안 config 불가침). 실 활성(외부 백엔드)은 D-3.
|
|
- 'local' → LocalBackend(settings.nas_mount_path) : 현행 NAS NFS, /file 동작 불변.
|
|
- 'nas_api'/'nas'→ NasApiBackend(env DS_NAS_API_BASE_URL) : 미프로비전 시 503(silent fallback X).
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import os
|
|
from functools import lru_cache
|
|
|
|
from core.config import settings
|
|
|
|
from .base import StatResult, StorageBackend, StorageNotConfigured
|
|
from .local import LocalBackend
|
|
from .nas_api import NasApiBackend
|
|
|
|
__all__ = [
|
|
"StorageBackend",
|
|
"StorageNotConfigured",
|
|
"StatResult",
|
|
"LocalBackend",
|
|
"NasApiBackend",
|
|
"get_storage_backend",
|
|
]
|
|
|
|
|
|
@lru_cache(maxsize=1)
|
|
def get_storage_backend() -> StorageBackend:
|
|
"""활성 스토리지 백엔드 1개 반환 (프로세스 단위 캐시)."""
|
|
backend = os.getenv("DS_STORAGE_BACKEND", "local").lower()
|
|
if backend == "local":
|
|
return LocalBackend(settings.nas_mount_path)
|
|
if backend in ("nas_api", "nas"):
|
|
return NasApiBackend(os.getenv("DS_NAS_API_BASE_URL"))
|
|
raise StorageNotConfigured(f"unknown DS_STORAGE_BACKEND={backend!r}")
|