org.noear.solon.ai.rag.repository

类 WeaviateRepository

java.lang.Object

org.noear.solon.ai.rag.repository.WeaviateRepository

所有已实现的接口:

Repository, RepositoryLifecycle, RepositoryStorable

@Preview(value="3.1")
public class WeaviateRepository
extends java.lang.Object
implements RepositoryStorable, RepositoryLifecycle

Weaviate 矢量存储知识库 基于 Weaviate REST / GraphQL 接口 说明： 1. 使用外部 EmbeddingModel 生成向量，通过 nearVector GraphQL 查询实现向量搜索； 2. 文档内容、元数据以属性形式写入 Weaviate，对应属性名为： - content: 文本内容 - url: 文档原始地址（如果有） - 其他 metadata: 直接展开为属性； 3. Document.id 对应 Weaviate 对象的 uuid（使用我们生成的 uuid，传给 Weaviate）。

从以下版本开始:

3.1

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	WeaviateRepository.Builder

方法概要

限定符和类型	方法和说明
static WeaviateRepository.Builder	builder(EmbeddingModel embeddingModel, java.lang.String baseUrl) 创建 Builder
static WeaviateRepository.Builder	builder(EmbeddingModel embeddingModel, java.lang.String baseUrl, java.lang.String token)
static WeaviateRepository.Builder	builder(EmbeddingModel embeddingModel, java.lang.String baseUrl, java.lang.String username, java.lang.String password)
static WeaviateRepository.Builder	builder(EmbeddingModel embeddingModel, WeaviateClient client)
void	deleteById(java.lang.String... ids) 按 Weaviate 对象 uuid 删除
void	dropRepository() 删除整个集合（删除 class）
boolean	existsById(java.lang.String id) 检查对象是否存在（按 uuid）
void	initRepository() 初始化仓库：创建 collection（class）Schema（如果不存在）
void	save(java.util.List<Document> documents) 批量保存文档（无进度回调）
void	save(java.util.List<Document> documents, java.util.function.BiConsumer<java.lang.Integer,java.lang.Integer> progressCallback) 批量保存文档（支持进度回调）
java.util.List<Document>	search(QueryCondition condition) 向量搜索（使用 GraphQL nearVector）

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.noear.solon.ai.rag.RepositoryStorable

asyncInsert, asyncSave, delete, exists, insert, insert, insert, save

从接口继承的方法 org.noear.solon.ai.rag.Repository

search

方法详细资料

initRepository

public void initRepository()
                    throws java.lang.Exception

初始化仓库：创建 collection（class）Schema（如果不存在）

指定者:

initRepository 在接口中 RepositoryLifecycle

抛出:

java.lang.Exception

dropRepository

public void dropRepository()
                    throws java.lang.Exception

删除整个集合（删除 class）

指定者:

dropRepository 在接口中 RepositoryLifecycle

抛出:

java.lang.Exception

save

public void save(java.util.List<Document> documents)
          throws java.io.IOException

批量保存文档（无进度回调）

指定者:

save 在接口中 RepositoryStorable

参数:

documents - 文档集

抛出:

java.io.IOException

save

public void save(java.util.List<Document> documents,
                 java.util.function.BiConsumer<java.lang.Integer,java.lang.Integer> progressCallback)
          throws java.io.IOException

批量保存文档（支持进度回调）

指定者:

save 在接口中 RepositoryStorable

参数:

documents - 文档集

progressCallback - 进度回调

抛出:

java.io.IOException

deleteById

public void deleteById(java.lang.String... ids)
                throws java.io.IOException

按 Weaviate 对象 uuid 删除

指定者:

deleteById 在接口中 RepositoryStorable

参数:

ids - 文档IDs

抛出:

java.io.IOException

existsById

public boolean existsById(java.lang.String id)
                   throws java.io.IOException

检查对象是否存在（按 uuid）

指定者:

existsById 在接口中 RepositoryStorable

参数:

id - 文档ID

抛出:

java.io.IOException

search

public java.util.List<Document> search(QueryCondition condition)
                                throws java.io.IOException

向量搜索（使用 GraphQL nearVector）

指定者:

search 在接口中 Repository

参数:

condition - 查询条件

抛出:

java.io.IOException

builder

public static WeaviateRepository.Builder builder(EmbeddingModel embeddingModel,
                                                 java.lang.String baseUrl)

创建 Builder

builder

public static WeaviateRepository.Builder builder(EmbeddingModel embeddingModel,
                                                 java.lang.String baseUrl,
                                                 java.lang.String token)

builder

public static WeaviateRepository.Builder builder(EmbeddingModel embeddingModel,
                                                 java.lang.String baseUrl,
                                                 java.lang.String username,
                                                 java.lang.String password)

builder

public static WeaviateRepository.Builder builder(EmbeddingModel embeddingModel,
                                                 WeaviateClient client)