用于LangChain,通过自动化工作流程处理用户消息,实时记录并缓冲信息,确保在短时间内(5秒)判断用户是否继续发送消息,避免重复回复。此流程整合了Redis和Twilio,提升了交互效率,确保AI代理能够在用户发送多条消息时,提供更连贯的回复,改善用户体验。
- 步骤 2:缓冲输入消息
新消息被推入 Redis 列表中,系统会在接收到新消息后等待 5 秒,以检查用户是否发送了更多消息。
- 步骤 3:获取最新消息堆栈
系统从 Redis 中获取最新的消息堆栈,并判断是否继续执行。
- 步骤 4:检查是否继续
如果最新消息与当前接收的消息相同,继续处理,否则终止执行。
- 步骤 5:获取聊天历史
系统从聊天内存中获取历史消息,以便生成合适的回复。
- 步骤 6:生成消息缓冲区
通过比较历史消息和最新消息,生成需要回复的消息缓冲区。
- 步骤 7:AI 代理生成回复
将缓冲区中的消息发送给 AI 代理,生成单条回复,提升用户体验。
- 步骤 8:发送回复
系统通过 Twilio 发送生成的回复给用户。