1class AppBuilderClientAnswer(BaseModel):
2    """执行步骤的具体内容
3        属性:
4            answer(str): query回答内容
5            events( list[Event]): 事件列表
6       """
7    answer: str = ""
8    events: list[Event] = []

1class Event(BaseModel):
2    """执行步骤的具体内容
3        属性:
4            code (int): 响应code码
5            message (str): 错误详情
6            status (str): 状态描述，preparing（准备运行）running（运行中）error（执行错误） done（执行完成）
7            event_type（str）: 事件类型
8            content_type（str）: 内容类型
9            detail(dict): 事件详情
10            usage(Usage): 大模型调用的token用量
11    """
12    code: int = 0
13    message: str = ""
14    status: str = ""
15    event_type: str = ""
16    content_type: str = ""
17    detail: dict = {}
18    usage: Optional[Usage] = None

1import appbuilder
2import os
3
4# 请前往千帆AppBuilder官网创建密钥，流程详见：https://cloud.baidu.com/doc/AppBuilder/s/Olq6grrt6#1%E3%80%81%E5%88%9B%E5%BB%BA%E5%AF%86%E9%92%A5
5# 设置环境变量
6os.environ["APPBUILDER_TOKEN"] = '...'
7app_id = '...'  # 已发布AppBuilder应用ID，可在console端查看
8# 初始化智能体
9builder = appbuilder.AppBuilderClient(app_id)
10# 创建会话
11conversation_id = builder.create_conversation()
12# 运行对话
13out = builder.run(conversation_id, "北京今天天气怎么样")
14# 打印会话结果 
15print(out.content.answer)

1import appbuilder
2from appbuilder.core.console.appbuilder_client import data_class
3import os
4
5# 请前往千帆AppBuilder官网创建密钥，流程详见：https://cloud.baidu.com/doc/AppBuilder/s/Olq6grrt6#1%E3%80%81%E5%88%9B%E5%BB%BA%E5%AF%86%E9%92%A5
6# 设置环境变量
7os.environ["APPBUILDER_TOKEN"] = '...'
8app_id = '...'  # 已发布AppBuilder应用的ID
9# 初始化智能体
10client = appbuilder.AppBuilderClient(app_id)
11# 创建会话
12conversation_id = client.create_conversation()
13
14# 上传一个介绍某汽车产品的说明文档
15file_id = client.upload_local_file(conversation_id, "/path/to/pdf/file")
16# 引用上传的文档，开始对话
17# 注意file_ids不是必填项，如果不需要引用特定文档，file_ids留空即可
18message = client.run(conversation_id, "汽车性能参数怎么样", file_ids=[file_id, ], stream=True)
19
20answer = ""
21
22# 每次迭代返回AppBuilderClientAnswer结构，内可能包括多个事件内容
23for content in message.content:
24    # stream=True时，将answer拼接起来才是完整的的对话结果
25    answer += content.answer
26    for event in content.events:
27        content_type = event.content_type
28        detail = event.detail
29        # 根据content类型对事件详情进行解析
30        if content_type == "code":
31            code_detail = data_class.CodeDetail(**detail)
32            print(code_detail.code)
33        elif content_type == "text":
34            text_detail = data_class.TextDetail(**detail)
35            print(text_detail.text)
36        elif content_type == "image":
37            image_detail = data_class.ImageDetail(**detail)
38            print(image_detail.url)
39        elif content_type == "rag":
40            rag_detail = data_class.RAGDetail(**detail)
41            if len(rag_detail.references) > 0:
42                print(rag_detail.references)
43        elif content_type == "function_call":
44            function_call_detail = data_class.FunctionCallDetail(**detail)
45            print(function_call_detail.video)
46        elif content_type == "audio":
47            audio_detail = data_class.AudioDetail(**detail)
48            print(audio_detail)
49        elif content_type == "video":
50            video_detail = data_class.VideoDetail(**detail)
51            print(video_detail)
52        elif content_type == "status":
53            status_detail = data_class.StatusDetail(**detail)
54            print(status_detail)
55        else:
56            default_detail = data_class.DefaultDetail(**detail)
57            print(default_detail)
58
59# 打印完整的answer结果
60print(answer)

