Github | Npm | Demo | Documentos
Adiciona ganchos e componentes para trabalhar com fluxos OpenAI.

nextjs-openai inclui ferramentas de front-end, e openai-streams inclui ferramentas para trabalhar com fluxos OpenAI em suas rotas de API.
yarn add nextjs-openai openai-streams
# -or-
npm i --save nextjs-openai openai-streams useBuffer() e useTextBuffer() são usados para carregar um buffer incrementador de dados (e texto) de um determinado 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> e <StreamingTextURL> renderizam o texto de um buffer de fluxo usando uma animação Fade-in.
import { StreamingTextURL } from "nextjs-openai" ;
export default function Demo ( ) {
return (
< StreamingTextURL
url = "/api/demo"
fade = { 600 }
throttle = { 100 }
/ >
) ;
} Se você deseja alterar o tipo de solicitação de rede feita com ganchos <StreamingTextURL> ou useBuffer() e useTextBuffer() , você pode definir as opções { method, data } .
{ data } é enviado como o corpo da solicitação de postagem por padrão. Para usar uma solicitação GET, defina { method = "GET" } e defina manualmente os parâmetros de pesquisa de URL em { url } .
Consulte src/pages/index.tsx para um exemplo ao 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 trabalhar com fluxos em suas rotas de 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"
} ; Se você não estiver usando o Edge Runtime, importe a versão NodeJS.Readable do 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 ) ;
}