|
|
@@ -109,13 +109,13 @@ async def sync_knowledge_base():
|
|
|
logger.info("文章增量: %d 篇 -> %d 块", len(articles), len(article_chunks))
|
|
|
|
|
|
microbiome = await loader.java.get_microbiome_articles()
|
|
|
- _delete_by_prefix(vectorstore, "microbiome_")
|
|
|
+ _delete_by_prefix(vectorstore, "microbiome")
|
|
|
microbiome_chunks = _build_chunks(splitter, microbiome, "microbiome")
|
|
|
stats["microbiome"] = len(microbiome_chunks)
|
|
|
logger.info("菌群知识库: %d 篇 -> %d 块", len(microbiome), len(microbiome_chunks))
|
|
|
|
|
|
dan_kb = await loader.java.get_dan_knowledge_base()
|
|
|
- _delete_by_prefix(vectorstore, "dan_knowledge_")
|
|
|
+ _delete_by_prefix(vectorstore, "dan_knowledge")
|
|
|
dan_chunks = _build_chunks(splitter, dan_kb, "dan_knowledge")
|
|
|
stats["dan_knowledge"] = len(dan_chunks)
|
|
|
logger.info("知识库(dan): %d 篇 -> %d 块", len(dan_kb), len(dan_chunks))
|