1package org.example;
2
3import java.io.IOException;
4import java.util.*;
5
6import com.google.gson.annotations.SerializedName;
7
8import com.baidubce.appbuilder.base.exception.AppBuilderServerException;
9import com.baidubce.appbuilder.console.appbuilderclient.AppBuilderClient;
10import com.baidubce.appbuilder.model.appbuilderclient.AppBuilderClientIterator;
11import com.baidubce.appbuilder.model.appbuilderclient.AppBuilderClientResult;
12import com.baidubce.appbuilder.model.appbuilderclient.Event;
13import com.baidubce.appbuilder.base.utils.json.JsonUtils;
14
15class AppBuilderClientDemo {
16
17    public static void main(String[] args) throws IOException, AppBuilderServerException {
18        System.setProperty("APPBUILDER_TOKEN", "请设置正确的应用密钥");
19        String appId = "请设置正确的应用ID";
20        AppBuilderClient builder = new AppBuilderClient(appId);
21        String conversationId = builder.createConversation();
22        // 填写上传文件路径
23        String fileId = builder.uploadLocalFile(conversationId, "/Users/zhangxiaoyu15/PycharmProjects/app-builder/test_app_builder_client/test.pdf");
24        // 输入query
25        // 注意file_ids不是必填项，如果不需要引用特定文档，则将new String[]{fileId}更换为new String[]{}即可
26        AppBuilderClientIterator itor = builder.run("中国四大传统节日是哪四个", conversationId, new String[]{fileId}, false);
27        StringBuilder answer = new StringBuilder();
28        // itor.hasNext()返回false时，表示流式调用结束
29        while(itor.hasNext())
30        {
31            AppBuilderClientResult response = itor.next();
32            answer.append(response.getAnswer());
33            for (Event event : response.getEvents()) {
34                switch (event.getContentType()) {
35                    case "rag":
36                        List<Object> references = (List<Object>)event.getDetail().get("references");
37                        for (Object reference : references) {
38                            ReferenceDetail ragDetail = JsonUtils.deserialize(JsonUtils.serialize(reference), ReferenceDetail.class);
39                            System.out.println("-----------------------------------");
40                            System.out.println("参考文献ID:"+ragDetail.getId());
41                            System.out.println("参考文献内容:"+ragDetail.getContent());
42                            System.out.println("来源:"+ragDetail.getFrom());
43                            System.out.println("BaiduSearch链接:"+ragDetail.getUrl());
44                            System.out.println("类型:"+ragDetail.getType());
45                            System.out.println("文档片段ID:"+ragDetail.getSegmentId());
46                            System.out.println("文档ID:"+ragDetail.getDocumentId());
47                            System.out.println("文档名称:"+ragDetail.getDocumentName());
48                            System.out.println("文档所属数据集ID:"+ragDetail.getDatasetId());
49                            System.out.println("-----------------------------------");
50                        }
51                        break;
52                    default:
53                        // System.out.println(event);
54                }
55            }
56        }
57        System.out.print("输出：");
58        System.out.println(answer);
59    }
60}
61
62class ReferenceDetail {
63    private int id;
64    private String content;
65    private String from;
66    private String url;
67    private String type;
68    @SerializedName("segment_id")
69    private String segmentId;
70    @SerializedName("document_id")
71    private String documentId;
72    @SerializedName("document_name")
73    private String documentName;
74    @SerializedName("dataset_id")
75    private String datasetId;
76
77    public int getId() {
78        return id;
79    }
80
81    public void setId(int id) {
82        this.id = id;
83    }
84
85    public String getContent() {
86        return content;
87    }
88
89    public void setContent(String content) {
90        this.content = content;
91    }
92
93    public String getFrom() {
94        return from;
95    }
96
97    public void setFrom(String from) {
98        this.from = from;
99    }
100
101    public String getUrl() {
102        return url;
103    }
104
105    public void setUrl(String url) {
106        this.url = url;
107    }
108
109    public String getType() {
110        return type;
111    }
112
113    public void setType(String type) {
114        this.type = type;
115    }
116
117    public String getSegmentId() {
118        return segmentId;
119    }
120
121    public void setSegmentId(String segmentId) {
122        this.segmentId = segmentId;
123    }
124
125    public String getDocumentId() {
126        return documentId;
127    }
128
129    public void setDocumentId(String documentId) {
130        this.documentId = documentId;
131    }
132
133    public String getDocumentName() {
134        return documentName;
135    }
136
137    public void setDocumentName(String documentName) {
138        this.documentName = documentName;
139    }
140
141    public String getDatasetId() {
142        return datasetId;
143    }
144
145    public void setDatasetId(String datasetId) {
146        this.datasetId = datasetId;
147    }
148
149    @Override
150    public String toString() {
151        return "RAGReference{" +
152                "id=" + id +
153                ", content='" + content + '\'' +
154                ", from='" + from + '\'' +
155                ", url='" + url + '\'' +
156                ", type='" + type + '\'' +
157                ", segmentId='" + segmentId + '\'' +
158                ", documentId='" + documentId + '\'' +
159                ", documentName='" + documentName + '\'' +
160                ", datasetId='" + datasetId + '\'' +
161                '}';
162    }
163}

