unity接入coze智能体

news2024/12/21 23:27:07

官网链接

coze智能体创建、设置

点击创建–选着智能体，随便起一个名字，就可以了
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

添加令牌

在这里插入图片描述
把随便起一个名字，设置时间，把所有选项都勾选上，一定要勾选所有团队空间，否则无法点击确定。
点击确定后，会有一个对话框。里面有key，这个key需要做好备份，对话框关闭后，就无法找到这个key了，没有key就无法进行对话
在这里插入图片描述

API

API链接

每个API里面都有示例，可以按照示例，在代码中调用对应的API
在这里插入图片描述

核心代码

class Coze {


    private string apiToken = "备份的key";
    private string botId = "智能体的bot";

    private string conversationId ;
    private string chatId;
    //AI智能体回复消息的回调
    public Action<string> receiveCallBack;
    public Action processEndCallBack;//进度结束后的回调
    public Action<int> processCallBack;//进度回调
   public IEnumerator SendChatRequest(string userMessage)
    {
        Debug.Log("创建对话");
        // Step 1: 发起对话请求
        string chatUrl = "https://api.coze.cn/v3/chat";
        string jsonBody = $@"{{
            ""bot_id"": ""{botId}"",
            ""user_id"": ""123456789"",
            ""stream"": true,
            ""auto_save_history"": true,
            ""additional_messages"": [
                {{
                    ""role"": ""user"",
                    ""content"": ""{userMessage}"",
                    ""content_type"": ""text""
                }}
            ]
        }}";

        UnityWebRequest chatRequest = new UnityWebRequest(chatUrl, "POST");
        byte[] bodyRaw = Encoding.UTF8.GetBytes(jsonBody);
        chatRequest.uploadHandler = new UploadHandlerRaw(bodyRaw);
        chatRequest.downloadHandler = new DownloadHandlerBuffer();
        chatRequest.SetRequestHeader("Authorization", "Bearer " + apiToken);
        chatRequest.SetRequestHeader("Content-Type", "application/json");

        yield return chatRequest.SendWebRequest();
        Debug.Log("创建对话完成");
        if (chatRequest.result == UnityWebRequest.Result.Success)
        {
            string response = chatRequest.downloadHandler.text;

            // 解析SSE格式
            string[] lines = response.Split('\n');
            string jsonData = "";
            foreach (string line in lines)
            {
                if (line.StartsWith("data:"))
                {
                    jsonData = line.Substring(5); // 去掉"data:"前缀
                    break;
                }
            }
            Debug.Log("对话Json:" + jsonData);
            if (!string.IsNullOrEmpty(jsonData))
            {
                SSEChatResponse sseResponse = JsonUtility.FromJson<SSEChatResponse>(jsonData);
                chatId = sseResponse.id;
                conversationId=sseResponse.conversation_id;
                Debug.Log($"Chat ID: {chatId}");

                // 继续执行后续代码
                yield return MonoInstanceTool.Instance.StartCoroutine(CheckChatStatus());

                yield return MonoInstanceTool.Instance.StartCoroutine(GetChatMessages());
            }
            else
            {
                Debug.LogError("Failed to parse SSE response");
            }
        }
        else
        {
            Debug.LogError("Error: " + chatRequest.error);
        }
    }

      IEnumerator CheckChatStatus()
    {
        bool isCompleted = false;
        while (!isCompleted)
        {
            string statusUrl = $"https://api.coze.cn/v3/chat/retrieve?chat_id={chatId}&conversation_id={conversationId}";
            UnityWebRequest statusRequest = UnityWebRequest.Get(statusUrl);
            statusRequest.SetRequestHeader("Authorization", "Bearer " + apiToken);
            statusRequest.SetRequestHeader("Content-Type", "application/json");
            yield return statusRequest.SendWebRequest();
            if (statusRequest.result == UnityWebRequest.Result.Success)
            {
                string response = statusRequest.downloadHandler.text;

                Debug.Log("检查：" + response);
                ChatResponse statusResponse = JsonUtility.FromJson<ChatResponse>(response);

                // 检查status是否为completed
                if (statusResponse.data.status == "completed")
                {
                    isCompleted = true;
                    Debug.Log("Chat completed!");
                }
                else
                {
                    Debug.Log("Chat still in progress...");
                }
            }
            else
            {
                Debug.LogError("Status check failed: " + statusRequest.error);
            }
            yield return new WaitForSeconds(1);
        }
    }
   //创建对话
    IEnumerator GetChatMessages()
    {
        string messageUrl = $"https://api.coze.cn/v3/chat/message/list?chat_id={chatId}&conversation_id={conversationId}";
        UnityWebRequest messageRequest = UnityWebRequest.Get(messageUrl);
        messageRequest.SetRequestHeader("Authorization", "Bearer " + apiToken);
        messageRequest.SetRequestHeader("Content-Type", "application/json");

        yield return messageRequest.SendWebRequest();

        if (messageRequest.result == UnityWebRequest.Result.Success)
        {
            string response = messageRequest.downloadHandler.text;
            MessageResponse messageResponse = JsonUtility.FromJson<MessageResponse>(response);

            // 查找类型为"answer"的消息
            string content = "";
            foreach (MessageData message in messageResponse.data)
            {
                if (message.type == "answer")
                {
                    content = message.content;
                    break;
                }
            }

            // 显示到UI上
            receiveCallBack?.Invoke(content);

        }
        else
        {
            Debug.LogError("Failed to get messages: " + messageRequest.error);
        }
    }
    
    string dataset_id ="知识库的id";
    string documentId;
   //文件上传知识库
   public IEnumerator UploadFile(string fileName,string base64File)
    {
        string fileExtension = Path.GetExtension(fileName);
        var requestBody = new
        {
            dataset_id = dataset_id,
            document_bases = new[]
            {
                new
                {
                    name =fileName,
                    source_info = new
                    {
                        file_base64 = base64File,
                        file_type = fileExtension
                    }
                }
            },
            chunk_strategy = new
            {
                separator = "\n\n",
                max_tokens = 800,
                remove_extra_spaces = false,
                remove_urls_emails = false,
                chunk_type = 0
            },
            format_type = 0
        };

        string json = JsonConvert.SerializeObject(requestBody);
        Debug.Log(json);
        byte[] jsonToSend = new UTF8Encoding().GetBytes(json);

        UnityWebRequest request = new UnityWebRequest("https://api.coze.cn/open_api/knowledge/document/create", "POST");
        request.uploadHandler = new UploadHandlerRaw(jsonToSend);
        request.downloadHandler = new DownloadHandlerBuffer();
        request.SetRequestHeader("Authorization", $"Bearer {apiToken}");
        request.SetRequestHeader("Content-Type", "application/json");
        request.SetRequestHeader("Agw-Js-Conv", "str");

        yield return request.SendWebRequest();

        if (request.result == UnityWebRequest.Result.ConnectionError || request.result == UnityWebRequest.Result.ProtocolError)
        {
            Debug.LogError("Error uploading file: " + request.error);
        }
        else
        {
            Debug.Log("Response: " + request.downloadHandler.text);
            // 解析 JSON 字符串为 JsonData 对象
            JsonData jsonObject = JsonMapper.ToObject(request.downloadHandler.text);

            // 获取 document_id
            documentId = jsonObject["document_infos"][0]["document_id"].ToString();

            MonoInstanceTool.Instance.StartCoroutine(FileProcess());
        }
    }
    //上传进度
    public IEnumerator FileProcess()
    {
        // 生成要发送的JSON数据
        var requestBody = new
        {
            document_ids = new string[]
            {
            dataset_id, // 知识库ID
            documentId  // 上传进度的文件ID
            }
        };
        string jsonBody = JsonConvert.SerializeObject(requestBody);
        string postUrl = $"https://api.coze.cn/v1/datasets/{dataset_id}/process";

        // 初始化请求对象
        UnityWebRequest request = new UnityWebRequest(postUrl, "POST");

        while (true)
        {
            byte[] bodyRaw = Encoding.UTF8.GetBytes(jsonBody);
            request.uploadHandler = new UploadHandlerRaw(bodyRaw);
            request.downloadHandler = new DownloadHandlerBuffer();
            request.SetRequestHeader("Authorization", $"Bearer {apiToken}"); // 设置Authorization header
            request.SetRequestHeader("Content-Type", "application/json");  // 设置Content-Type为JSON

            // 发送请求并等待返回
            yield return request.SendWebRequest();

            if (request.result == UnityWebRequest.Result.ConnectionError || request.result == UnityWebRequest.Result.ProtocolError)
            {
                Debug.LogError("进度POST 请求失败，错误信息: " + request.error);
                yield break;  // 如果请求失败则退出
            }

            string response = request.downloadHandler.text;
            Debug.Log("ProcessResponse: " + response);

            JsonData jsonObject = JsonMapper.ToObject(response);

            // 获取 status 和 progress
            int status = (int)jsonObject["data"]["data"][0]["status"];
            int progress = (int)jsonObject["data"]["data"][0]["progress"];

            // 如果文件正在处理中，则循环等待并检查进度
            if (status == 0) // 处理中，status 为 0
            {
                processCallBack?.Invoke(progress);

                // 等待一段时间后再次请求
                yield return new WaitForSeconds(2f);  // 每1秒查询一次状态

                // 重新初始化请求对象
                request = new UnityWebRequest(postUrl, "POST");
            }
            else
            {
                // 当 status 为 1 时，表示处理完毕
                if (status == 1)
                {
                    Debug.Log("文件处理完毕，执行后续操作...");
                    // 在这里执行文件处理完毕后的操作
                    // 例如调用回调函数
                    processEndCallBack?.Invoke();
                }
                else if (status == 9)
                {
                    Debug.LogWarning("文件处理失败，建议重新上传");
                    // 在这里可以添加处理文件失败的逻辑
                }

                // 跳出循环，避免重复请求
                break;
            }
        }
    }

}

