百度AI千帆大模型示例代码 GO语言版

前端:

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>Sample</title>
</head>
<body><label for="textInput">Prompt:</label><input type="textarea" id="textInput" placeholder="您有什么问题"><button onclick="run_prompt()">执行prompt</button><p><textarea id="answer" rows="10" cols="50" readonly></textarea></p>
<script>current_text = document.getElementById('answer');text = "";char_index = 0function run_prompt() {var inputValue = document.getElementById('textInput').value;document.getElementById('answer').value = "";// 调用服务端的流式接口, 修改为自己的服务器地址和端口号fetch('http://<server address>:8000/eb_stream', {method: 'post',headers: {'Content-Type': 'text/plain'},body: JSON.stringify({'prompt': inputValue})}).then(response => {return response.body;}).then(body => {const reader = body.getReader();const decoder = new TextDecoder();function read() {return reader.read().then(({ done, value }) => {if (done) { // 读取完成return;}data = decoder.decode(value, { stream: true });text += JSON.parse(data).result;type();  // 打字机效果输出return read();});}return read();}).catch(error => {console.error('发生错误:', error);});}function type() {let enableCursor = true;  // 启用光标效果if (char_index < text.length) {let txt = document.getElementById('answer').value;let cursor = enableCursor ? "|" : "";if (enableCursor && txt.endsWith("|")) {txt = txt.slice(0, -1);}document.getElementById('answer').value = txt + text.charAt(char_index) + cursor;char_index++;setTimeout(type, 1000/5);  // 打字机速度控制, 每秒5个字}}
</script>
</body>
</html>
// go run main.gopackage mainimport ("bufio""encoding/json""fmt""io""log""net/http""strings""github.com/gin-contrib/cors""github.com/gin-gonic/gin"
)const (// 运行端口号SERVER_PORT = ":8000"// 千帆应用 AK/SKAPI_KEY    = "JMLF5n6eWqxxxx9ECh"SECRET_KEY = "s1ii7dGJBK5Jxxxx8iIrAET"// 鉴权接口URLTOKEN_URL = "https://aip.baidubce.com/oauth/2.0/token"// 大模型接口URLEB_URL = "https://aip.baidubce.com/rpc/2.0/ai_custom/v1/wenxinworkshop/chat/eb-instant"
)// GetAccessToken 使用 AK,SK 生成鉴权签名(Access Token)
func GetAccessToken() (string, error) {// 拼接请求参数postData := fmt.Sprintf("grant_type=client_credentials&client_id=%s&client_secret=%s", API_KEY, SECRET_KEY)client := &http.Client{}req, err := http.NewRequest("POST", TOKEN_URL, strings.NewReader(postData))if err != nil {return "", fmt.Errorf("创建HTTP Request报错: %s", err.Error())}// 设置请求头req.Header.Add("Content-Type", "application/json")req.Header.Add("Accept", "application/json")// 发起请求并获取响应ret, err := client.Do(req)if err != nil {return "", fmt.Errorf("执行HTTP请求报错: %s", err.Error())}defer ret.Body.Close()// 解析响应内容body, err := io.ReadAll(ret.Body)if err != nil {return "", fmt.Errorf("获取Token报错: %s", err.Error())}// 解析并返回 access_tokenaccessTokenObj := map[string]string{}_ = json.Unmarshal([]byte(body), &accessTokenObj)return accessTokenObj["access_token"], nil
}// main 主入口
func main() {// 初始化Gin实例r := gin.Default()// 跨域配置r.Use(cors.Default())// 注册路由r.POST("/eb_stream", func(c *gin.Context) {// 设置响应头c.Header("Connection", "keep-alive")c.Header("Cache-Control", "no-cache")c.Header("Transfer-Encoding", "chunked")c.Header("Content-Type", "text/event-stream")// 获取入参var prompt struct {Prompt string `json:"prompt"`}if err := c.ShouldBindJSON(&prompt); err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})return}// 获取 Access Tokentoken, err := GetAccessToken()if err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})return}// 组装请求参数并请求文心source := "&sourceVer=0.0.1&source=app_center&appName=streamDemo"url := EB_URL + "?access_token=" + token + sourcepayload := strings.NewReader(fmt.Sprintf(`{"messages":[{"role":"user","content":"%s"}],"stream":true}`, prompt.Prompt))resp, err := http.Post(url, "application/json", payload)if err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})return}defer resp.Body.Close()// 处理返回结果并写入响应流c.Stream(func(w io.Writer) bool {reader := bufio.NewReader(resp.Body)for {// 逐行读取line, err := reader.ReadBytes('\n')if err != nil {log.Println("读取大模型响应数据失败: ", err.Error())break}// 对读到的这行数据进行处理lineStr := string(line)if strings.HasPrefix(lineStr, "data:") {lineStr = strings.TrimPrefix(lineStr, "data:")lineStr = strings.TrimSuffix(lineStr, "\n")log.Println("收到大模型的响应: ", lineStr)// 写入响应流_, err = w.Write([]byte(lineStr))if err != nil {log.Println("写入响应流失败: ", err.Error())return false}// 判断是否为结束if strings.Contains(lineStr, `"is_end":true`) {log.Println("收到大模型反馈的结束标志")break}}log.Println("等待大模型下一次响应")return true}log.Println("流式响应结束")return false})})// 启动服务r.Run(SERVER_PORT)
}