1java
2package org.example;
3
4import java.io.IOException;
5import java.util.*;
6
7import com.google.gson.annotations.SerializedName;
8
9import com.baidubce.appbuilder.base.exception.AppBuilderServerException;
10import com.baidubce.appbuilder.console.appbuilderclient.AppBuilderClient;
11import com.baidubce.appbuilder.model.appbuilderclient.AppBuilderClientIterator;
12import com.baidubce.appbuilder.model.appbuilderclient.AppBuilderClientResult;
13import com.baidubce.appbuilder.model.appbuilderclient.Event;
14import com.baidubce.appbuilder.base.utils.json.JsonUtils;
15
16class AppBuilderClientDemo {
17
18    public static void main(String[] args) throws IOException, AppBuilderServerException {
19        System.setProperty("APPBUILDER_TOKEN", "请设置正确的应用密钥");
20        String appId = "请设置正确的应用ID";
21        AppBuilderClient builder = new AppBuilderClient(appId);
22        String conversationId = builder.createConversation();
23       
24       	AppBuilderClientRunRequest request = new AppBuilderClientRunRequest();
25        request.setAppId(appId);
26        request.setConversationID(conversationId);
27        request.setQuery("今天北京的天气怎么样?");
28        request.setStream(false);
29
30        String name = "get_cur_whether";
31        String desc = "这是一个获得指定地点天气的工具";
32        Map<String, Object> parameters = new HashMap<>();
33
34        Map<String, Object> location = new HashMap<>();
35        location.put("type", "string");
36        location.put("description", "省，市名，例如：河北省");
37
38        Map<String, Object> unit = new HashMap<>();
39        unit.put("type", "string");
40        List<String> enumValues = new ArrayList<>();
41        enumValues.add("摄氏度");
42        enumValues.add("华氏度");
43        unit.put("enum", enumValues);
44
45        Map<String, Object> properties = new HashMap<>();
46        properties.put("location", location);
47        properties.put("unit", unit);
48
49        parameters.put("type", "object");
50        parameters.put("properties", properties);
51        List<String> required = new ArrayList<>();
52        required.add("location");
53        parameters.put("required", required);
54
55        AppBuilderClientRunRequest.Tool.Function func =
56                new AppBuilderClientRunRequest.Tool.Function(name, desc, parameters);
57        AppBuilderClientRunRequest.Tool tool =
58                new AppBuilderClientRunRequest.Tool("function", func);
59        request.setTools(new AppBuilderClientRunRequest.Tool[] {tool});
60
61        AppBuilderClientIterator itor = builder.run(request);
62        assertTrue(itor.hasNext());
63        String ToolCallID = "";
64        while (itor.hasNext()) {
65            AppBuilderClientResult result = itor.next();
66            ToolCallID = result.getEvents()[0].getToolCalls()[0].getId();
67            System.out.println(result);
68        }
69
70        AppBuilderClientRunRequest request2 = new AppBuilderClientRunRequest();
71        request2.setAppId(appId);
72        request2.setConversationID(conversationId);
73
74        AppBuilderClientRunRequest.ToolOutput output =
75                new AppBuilderClientRunRequest.ToolOutput(ToolCallID, "北京今天35度");
76        request2.setToolOutputs(new AppBuilderClientRunRequest.ToolOutput[] {output});
77        AppBuilderClientIterator itor2 = builder.run(request2);
78        assertTrue(itor2.hasNext());
79        while (itor2.hasNext()) {
80            AppBuilderClientResult result = itor2.next();
81            System.out.println(result);
82        }
83    }
84}

