MongoDB 聊天记忆
兼容性
仅在 Node.js 上可用。
您可以通过将 runtime
变量设置为 nodejs
来创建使用 MongoDB 的 API 路由,如下所示
export const runtime = "nodejs";
您可以在 Next.js 文档中阅读有关边缘运行时的更多信息 这里。
为了在聊天会话之间实现长期持久化,您可以用 MongoDB 实例替换默认的内存中 chatHistory
,该实例支持 BufferMemory
等聊天记忆类。
设置
您需要在项目中安装 Node MongoDB SDK
- npm
- Yarn
- pnpm
npm install -S mongodb
yarn add mongodb
pnpm add mongodb
提示
- npm
- Yarn
- pnpm
npm install @langchain/openai @langchain/community
yarn add @langchain/openai @langchain/community
pnpm add @langchain/openai @langchain/community
您还需要一个 MongoDB 实例来连接。
使用
存储在 MongoDB 中的每个聊天历史会话都必须具有唯一的会话 ID。
import { MongoClient, ObjectId } from "mongodb";
import { BufferMemory } from "langchain/memory";
import { ChatOpenAI } from "@langchain/openai";
import { ConversationChain } from "langchain/chains";
import { MongoDBChatMessageHistory } from "@langchain/mongodb";
const client = new MongoClient(process.env.MONGODB_ATLAS_URI || "", {
driverInfo: { name: "langchainjs" },
});
await client.connect();
const collection = client.db("langchain").collection("memory");
// generate a new sessionId string
const sessionId = new ObjectId().toString();
const memory = new BufferMemory({
chatHistory: new MongoDBChatMessageHistory({
collection,
sessionId,
}),
});
const model = new ChatOpenAI({
model: "gpt-3.5-turbo",
temperature: 0,
});
const chain = new ConversationChain({ llm: model, memory });
const res1 = await chain.invoke({ input: "Hi! I'm Jim." });
console.log({ res1 });
/*
{
res1: {
text: "Hello Jim! It's nice to meet you. My name is AI. How may I assist you today?"
}
}
*/
const res2 = await chain.invoke({ input: "What did I just say my name was?" });
console.log({ res2 });
/*
{
res1: {
text: "You said your name was Jim."
}
}
*/
// See the chat history in the MongoDb
console.log(await memory.chatHistory.getMessages());
// clear chat history
await memory.chatHistory.clear();
API 参考
- BufferMemory 来自
langchain/memory
- ChatOpenAI 来自
@langchain/openai
- ConversationChain 来自
langchain/chains
- MongoDBChatMessageHistory 来自
@langchain/mongodb