程序包 com.sh.ai.impl.ragflow

类 RagFlowService

java.lang.Object

com.sh.ai.AIServiceBase

com.sh.ai.impl.ragflow.RagFlowService

所有已实现的接口:

AIService, RagAIService<RagFlowConfig,RagFlowQueryParam>

public class RagFlowService
extends AIServiceBase
implements RagAIService<RagFlowConfig,RagFlowQueryParam>

RagFlow服务逻辑

字段概要

字段

修饰符和类型	字段	说明
protected static org.apache.logging.log4j.Logger	log4j

构造器概要

构造器

构造器	说明
RagFlowService()

方法概要

修饰符和类型	方法	说明
AIResponse	addChunk(RagFlowConfig config, String datasetId, String documentId, String content)	Adds a chunk to a specified document in a specified dataset
AIResponse	addChunk(RagFlowConfig config, String datasetId, String documentId, String content, List<String> keywords)
AIResponse	chat(RagFlowConfig config, Consumer<AICallbackMessage> callback)	执行
AIResponse	chat(RagFlowConfig config, Consumer<AICallbackMessage> callback, int level)
AIResponse	createChatAssistant(RagFlowConfig config, String chatName, List<String> datasetIds)	创建聊天助手
AIResponse	createChatSession(RagFlowConfig config)	创建会话 https://ragflow.io/docs/dev/http_api_reference#create-session-with-chat-assistant
AIResponse	deleteChatAssistant(RagFlowConfig config, List<String> ids)	删除会话助手
AIResponse	deleteChatSession(RagFlowConfig config, String... ids)	删除会话
AIResponse	deleteChunk(RagFlowConfig config, String datasetId, String documentId, String... ids)	删除chunk
AIResponse	deleteDocument(RagFlowConfig config, String datasetId, String... ids)	删除文件
AIResponse	parseDocument(RagFlowConfig config, String datasetId, String... ids)	解析文件
AIResponse	process(String type, RagFlowConfig config, Consumer<AICallbackMessage> callback)
AIResponse	queryChatHistory(RagFlowConfig config, RagFlowQueryParam param)	查询历史会话信息
AIResponse	queryChunk(RagFlowConfig config, String datasetId, String documentId, RagFlowQueryParam queryParam)	查询
AIResponse	queryDocument(RagFlowConfig config, String datasetId, RagFlowQueryParam queryParam)	查询文档
AIResponse	retrieveChunk(RagFlowConfig config, String datasetId, String documentId, RagFlowQueryParam param)	检索数据块
AIResponse	updateChatAssistant(RagFlowConfig config, String chatName, List<String> datasetIds)	更新会话助手
AIResponse	updateChunk(RagFlowConfig config, String datasetId, String documentId, String chunkId, String content, List<String> keywords, boolean available)	更新chunk
AIResponse	uploadDocument(RagFlowConfig config, String datasetId, File... files)	上传文件
AIResponse	uploadDocumentAndParse(RagFlowConfig config, String datasetId, File... files)	上传文件并解析

从类继承的方法 com.sh.ai.AIServiceBase

addEventCallback, notifyEvent

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

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

字段详细资料

log4j

protected static org.apache.logging.log4j.Logger log4j

构造器详细资料

RagFlowService

public RagFlowService()

方法详细资料

process

public AIResponse process(String type,
 RagFlowConfig config,
 Consumer<AICallbackMessage> callback)

指定者:

process 在接口中 RagAIService<RagFlowConfig,RagFlowQueryParam>

chat

public AIResponse chat(RagFlowConfig config,
 Consumer<AICallbackMessage> callback)

执行

参数:

config -

callback -

chat

public AIResponse chat(RagFlowConfig config,
 Consumer<AICallbackMessage> callback,
 int level)

createChatAssistant

public AIResponse createChatAssistant(RagFlowConfig config,
 String chatName,
 List<String> datasetIds)

创建聊天助手

参数:

config -

返回:

AIResponse

updateChatAssistant

public AIResponse updateChatAssistant(RagFlowConfig config,
 String chatName,
 List<String> datasetIds)

更新会话助手

参数:

config -

chatName -

datasetIds -

返回:

deleteChatAssistant

public AIResponse deleteChatAssistant(RagFlowConfig config,
 List<String> ids)

删除会话助手

参数:

config -

ids -

返回:

AIResponse

createChatSession

public AIResponse createChatSession(RagFlowConfig config)

创建会话 https://ragflow.io/docs/dev/http_api_reference#create-session-with-chat-assistant

参数:

config -

返回:

AIResponse

deleteChatSession

public AIResponse deleteChatSession(RagFlowConfig config,
 String... ids)

删除会话

参数:

config -

ids - 会话编号

返回:

AIResponse

queryDocument

public AIResponse queryDocument(RagFlowConfig config,
 String datasetId,
 RagFlowQueryParam queryParam)

查询文档

参数:

config -

datasetId -

queryParam -

返回:

AIResponse

uploadDocument

public AIResponse uploadDocument(RagFlowConfig config,
 String datasetId,
 File... files)

上传文件

参数:

config -

datasetId -

files -

返回:

AIResponse

uploadDocumentAndParse

public AIResponse uploadDocumentAndParse(RagFlowConfig config,
 String datasetId,
 File... files)

上传文件并解析

参数:

config -

datasetId -

files -

返回:

AIResponse

parseDocument

public AIResponse parseDocument(RagFlowConfig config,
 String datasetId,
 String... ids)

解析文件

参数:

config -

datasetId -

ids -

返回:

AIResponse

deleteDocument

public AIResponse deleteDocument(RagFlowConfig config,
 String datasetId,
 String... ids)

删除文件

参数:

config -

datasetId -

ids -

返回:

AIResponse

addChunk

public AIResponse addChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 String content)

Adds a chunk to a specified document in a specified dataset

参数:

config -

返回:

AIResponse

addChunk

public AIResponse addChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 String content,
 List<String> keywords)

deleteChunk

public AIResponse deleteChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 String... ids)

删除chunk

参数:

config -

ids -

返回:

AIResponse

updateChunk

public AIResponse updateChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 String chunkId,
 String content,
 List<String> keywords,
 boolean available)

更新chunk

参数:

config -

datasetId -

documentId -

chunkId -

content -

keywords -

available -

返回:

AIResponse

queryChunk

public AIResponse queryChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 RagFlowQueryParam queryParam)

查询

参数:

config -

datasetId -

documentId -

queryParam -

返回:

AIResponse

retrieveChunk

public AIResponse retrieveChunk(RagFlowConfig config,
 String datasetId,
 String documentId,
 RagFlowQueryParam param)

检索数据块

参数:

config -

datasetId -

documentId -

返回:

AIResponse

queryChatHistory

public AIResponse queryChatHistory(RagFlowConfig config,
 RagFlowQueryParam param)

查询历史会话信息

指定者:

queryChatHistory 在接口中 RagAIService<RagFlowConfig,RagFlowQueryParam>

参数:

config -

param -

返回:

AIResponse