1Go
2package main
3
4import (
5	"errors"
6	"fmt"
7	"io"
8	"os"
9
10	"github.com/baidubce/app-builder/go/appbuilder"
11)
12
13func main() {
14	// 设置APPBUILDER_TOKEN、GATEWAY_URL_V2环境变量
15	os.Setenv("APPBUILDER_TOKEN", "请设置正确的应用密钥")
16	// 默认可不填，默认值是 https://qianfan.baidubce.com
17	os.Setenv("GATEWAY_URL_V2", "")
18	config, err := appbuilder.NewSDKConfig("", "")
19	if err != nil {
20		fmt.Println("new config failed: ", err)
21		return
22	}
23	// 初始化实例
24	appID := "请填写正确的应用ID"
25	builder, err := appbuilder.NewAppBuilderClient(appID, config)
26	if err != nil {
27		fmt.Println("new agent builder failed: ", err)
28		return
29	}
30	// 创建对话ID
31	conversationID, err := builder.CreateConversation()
32	if err != nil {
33		fmt.Println("create conversation failed: ", err)
34		return
35	}
36	// 与创建应用时绑定的知识库不同之处在于，
37	// 所上传文件仅在本次会话ID下发生作用，如果创建新的会话ID，上传的文件自动失效
38	// 而知识库在不同的会话ID下均有效
39	fileID, err := builder.UploadLocalFile(conversationID, "/path/to/cv.pdf")
40	if err != nil {
41		fmt.Println("upload local file failed:", err)
42		return
43	}
44	// 执行流式对话
45    // 注意file_ids不是必填项，如果不需要引用特定的文档，则将[]string{fileID}更换为nil即可
46    // 同时还需要将上文的fileID, err := builder.UploadLocalFile(conversationID,  "/path/to/cv.pdf")代码
47    // 更换为 _, err = client.UploadLocalFile(conversationID,  "/path/to/cv.pdf"),否则会报错
48	i, err := builder.Run(conversationID, "描述简历中的候选人情况", []string{fileID}, true)
49	if err != nil {
50		fmt.Println("run failed: ", err)
51		return
52	}
53
54	completedAnswer := ""
55	var answer *appbuilder.AppBuilderClientAnswer
56	for answer, err = i.Next(); err == nil; answer, err = i.Next() {
57		completedAnswer = completedAnswer + answer.Answer
58		for _, ev := range answer.Events {
59			evJSON, _ := json.Marshal(ev)
60			fmt.Println(string(evJSON))
61		}
62	}
63	// 迭代正常结束err应为io.EOF
64	if errors.Is(err, io.EOF) {
65		fmt.Println("run success")
66		fmt.Println("智能体回答内容： ", completedAnswer)
67	} else {
68		fmt.Println("run failed:", err)
69	}
70}

