GitHub | Npm | Демо | Док
Добавляет крючки и компоненты для работы с потоками Openai.

nextjs-openai включает в себя инструменты Frontend, а openai-streams включает в себя инструменты для работы с потоками OpenAI на ваших маршрутах API.
yarn add nextjs-openai openai-streams
# -or-
npm i --save nextjs-openai openai-streams useBuffer() и useTextBuffer() используются для загрузки буфера увеличения данных (и текста) из данного URL.
import { useTextBuffer } from "nextjs-openai" ;
export default function Demo ( ) {
const { buffer , refresh , cancel , done } = useTextBuffer ( {
url : "/api/demo"
} ) ;
return (
< div >
< StreamingText buffer = { buffer } fade = { 600 } / >
< button onClick = { refresh } disabled = { ! done } > Refresh < / button >
< button onClick = { cancel } disabled = { done } > Cancel < / button >
< / div >
) ;
} <StreamingText> и <StreamingTextURL> рендеринг текст из буфера потока с использованием анимации затухания.
import { StreamingTextURL } from "nextjs-openai" ;
export default function Demo ( ) {
return (
< StreamingTextURL
url = "/api/demo"
fade = { 600 }
throttle = { 100 }
/ >
) ;
} Если вы хотите изменить тип сетевого запроса, сделанный с помощью крючков <StreamingTextURL> или useBuffer() и useTextBuffer() , вы можете установить параметры { method, data } .
{ data } отправляется в качестве корпуса запроса post по умолчанию. Чтобы использовать запрос GET, установите { method = "GET" } и вручную установите параметры поиска URL на { url } .
См src/pages/index.tsx для живого примера.
<StreamingTextURL> import { StreamingTextURL } from "nextjs-openai" ;
export default function Home ( ) {
const [ data , setData ] = useState ( { name : "John" } ) ;
// ...
return (
< StreamingTextURL url = "/api/demo" data = { data } >
);
} useTextBuffer() import { useTextBuffer , StreamingText } from "nextjs-openai" ;
export default function Home ( ) {
const [ data , setData ] = useState ( { name : "John" } ) ;
const { buffer , refresh , cancel } = useTextBuffer ( {
url : "/api/demo" ,
throttle : 100 ,
data ,
/**
* Optional: Override params for `fetch(url, params)`.
*/
options : {
headers : {
// ...
}
}
} ) ;
// ...
return (
< StreamingText buffer = { buffer } >
);
} Используйте openai-streams для работы с потоками в ваших маршрутах API.
import { OpenAI } from "openai-streams" ;
export default async function handler ( ) {
const stream = await OpenAI (
"completions" ,
{
model : "text-davinci-003" ,
prompt : "Write a happy sentence.nn" ,
max_tokens : 25
} ,
) ;
return new Response ( stream ) ;
}
export const config = {
runtime : "edge"
} ; Если вы не используете время выполнения Edge, импортируйте NodeJS.Readable версию из openai-streams/node .
import type { NextApiRequest , NextApiResponse } from "next" ;
import { OpenAI } from "openai-streams/node" ;
export default async function test ( _ : NextApiRequest , res : NextApiResponse ) {
const stream = await OpenAI (
"completions" ,
{
model : "text-davinci-003" ,
prompt : "Write a happy sentence.nn" ,
max_tokens : 25
}
) ;
stream . pipe ( res ) ;
}