|
| 1 | +"""KnowledgeDB 경험 자산 조회 — 모듈 레벨 함수. |
| 2 | +
|
| 3 | +dartlab.pastInsight(stockCode) / dartlab.sectorInsights(sector) 로 노출. |
| 4 | +AI tool 자동 등록 경로 (`_autoDiscover`) 가 dartlab.__all__ 순회 시 자동 포함. |
| 5 | +
|
| 6 | +사상 (ops/ai.md §7 경험 자산화 순환): |
| 7 | +- 사람 (블로그) + AI (응답) 가 쌓은 서사·bullet 이 KnowledgeDB 에 보존 |
| 8 | +- 떠먹이기 아님 — AI 가 자율 판단 ("이 회사 전에 본 적 있나?") 으로 호출 |
| 9 | +- 블로그 (검증 프리미엄) 우선, 없으면 AI 축적 fallback |
| 10 | +""" |
| 11 | + |
| 12 | +from __future__ import annotations |
| 13 | + |
| 14 | +from typing import Any |
| 15 | + |
| 16 | + |
| 17 | +def _recordToDict(rec: Any) -> dict[str, Any] | None: |
| 18 | + """InsightRecord → dict 변환. dataclass 또는 namedtuple 모두 지원.""" |
| 19 | + if rec is None: |
| 20 | + return None |
| 21 | + if hasattr(rec, "_asdict"): |
| 22 | + return rec._asdict() |
| 23 | + if hasattr(rec, "__dict__"): |
| 24 | + return {k: v for k, v in rec.__dict__.items() if not k.startswith("_")} |
| 25 | + if isinstance(rec, dict): |
| 26 | + return rec |
| 27 | + return {"value": str(rec)} |
| 28 | + |
| 29 | + |
| 30 | +def pastInsight(stockCode: str) -> dict[str, Any] | None: |
| 31 | + """특정 회사의 과거 분석 서사 조회. |
| 32 | +
|
| 33 | + 우선순위: 블로그 (사람 검증 프리미엄) → AI 축적. |
| 34 | + AI 가 분석 전 "이 회사 전에 본 적 있나?" 자율 판단 후 호출. |
| 35 | +
|
| 36 | + Args: |
| 37 | + stockCode: 종목코드 (예: '005930', 'AAPL') |
| 38 | +
|
| 39 | + Returns: |
| 40 | + dict — narrative / strengths / weaknesses / keyMetrics / dataAsOf / source. |
| 41 | + None — 과거 분석 없음. |
| 42 | + """ |
| 43 | + try: |
| 44 | + from dartlab.ai.persistence import KnowledgeDB |
| 45 | + except ImportError: |
| 46 | + return None |
| 47 | + |
| 48 | + try: |
| 49 | + db = KnowledgeDB.get() |
| 50 | + except (OSError, RuntimeError): |
| 51 | + return None |
| 52 | + |
| 53 | + rec = db.get_insight(stockCode, source="blog") |
| 54 | + if rec is None: |
| 55 | + rec = db.get_insight(stockCode) |
| 56 | + return _recordToDict(rec) |
| 57 | + |
| 58 | + |
| 59 | +def sectorInsights(sector: str, limit: int = 3) -> list[dict[str, Any]]: |
| 60 | + """동종 업계 과거 분석 서사 목록 (교차 학습). |
| 61 | +
|
| 62 | + AI 가 "이 업종에서 전에 어떤 패턴 발견했나?" 자율 판단 후 호출. |
| 63 | + 매크로/섹터 질문에 특히 유용. |
| 64 | +
|
| 65 | + Args: |
| 66 | + sector: 업종명 (예: '반도체', '식품') |
| 67 | + limit: 상위 N개 (기본 3) |
| 68 | +
|
| 69 | + Returns: |
| 70 | + list — 각 항목: narrative / strengths / weaknesses / keyMetrics / stockCode / corpName. |
| 71 | + """ |
| 72 | + try: |
| 73 | + from dartlab.ai.persistence import KnowledgeDB |
| 74 | + except ImportError: |
| 75 | + return [] |
| 76 | + |
| 77 | + try: |
| 78 | + db = KnowledgeDB.get() |
| 79 | + except (OSError, RuntimeError): |
| 80 | + return [] |
| 81 | + |
| 82 | + records = db.get_sector_insights(sector, limit=limit) |
| 83 | + return [d for d in (_recordToDict(r) for r in records) if d is not None] |
0 commit comments