// 添加这些数据结构类在CozeTest类外部
[System.Serializable]
public class ChatResponse
{
    public ChatData data;
    public int code;
    public string msg;
}

[System.Serializable]
public class ChatData
{
    public string id;
    public string conversation_id;
    public string bot_id;
    public long created_at;
    public long completed_at;
    public string last_error;
    public object meta_data;
    public string status;
    public UsageData usage;
}

[System.Serializable]
public class UsageData
{
    public int token_count;
    public int output_count;
    public int input_count;
}

[System.Serializable]
public class MessageResponse
{
    public int code;
    public MessageData[] data;
    public string msg;
}

[System.Serializable]
public class MessageData
{
    public string bot_id;
    public string content;
    public string content_type;
    public string conversation_id;
    public string id;
    public string role;
    public string type;
}

[System.Serializable]
public class SSEChatResponse
{
    public string id;
    public string conversation_id;
    public string bot_id;
    public long created_at;
    public LastError last_error;
    public string status;
    public UsageData usage;
    public string section_id;
}

[System.Serializable]
public class LastError
{
    public int code;
    public string msg;
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2263479.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

EE308FZ_Sixth Assignment_Beta Sprint_Sprint Essay 3

EE308FZ_Sixth Assignment_Beta Sprint_Sprint Essay 3

Assignment 6Beta SprintCourseEE308FZ[A] — Software EngineeringClass Link2401_MU_SE_FZURequirementsTeamwork—Beta SprintTeam NameFZUGOObjectiveSprint Essay 3_Day5-Day6 (12.15-12.16)Other Reference1. WeChat Mini Program Design Guide 2. Javascript Style Guid…
阅读更多...
国内主流的工程项目管理软件有哪些？

国内主流的工程项目管理软件有哪些？

随着科技的发展&#xff0c;工程管理软件已经成为了工程管理的重要工具。在国内&#xff0c;有许多优秀的工程管理软件&#xff0c;它们可以帮助我们更好地管理工程项目。那么&#xff0c;你知道有哪些工程管理软件吗&#xff1f;下面就让我们一起来盘点一下。 1、广联达 广联…
阅读更多...
网络变压器如何识别电路

网络变压器如何识别电路

1. 基本符号的理解 曲线&#xff1a;表示变压器的线圈&#xff08;windings&#xff09;&#xff0c;每个曲线代表一个独立的线圈。 直线&#xff1a;用于连接不同的元件或引脚&#xff0c;表明电流路径。 2. 关键标注解释 CT&#xff08;Center Tap&#xff09;&#xff1a;中…
阅读更多...
【原生js案例】ajax的简易封装实现后端数据交互

【原生js案例】ajax的简易封装实现后端数据交互

ajax是前端与后端数据库进行交互的最基础的工具&#xff0c;第三方的工具库比如jquery,axios都有对ajax进行第二次的封装&#xff0c;fecth是浏览器原生自带的功能&#xff0c;但是它与ajax还是有区别的&#xff0c;总结如下&#xff1a; ajax与fetch对比 实现效果 代码实现 …
阅读更多...
免费开源！推荐一款网页版数据库管理工具！

免费开源！推荐一款网页版数据库管理工具！

免费开源&#xff01;推荐一款网页版数据库管理工具&#xff01; DBGate 是一个开源的数据库管理工具&#xff0c;DBGate 的最大特点是可以 Web 访问&#xff01;&#xff0c;轻松实现一台机器部署&#xff0c;所有人使用&#xff01; 无论是 MySQL、PostgreSQL、SQLite 还是…
阅读更多...
主要是使用#includenlohmannjson.hpp时显示找不到文件，但是我文件已正确导入visual studio配置，也保证文件正确存在

主要是使用#includenlohmannjson.hpp时显示找不到文件，但是我文件已正确导入visual studio配置，也保证文件正确存在

问题&#xff1a; 主要是在项目配置中包括了C/C配置中文件位置&#xff0c;但是没有把nlohmann上一级的目录包括进去&#xff0c;导致#include"nlohmann/json.hpp"找不到文件位置 解决&#xff1a; 加上上一级目录到附加包含目录 596513661)] 总结&#xff1a; 找不…
阅读更多...
智慧公交指挥中枢，数据可视化 BI 驾驶舱

智慧公交指挥中枢，数据可视化 BI 驾驶舱

随着智慧城市的蓬勃发展&#xff0c;公共交通作为城市运营的核心枢纽&#xff0c;正朝着智能化和数据驱动的方向演进。通过整合 CAN 总线技术(Controller Area Network&#xff0c;控制器局域网总线)、车载智能终端、大数据分析及处理等尖端技术&#xff0c;构建的公交“大脑”…
阅读更多...
[c++11(二)]Lambda表达式和Function包装器及bind函数

[c++11(二)]Lambda表达式和Function包装器及bind函数

1.前言 Lambda表达式着重解决的是在某种场景下使用仿函数困难的问题&#xff0c;而function着重解决的是函数指针的问题&#xff0c;它能够将其简单化。 本章重点&#xff1a; 本章将着重讲解lambda表达式的规则和使用场景&#xff0c;以及function的使用场景及bind函数的相关使…
阅读更多...
redis数据类型：list

redis数据类型：list

list 的相关命令配合使用的应用场景&#xff1a; 栈和队列&#xff1a;插入和弹出命令的配合&#xff0c;亦可实现栈和队列的功能 实现哪种数据结构&#xff0c;取决于插入和弹出命令的配合&#xff0c;如左插右出或右插左出&#xff1a;这两种种方式实现先进先出的数据结构&a…
阅读更多...
基于51单片机的验证码收发系统的仿真设计

基于51单片机的验证码收发系统的仿真设计

一、设计要求 主机、从机均以AT89C52单片机为控制核心。主机生成6位随机验证码、并将验证码发送给从机&#xff1b;从机输入验证码发送给主机&#xff0c;主机接收来自从机发送的验证码并核对两个验证码是否一致。 二、设计内容 主机通过独立按键生成6位随机验证码并发送给从…
阅读更多...
WPF实现曲线数据展示【案例：震动数据分析】

WPF实现曲线数据展示【案例：震动数据分析】

wpf实现曲线数据展示&#xff0c;函数曲线展示&#xff0c;实例&#xff1a;震动数据分析为例。 如上图所示&#xff0c;如果你想实现上图中的效果&#xff0c;请详细参考我的内容&#xff0c;创作不易&#xff0c;给个赞吧。 一共有两种方式来实现&#xff0c;一种是使用第三…
阅读更多...
[机器学习]AdaBoost（数学原理 + 例子解释 + 代码实战）

[机器学习]AdaBoost（数学原理 + 例子解释 + 代码实战）

AdaBoost AdaBoost&#xff08;Adaptive Boosting&#xff09;是一种Boosting算法&#xff0c;它通过迭代地训练弱分类器并将它们组合成一个强分类器来提高分类性能。 AdaBoost算法的特点是它能够自适应地调整样本的权重&#xff0c;使那些被错误分类的样本在后续的训练中得到…
阅读更多...
详细解读TISAX认证的意义

详细解读TISAX认证的意义

详细解读TISAX认证的意义&#xff0c;犹如揭开信息安全领域的一颗璀璨明珠&#xff0c;它不仅代表了企业在信息安全管理方面的卓越成就&#xff0c;更是通往全球汽车供应链信任桥梁的关键一环。TISAX&#xff0c;即“Trusted Information Security Assessment Exchange”&#…
阅读更多...
黑马Redis数据结构学习笔记

黑马Redis数据结构学习笔记

Redis数据结构 动态字符串 Intset Dict ZipList QuickList SkipList 类似倍增 RedisObject 五种数据类型 String List Set ZSet Hash
阅读更多...
sqlilabs靶场二十一关二十五关攻略

sqlilabs靶场二十一关二十五关攻略

第二十一关 第一步 可以发现cookie是经过64位加密的 我们试试在这里注入 选择给他编码 发现可以成功注入 爆出表名 爆出字段 爆出数据 第二十二关 跟二十一关一模一样 闭合换成" 第二十三关 第二十三关重新回到get请求&#xff0c;会发现输入单引号报错&#xff0c…
阅读更多...
Win10将WindowsTerminal设置默认终端并添加到右键（无法使用微软商店）

Win10将WindowsTerminal设置默认终端并添加到右键（无法使用微软商店）

由于公司内网限制&#xff0c;无法通过微软商店安装 Windows Terminal&#xff0c;本指南提供手动安装和配置新版 Windows Terminal 的步骤&#xff0c;并添加右键菜单快捷方式。 1. 下载新版终端安装包: 访问 Windows Terminal 的 GitHub 发布页面&#xff1a;https://githu…
阅读更多...
从地铁客流讲开来：十二城日常地铁客运量特征

从地铁客流讲开来：十二城日常地铁客运量特征

随着城市化进程的加速和人口的不断增长&#xff0c;公共交通系统在现代都市生活中扮演着日益重要的角色。地铁作为高效、环保的城市交通方式&#xff0c;已经成为居民日常出行不可或缺的一部分。本文聚焦于2024年10月28日至12月1日期间&#xff0c;对包括北上广深这四个超一线城…
阅读更多...
firefox浏览器如何安装驱动？

firefox浏览器如何安装驱动？

firefox的浏览器驱动:https://github.com/mozilla/geckodriver/releases 将geckodriver.exe所在文件路径追加到系统环境变量path的后面
阅读更多...
2.2.3 进程通信举例

2.2.3 进程通信举例

文章目录 PV操作实现互斥PV操作实现同步高级通信 PV操作实现互斥 PV操作实现互斥。先明确临界资源是什么&#xff0c;然后确定信号量的初值。实现互斥时&#xff0c;一般是执行P操作&#xff0c;进入临界区&#xff0c;出临界区执行V操作。 以统计车流量为例。临界资源是记录统…
阅读更多...
UE5 移植Editor或Developer模块到Runtime

UE5 移植Editor或Developer模块到Runtime

要将源码中的非运行时模块移植到Runtime下使用，个人理解就是一个解决编译报错的过程，先将目标模块复制到项目的source目录内，然后修改模块文件夹名称，修改模块.build.cs与文件夹名称保持一致 修改build.cs内的类名 ，每个模块都要修改 // Copyright Epic Games, Inc. All …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023