1type Tool struct {
2	Type     string   `json:"type"`
3	Function Function `json:"function"`
4}
5
6type Function struct {
7	Name        string                 `json:"name"`
8	Description string                 `json:"description"`
9	Parameters  map[string]interface{} `json:"parameters"`
10}
11
12type ToolOutput struct {
13	ToolCallID string `json:"tool_call_id" description:"工具调用ID"`
14	Output     string `json:"output" description:"工具输出"`
15}

1package main
2
3import (
4	"errors"
5	"fmt"
6	"io"
7	"os"
8
9	"github.com/baidubce/app-builder/go/appbuilder"
10)
11
12func main() {
13	// 设置APPBUILDER_TOKEN、GATEWAY_URL_V2环境变量
14	os.Setenv("APPBUILDER_TOKEN", "请设置正确的应用密钥")
15	// 默认可不填，默认值是 https://qianfan.baidubce.com
16	os.Setenv("GATEWAY_URL_V2", "")
17	config, err := appbuilder.NewSDKConfig("", "")
18	if err != nil {
19		fmt.Println("new config failed: ", err)
20		return
21	}
22	// 初始化实例
23	appID := "请填写正确的应用ID"
24	builder, err := appbuilder.NewAppBuilderClient(appID, config)
25	if err != nil {
26		fmt.Println("new agent builder failed: ", err)
27		return
28	}
29	// 创建对话ID
30	conversationID, err := builder.CreateConversation()
31	if err != nil {
32		fmt.Println("create conversation failed: ", err)
33		return
34	}
35
36	parameters := make(map[string]interface{})
37
38	location := make(map[string]interface{})
39	location["type"] = "string"
40	location["description"] = "省，市名，例如：河北省"
41
42	unit := make(map[string]interface{})
43	unit["type"] = "string"
44	unit["enum"] = []string{"摄氏度", "华氏度"}
45
46	properties := make(map[string]interface{})
47	properties["location"] = location
48	properties["unit"] = unit
49
50	parameters["type"] = "object"
51	parameters["properties"] = properties
52	parameters["required"] = []string{"location"}
53
54	i, err := client.RunWithFunctionCall(appbuilder.AppBuilderClientRunRequest{
55		AppID:          appID,
56		Query:          "今天北京的天气怎么样?",
57		ConversationID: conversationID,
58		Stream:         true,
59		Tools: []appbuilder.Tool{
60			{
61				Type: "function",
62				Function: appbuilder.Function{
63					Name:        "get_cur_whether",
64					Description: "这是一个获得指定地点天气的工具",
65					Parameters:  parameters,
66				},
67			},
68		},
69	})
70	if err != nil {
71		fmt.Println("run failed:", err)
72	}
73	totalAnswer := ""
74	toolCallID := ""
75	for answer, err := i.Next(); err == nil; answer, err = i.Next() {
76		totalAnswer = totalAnswer + answer.Answer
77		for _, ev := range answer.Events {
78			toolCallID = ev.ToolCalls[0].ID
79			evJSON, _ := json.Marshal(ev)
80			fmt.Println(string(evJSON))
81		}
82	}
83
84	i2, err := client.RunWithFunctionCall(appbuilder.AppBuilderClientRunRequest{
85		ConversationID: conversationID,
86		AppID:          appID,
87		ToolOutputs: []appbuilder.ToolOutput{
88			{
89				ToolCallID: toolCallID,
90				Output:     "北京今天35度",
91			},
92		},
93		Stream: true,
94	})
95
96	if err != nil {
97		fmt.Println("run failed: ", err)
98	}
99
100	for answer, err := i2.Next(); err == nil; answer, err = i2.Next() {
101		totalAnswer = totalAnswer + answer.Answer
102		for _, ev := range answer.Events {
103			evJSON, _ := json.Marshal(ev)
104			fmt.Println(string(evJSON))
105		}
106	}
107
108	fmt.Println("----------------answer-------------------")
109	fmt.Println(totalAnswer)
110}