2026年医疗AI的可信革命全栈实现（下）

9.3 向量索引构建示例

文档进入向量库前，应先清洗、切分、打标签、嵌入，再写入索引。以下示例展示一种最简流程，真实环境中可替换为Milvus或Qdrant SDK。

代码清单 9-2 文档切分与索引写入

from dataclasses import dataclass
from typing import Iterable
import hashlib

@dataclass
class Chunk:
    chunk_id: str
    text: str
    metadata: dict

def chunk_document(doc_id: str, title: str, text: str, source_type: str) -> list[Chunk]:
    parts = [p.strip() for p in text.split("\n\n") if p.strip()]
    chunks = []
    for i, part in enumerate(parts):
        cid = hashlib.md5(f"{doc_id}-{i}-{part[:100]}".encode()).hexdigest()
        chunks.append(
            Chunk(
                chunk_id=cid,
                text=f"[{title}]\n{part}",
                metadata={"doc_id": doc_id, "source_type": source_type, "seq": i},
            )
        )
    return chunks

def upsert_vector_store(chunks: Iterable[Chunk], embed_fn, store):
    rows = []
    for c in chunks:
        vec = embed_fn(c.text)
        rows.append({"id": c.chunk_id, "vector": vec, "payload": c.metadata | {"text": c.text}})
    store.upsert(rows)

9.4 检索后的证据过滤

可信系统不能把Top-k检索结果直接交给LLM。至少应做三步过滤：版本过滤、来源过滤和任务过滤。比如分诊任务应优先召回急诊路径与院内制度，而不是科研论文；药物风险任务应优先结构化说明书和高等级指南，而非社区帖子。经过过滤后，再做重排与证据回指，才能进入后续推理层。

9.5 结构化表示的真正价值

很多团队把结构化表示视为“加一道前处理”，但事实上它改变的是系统认知方式。没有它，Agent面对的是一堆文本；有了它，Agent面对的是一个带证据索引的状态空间。前者天然容易走向语言幻觉，后者才有可能接入概率图模型与不确定性度量。

10 核心算法与代码实现（二）：贝叶斯网络、风险阈值与Agent路由

10.1 用贝叶斯网络表示诊断状态

下面给出一个极简的胸痛场景示例。真实医疗系统当然远比这个复杂，但它足以说明“结论不是一句话，而是一组后验概率”。

代码清单 10-1 pgmpy定义诊断网络

from pgmpy.models import BayesianNetwork
from pgmpy.factors.discrete import TabularCPD
from pgmpy.inference import VariableElimination

model = BayesianNetwork([
    ("age_risk", "mi"),
    ("st_elevation", "mi"),
    ("troponin_high", "mi"),
    ("d_dimer_high", "pe"),
    ("tachycardia", "pe"),
    ("mi", "chest_pain"),
    ("pe", "chest_pain"),
])

cpd_age = TabularCPD("age_risk", 2, [[0.6], [0.4]])
cpd_st = TabularCPD("st_elevation", 2, [[0.85], [0.15]])
cpd_trop = TabularCPD("troponin_high", 2, [[0.8], [0.2]])
cpd_dd = TabularCPD("d_dimer_high", 2, [[0.7], [0.3]])
cpd_tachy = TabularCPD("tachycardia", 2, [[0.75], [0.25]])

cpd_mi = TabularCPD(
    "mi", 2,
    values=[
        [0.99, 0.85, 0.80, 0.30, 0.40, 0.10, 0.08, 0.01],
        [0.01, 0.15, 0.20, 0.70, 0.60, 0.90, 0.92, 0.99],
    ],
    evidence=["age_risk", "st_elevation", "troponin_high"],
    evidence_card=[2, 2, 2]
)

cpd_pe = TabularCPD(
    "pe", 2,
    values=[
        [0.97, 0.70, 0.50, 0.10],
        [0.03, 0.30, 0.50, 0.90],<