ERNIE-Bot 4.0

package mainimport ("encoding/json""fmt""io/ioutil""net/http""strings"
)
const API_KEY = "JMLF5n6eWq2xxxECh"
const SECRET_KEY = "s1ii7dGJBxxxzT8iIrAET"func main() {url := "https://aip.baidubce.com/rpc/2.0/ai_custom/v1/wenxinworkshop/chat/completions_pro?access_token=" + GetAccessToken()payload := strings.NewReader(`{"disable_search":false,"enable_citation":false}`)client := &http.Client {}req, err := http.NewRequest("POST", url, payload)if err != nil {fmt.Println(err)return}req.Header.Add("Content-Type", "application/json")res, err := client.Do(req)if err != nil {fmt.Println(err)return}defer res.Body.Close()body, err := ioutil.ReadAll(res.Body)if err != nil {fmt.Println(err)return}fmt.Println(string(body))
}/*** 使用 AK,SK 生成鉴权签名(Access Token)* @return string 鉴权签名信息(Access Token)*/
func GetAccessToken() string {url := "https://aip.baidubce.com/oauth/2.0/token"postData := fmt.Sprintf("grant_type=client_credentials&client_id=%s&client_secret=%s", API_KEY, SECRET_KEY)resp, err := http.Post(url, "application/x-www-form-urlencoded", strings.NewReader(postData))if err != nil {fmt.Println(err)return ""}defer resp.Body.Close()body, err := ioutil.ReadAll(resp.Body)if err != nil {fmt.Println(err)return ""}accessTokenObj := map[string]string{}json.Unmarshal([]byte(body), &accessTokenObj)return accessTokenObj["access_token"]
}  

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Kubernetes基础(二十七)-nodePort/targetPort/port/containerPort/hostPort

1 nodePort/targetPort/port/containerPort 1.1 实现层级 1.2 配置方式 ########service########### apiVersion: v1 kind: Service metadata: labels: name: app1 name: app1 namespace: default spec: type: NodePort ports: - <strong>port: 8080 t…

基于C#开发OPC DA客户端——搭建KEPServerEX服务

简介 OPC DA (OLE for Process Control Data Access) 是一种工业自动化领域中的通信协议标准&#xff0c;它定义了应用程序如何访问由OPC服务器提供的过程控制数据。OPC DA标准允许软件应用程序&#xff08;客户端&#xff09;从OPC服务器读取实时数据或向服务器写入数据&…

python:pyecharts 画基金净值 月K线图

pip install pyecharts1.9.1 pyecharts-1.9.1-py3-none-any.whl 我想在本地&#xff08;PC) 画出 基金净值 月K线图&#xff0c;不想每次看图都需联网。 cd my_dir mkdir echarts cd echarts curl -O https://assets.pyecharts.org/assets/echarts.min.js 修改一下开源代码 …

题目 1041: [编程入门]宏定义之找最大数

问题描述&#xff1a; 分别用函数和带参的宏&#xff0c;从三个数中找出最大的数。 样例输入&#xff1a; 1 2 3 样例输出&#xff1a; 3.000 3.000 代码分析&#xff1a; 函数与宏的使用&#xff1a; 函数 max() 用于找出三个实数中的最大值&#xff0c;通过比较大小并…

记录前端面试的一些笔试题(持续更新......)

文章目录 js相关数组去重数组对象去重 实现数组unshift数组扁平化tree型数据扁平化list数据转tree型数据 对象深拷贝防抖/节流函数柯里化函数管道 随便记录一些&#xff0c;面试或者工作中都会用到&#xff0c;实现的方法很多&#xff0c;这里只是一小部分&#xff0c;有更好的…

蓝桥集训之棋盘

蓝桥集训之棋盘 核心思想&#xff1a;差分二进制 因为最终输出的棋盘为01组成k&1 –> 奇1偶0 所以每次差分时元素 最中&1输出即可 #include<iostream>#include<cstring>using namespace std;const int N 2010;int b[N][N];int n,m;int main(){cin&g…

Kubernetes(k8s第四部分之servers)

1&#xff0c;为什么不使用round-robin DNS&#xff1f; 因为DNS有缓存&#xff0c;不会清理&#xff0c;无法负载均衡 ipvs代理模式&#xff0c;这种模式&#xff0c;kube-proxy会监视Kubernetes Service 对象和Endpoints&#xff0c;调用netlink接口以相应地创建ipvs规则并…

理解Linux环境变量及export命令

主要看三个问题 在Linux和Unix系统中&#xff0c;环境变量对于管理系统和应用程序的行为至关重要。本文将介绍Linux环境变量的概念&#xff0c;以及使用export命令设置环境变量的原理和作用。 什么是环境变量&#xff1f; 在Linux和Unix系统中&#xff0c;环境变量是一种可以…

