import os
import appbuilder


# 请前往千帆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
# 设置环境变量
os.environ["APPBUILDER_TOKEN"] = (
    "..."
)

# 组件ID，可在个人空间-组件下查看
component_id = "..."
client = appbuilder.ComponentClient()
message = client.run(component_id=component_id, version="latest",
                 stream=False, sys_origin_query="北京景点推荐")
print(message.content.content[0].text)

import os
import appbuilder


# 请前往千帆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
# 设置环境变量
os.environ["APPBUILDER_TOKEN"] = (
    "..."
)

# 组件ID，可在个人空间-组件下查看
component_id = "..."
client = appbuilder.ComponentClient()
message = client.run(component_id=component_id, version="latest",
                     stream=True, sys_origin_query="北京景点推荐")
for content in message.content:
    if len(content.content)>0:
        print(content.content[0].text)

package com.baidubce.appbuilder.demo;

import com.baidubce.appbuilder.base.exception.AppBuilderServerException;
import com.baidubce.appbuilder.console.componentclient.ComponentClient;
import com.baidubce.appbuilder.model.componentclient.ComponentClientIterator;
import com.baidubce.appbuilder.model.componentclient.ComponentClientRunRequest;
import com.baidubce.appbuilder.model.componentclient.ComponentClientRunResponse;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

public class ComponentClientDemo {
    public static void main(String[] args) {
        // 组件ID，可在个人空间-组件下查看
        String componentId = "...";

        try {
            ComponentClient client = new ComponentClient();
            Map<String, Object> parameters = new HashMap<>();
            parameters.put(ComponentClientRunRequest.SysOriginQuery, "北京景点推荐");

            // Run without streaming
            ComponentClientIterator iter = client.run(componentId, "latest", "", false, parameters);
            while (iter.hasNext()) {
                ComponentClientRunResponse response = iter.next();
                if(response.getContent().length > 0) {
                    Map<String, Object> textMap = (Map<String, Object>) response.getContent()[0].getText();
                    System.out.println("Without streaming: " + textMap.toString());
                }
            }

            // Run with streaming
            iter = client.run(componentId, "latest", "", true, parameters);
            Map<String, Object> textMap = null;
            while (iter.hasNext()) {
                ComponentClientRunResponse response = iter.next();
                if (response.getContent().length > 0) {
                    textMap = (Map<String, Object>) response.getContent()[0].getText();
                }
            }
            if (textMap != null) {
                System.out.println("With streaming: " + textMap.toString());
            }

        } catch (IOException | AppBuilderServerException e) {
            e.printStackTrace();
        }
    }
}

// 安装说明：
// 支持Go 1.18以上版本
// go get github.com/baidubce/app-builder/go/appbuilder

package main

import (
	"fmt"
	"os"

	"github.com/baidubce/app-builder/go/appbuilder"
)

func main() {
	os.Setenv("APPBUILDER_LOGLEVEL", "DEBUG")
	os.Setenv("APPBUILDER_LOGFILE", "")
  // 请前往千帆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
	config, err := appbuilder.NewSDKConfig("", "...")
	if err != nil {
		fmt.Println("new http client config failed: ", err)
	}

  // 组件ID，可在个人空间-组件下查看
	componentID := "..."
	client, err := appbuilder.NewComponentClient(config)
	if err != nil {
		fmt.Println("new ComponentClient instance failed")
	}

	parameters := map[string]any{
		appbuilder.SysOriginQuery: "北京景点推荐",
	}
	ans, err := client.Run(componentID, "latest", "", false, parameters)
	if err != nil {
		fmt.Println("run component failed: " + err.Error())
	}

	// run non stream
	for answer, err := ans.Next(); err == nil; answer, err = ans.Next() {
		data := answer.Content[0].Text
		if data == nil {
			fmt.Println("run component failed: data is nil")
			return
		}
		fmt.Println("run component result: ")
		fmt.Println(data)
	}

	// run stream
	streamAns, err := client.Run(componentID, "latest", "", true, parameters)
	if err != nil {
		fmt.Println("run component failed: " + err.Error())
	}
	var answerText any
	for answer, err := streamAns.Next(); err == nil; answer, err = streamAns.Next() {
		if len(answer.Content) == 0 {
			continue
		}
		answerText = answer.Content[0].Text
	}
	if answerText == nil {
		fmt.Println("run component failed: answer is nil")
		return
	}
	fmt.Println("run component result: ")
	fmt.Println(answerText)
}