替换流程(伪代码)
替换流程(伪代码)
def reindex(doc):
new_chunks = build_chunks(doc.text, meta={"doc_id": doc.id,
"doc_version": doc.version})
store.delete(filter={"doc_id": doc.id}) # 删旧
store.upsert(new_chunks, embed_batch(new_chunks)) # 写新
report(doc.id, old=old_count, new=len(new_chunks))重建要可回滚:写入新集合或新分区,验证通过再切流量,出问题切回旧索引。