将字典中的键和值对换

Python中要将字典中的键和值对换比如&#xff1a; {daisy: 0, dandelion: 1, roses: 2, sunflower: 3, tulips: 4} 变成 {0: daisy, 1: dandelion, 2: roses, 3: sunflower, 4: tulipsoriginal_dict {daisy: 0, dandelion: 1, roses: 2, sunflower: 3, tulips: 4} new_dict {…

pwn学习笔记(5)--格式化字符串漏洞(未完全完成)

pwn学习笔记&#xff08;5&#xff09;–格式化字符串漏洞 ​ 前言&#xff1a;由于条件有限&#xff0c;因此对于该漏洞的学习不算很多&#xff0c; 格式化字符串漏洞基础&#xff1a; 格式化字符串介绍&#xff1a; ​ 格式化字符串函数可以接收可变数量的参数&#xff0…

清除注册表的U盘(USB盘)使用记录,或者电脑的U盘记录

清除注册表的U盘(USB盘)使用记录&#xff0c;或者电脑的U盘记录 1、可以考虑使用psexec.exe&#xff0c;在Windows图标按右键选择Windows PowerShell(管理员)(A)&#xff0c;然后输入PsExec.exe -i -d -s regedit.exe就可以删除(如果打开注册表&#xff0c;删除id需要右键修改…

鸿蒙学习-数据持久化

应用数据持久化概述 应用数据持久化&#xff0c;是指应用将内存中的数据通过文件或数据库的形式保存到设备上。内存中的数据形态通常是任意的数据结构或数据对象&#xff0c;存储介质上的数据形态可能是文本、数据库、二进制文件等。 HarmonyOS标准系统支持典型的存储数据形态…

win11下安装mysql

一、下载MySQL 官方下载传送门 我安装的版本是5.7.83 二、安装MySQL 1.双击安装包 2.选择Custom(自定义安装)&#xff0c;然后Next> 3.根据你的系统做选择&#xff0c;我的是64位&#xff0c;所选MySQL Servers 5.7.38 -x64&#xff0c;然后按箭头将选中的版本移到右边…

qt学习:QPaintEvent绘图事件+QPainter画家

目录 QPaintEvent绘图事件 常见事件 QPainter 初始化 QPainter 设置画笔和画刷 绘制图形 结束绘制 画线 画矩形 画圆形 画弧线 画扇形 指定画笔大小 QPen 抗锯齿 无边框 画指针 多边形 渐变色 QLinearGradient 使用步骤 示例一 线性渐变 示例二 径向渐…

Java基于springboot的社区团购系统设计论文

摘 要 本课题是根据用户的需要以及网络的优势建立的一个社区团购系统&#xff0c;来满足用户团购的需求。 本社区团购系统应用Java技术&#xff0c;MYSQL数据库存储数据&#xff0c;基于Spring Boot框架开发。在网站的整个开发过程中&#xff0c;首先对系统进行了需求分析&…

小迪安全32WEB 攻防-通用漏洞文件上传二次渲染.htaccess变异免杀

#知识点&#xff1a; 1、文件上传-二次渲染 2、文件上传-简单免杀变异 3、文件上传-.htaccess 妙用 4、文件上传-PHP 语言特性 #详细点&#xff1a; 1、检测层面&#xff1a;前端&#xff0c;后端等 2、检测内容&#xff1a;文件头&#xff0c;完整性&#xff0c…

青蛙过河。

&#xff01;&#xff01;&#xff01;思路和代码源自蓝桥云课大佬题解 问题描述 小青蛙住在一条河边&#xff0c;它想到河对岸的学校去学习。小青蛙打算经过河里的石头跳到对岸。 河里的石头排成了一条直线小青蛙每次跳跃必须落在一块石头或者岸上。 不过,每块石头有一个高度,…

【数据结构】拆分详解 - 排序

文章目录 前言一、排序的概念及其运用  1.1 排序的概念  1.2 排序的运用  1.3 常见的排序算法  1.4 排序算法性能测试对比函数 二、常见排序算法的实现  2.1 插入排序   2.1.1  基本思想   2.1.2  直接插入排序   2.1.3  希尔排序     1. 预排序&am…

特殊设计模式

▶实现一个类&#xff0c;不能被拷贝 ▶实现一个类&#xff0c;只能在堆上创建 ❗实现一个类&#xff0c;只能创建在栈上 ❗设计一个不能继承的类 ❗单例模式——一个类只能生成一个对象   ❔饿汉模式——在每次程序启动都会自动生成一个对象   ❓懒汉模式——在第一次需要…

学编程怎么样才能更快入手,编程怎么简单易学

学编程怎么样才能更快入手&#xff0c;编程怎么简单易学 一、前言 对于初学编程建议先从简单入手&#xff0c;然后再学习其他复杂的编程语言。 今天给大家分享的中文编程开发语言工具 进度条构件的用法。 编程入门视频教程链接 https://edu.csdn.net/course/detail/39036 …