GitHub | NPM | Demostración | Documento
Agrega ganchos y componentes para trabajar con transmisiones OpenAI.

nextjs-openai incluye herramientas frontend y openai-streams incluye herramientas para trabajar con transmisiones OpenAI en sus rutas API.
yarn add nextjs-openai openai-streams
# -or-
npm i --save nextjs-openai openai-streams useBuffer() y useTextBuffer() se usan para cargar un búfer incremento de datos (y texto) de una URL dada.
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> y <StreamingTextURL> Renderiza el texto de un búfer de transmisión utilizando una animación de desvanecimiento.
import { StreamingTextURL } from "nextjs-openai" ;
export default function Demo ( ) {
return (
< StreamingTextURL
url = "/api/demo"
fade = { 600 }
throttle = { 100 }
/ >
) ;
} Si desea cambiar el tipo de solicitud de red realizada con <StreamingTextURL> o los ganchos useBuffer() y useTextBuffer() , puede establecer las opciones { method, data } .
{ data } se envía como el cuerpo de la solicitud posterior de forma predeterminada. Para usar una solicitud GET, establezca { method = "GET" } y establezca manualmente los parámetros de búsqueda de URL en { url } .
Consulte src/pages/index.tsx para un ejemplo en vivo.
<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 } >
);
} Use openai-streams para trabajar con transmisiones en sus rutas 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"
} ; Si no está utilizando el tiempo de ejecución de Edge, importe la versión NodeJS.Readable desde 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 ) ;
}