service_chat 支持基于一个已创建的知识服务进行检索/问答。
| 参数 | 类型 | 是否必选 | 默认值 | 参数说明 |
|---|---|---|---|---|
serviceResourceId | String | 是 | -- | 知识服务唯一 ID |
messages | List | 是 | -- | 检索/问答多轮对话消息
图文对话:
|
queryParam | Map<String, Object> | 否 | null | 检索过滤条件
多层 filter:
|
stream | Boolean | 否 | true | 是否采用流式返回
|
目前知识服务主要分为两类,检索类型和问答类型。针对不同类型的知识服务,返回的消息格式也有所不同
检索/问答/流式的差异体现在 Data 内字段是否出现及返回时机:
Count、RewriteQuery、ResultList 通常在首流返回;TokenUsage 通常在尾流返回;GeneratedAnswer、ReasoningContent 在中间流分段返回(SSE)。
| 字段 | 类型 | 参数说明 |
|---|---|---|
| code | Integer | 状态码 |
| message | String | 返回信息 |
| requestId | String | 标识每个请求的唯一标识符 |
| data | ServiceChatData | ServiceChatData |
| 字段 | 类型 | 参数说明 |
|---|---|---|
| count | Integer | 检索结果返回的条数 |
| rewriteQuery | String | query 改写的结果 |
| tokenUsage | Object | Token 使用信息 |
| resultList | List | 检索返回的信息 |
| generatedAnswer | String | LLM 模型生成的回答 |
| reasoningContent | String | 推理模型生成的内容 |
| prompt | String | prompt 内容 |
| end | Boolean | 是否结束(流式场景用于标识最后一段) |
| 字段 | 类型 | 参数说明 |
|---|---|---|
| id | String | 索引的主键 |
content | String | 切片内容 |
| mdContent | String | markdown 格式的解析结果(表格切片可通过 ChunkType == table 判断) |
| score | Double | 向量化语义检索得分 |
| pointId | String | 切片 id |
| originText | String | 原始文本 |
| originalQuestion | String | faq 数据检索召回的答案对应的原始问题 |
| chunkTitle | String | 切片标题 |
| chunkId | Long | 切片位次 id(代表在原始文档中的位次顺序) |
| processTime | Long | 检索耗时(秒) |
| rerankScore | Double | 重排得分 |
| docInfo | ServiceChatRetrieveItemDocInfo | ServiceChatRetrieveItemDocInfo |
| recallPosition | Integer | 向量化语义检索召回位次 |
| rerankPosition | Integer | 重排位次 |
| chunkType | String | 切片所属类型(如 doc-image、image、video、table、mixed-table、text、structured、faq 等) |
| chunkSource | String | 切片来源 |
| updateTime | Long | 更新时间 |
| chunkAttachment | List | 检索召回附件的临时下载链接,有效期 10 分钟 |
| tableChunkFields | List | 结构化数据检索返回单行全量数据 |
| originalCoordinate | Map<String, Object> | 切片在所属文档的原始位置坐标 |
| 字段 | 类型 | 参数说明 |
|---|---|---|
| docId | String | 文档 id |
| docName | String | 文档名字 |
| createTime | Long | 文档的创建时间 |
| docType | String | 知识所属原始文档的类型 |
| docMeta | String | 文档相关元信息 |
| source | String | 知识来源类型 |
| title | String | 知识所属文档的标题 |
| 字段 | 类型 | 参数说明 |
|---|---|---|
| uuid | String | 附件的唯一标识 |
| caption | String | 图片所属标题,若未识别到标题则值为 "\n" |
| type | String | image 等 |
| link | String | 临时下载链接,有效期 10 分钟 |
| infoLink | String | 附件 info_link |
| columnName | String | 附件列名 |
| 字段 | 类型 | 参数说明 |
|---|---|---|
| fieldName | String | 字段名 |
| fieldValue | Object | 字段值 |
首次使用知识库 SDK,可参考 使用说明
本示例演示了知识库 Java SDK 中 ServiceChat 的基础使用方法,包含普通调用和流式调用两种方式;该功能使用 API Key 鉴权(VIKING_API_KEY),且需配置知识服务 ID。
package com.volcengine.vikingdb.runtime.knowledge.examples.service_chat; import com.fasterxml.jackson.databind.ObjectWriter; import com.volcengine.vikingdb.runtime.core.ApiClient; import com.volcengine.vikingdb.runtime.core.RequestAddition; import com.volcengine.vikingdb.runtime.core.auth.Auth; import com.volcengine.vikingdb.runtime.core.auth.AuthWithApiKey; import com.volcengine.vikingdb.runtime.enums.Scheme; import com.volcengine.vikingdb.runtime.knowledge.model.request.ChatMessage; import com.volcengine.vikingdb.runtime.knowledge.model.request.ServiceChatRequest; import com.volcengine.vikingdb.runtime.knowledge.model.response.ServiceChatResponse; import com.volcengine.vikingdb.runtime.knowledge.service.KnowledgeService; import java.util.Collections; public class Main { private static final ObjectWriter PRETTY_JSON = ApiClient.objectMapper.writerWithDefaultPrettyPrinter(); private static final Scheme SCHEME = Scheme.HTTPS; private static final String HOST = "api-knowledgebase.mlp.cn-beijing.volces.com"; private static final String REGION = "cn-beijing"; private static final String SERVICE_RESOURCE_ID = "<YOUR_SERVICE_RESOURCE_ID>"; public static void main(String[] args) throws Exception { String apiKey = getEnv("VIKING_API_KEY"); if (apiKey.isEmpty()) { System.out.println("missing_auth: set VIKING_API_KEY"); return; } Auth auth = new AuthWithApiKey(apiKey); KnowledgeService service = newKnowledgeService(auth); ServiceChatRequest req = ServiceChatRequest.builder() .serviceResourceId(SERVICE_RESOURCE_ID) .messages(Collections.singletonList(ChatMessage.builder() .role("user") .content("<YOUR_QUERY>") .build())) .stream(false) .build(); ServiceChatResponse resp = service.serviceChat(req, new RequestAddition()); printJson("service_chat", resp); } private static KnowledgeService newKnowledgeService(Auth auth) { return new KnowledgeService(SCHEME, HOST, REGION, auth); } private static String getEnv(String name) { String v = System.getenv(name); if (v == null) { return ""; } v = v.trim(); return v.isEmpty() ? "" : v; } private static void printJson(String name, Object obj) throws Exception { if (obj == null) { System.out.println(name + ": null"); return; } System.out.println(name + ": " + PRETTY_JSON.writeValueAsString(obj)); } }
package com.volcengine.vikingdb.runtime.knowledge.examples.service_chat_stream; import com.volcengine.vikingdb.runtime.core.RequestAddition; import com.volcengine.vikingdb.runtime.core.auth.Auth; import com.volcengine.vikingdb.runtime.core.auth.AuthWithApiKey; import com.volcengine.vikingdb.runtime.enums.Scheme; import com.volcengine.vikingdb.runtime.knowledge.model.request.ChatMessage; import com.volcengine.vikingdb.runtime.knowledge.model.request.ServiceChatRequest; import com.volcengine.vikingdb.runtime.knowledge.model.response.ServiceChatResponse; import com.volcengine.vikingdb.runtime.knowledge.service.KnowledgeService; import com.volcengine.vikingdb.runtime.knowledge.service.KnowledgeStream; import java.util.Collections; public class Main { private static final Scheme SCHEME = Scheme.HTTPS; private static final String HOST = "api-knowledgebase.mlp.cn-beijing.volces.com"; private static final String REGION = "cn-beijing"; private static final String SERVICE_RESOURCE_ID = "<YOUR_SERVICE_RESOURCE_ID>"; public static void main(String[] args) throws Exception { String apiKey = getEnv("VIKING_API_KEY"); if (apiKey.isEmpty()) { System.out.println("missing_auth: set VIKING_API_KEY"); return; } Auth auth = new AuthWithApiKey(apiKey); KnowledgeService service = newKnowledgeService(auth); ServiceChatRequest req = ServiceChatRequest.builder() .serviceResourceId(SERVICE_RESOURCE_ID) .messages(Collections.singletonList(ChatMessage.builder() .role("user") .content("<YOUR_QUERY>") .build())) .stream(true) .build(); try (KnowledgeStream<ServiceChatResponse> stream = service.serviceChatStream(req, new RequestAddition())) { System.out.println("service_chat_stream:"); for (ServiceChatResponse item : stream) { if (item != null && item.getData() != null && item.getData().getGeneratedAnswer() != null) { System.out.print(item.getData().getGeneratedAnswer()); } if (item != null && item.getData() != null && Boolean.TRUE.equals(item.getData().getEnd())) { break; } } System.out.print("\n"); } } private static KnowledgeService newKnowledgeService(Auth auth) { return new KnowledgeService(SCHEME, HOST, REGION, auth); } private static String getEnv(String name) { String v = System.getenv(name); if (v == null) { return ""; } v = v.trim(); return v.isEmpty() ? "" : v; } }