手动触发自动化 - N8N 工作流导航

适用人群

适合需要自动化消息处理和信息提取的开发者和团队。特别是那些使用 LangChain 和 Redis 进行数据管理和流处理的用户。此工作流适合于希望减少手动干预并提高响应速度的技术团队和产品经理。

解决的问题

该工作流解决了在接收消息后如何有效管理和处理信息的问题。它通过使用 Redis 存储消息和状态，确保在高并发情况下能保持数据一致性，并通过 LangChain 的信息提取功能来整合和生成响应，减少了信息重复和遗漏的风险。

工作流程

手动触发工作流: 用户点击“测试工作流”按钮，启动整个流程。
2. 获取等待时间: 通过代码节点计算消息字数，决定等待时间（少于 5 个字的消息等待 45 秒，否则等待 30 秒）。
3. 设置最后接收时间: 将当前时间戳存储到 Redis，以便后续判断。
4. 检查是否有待处理的回复: 从 Redis 获取 waiting_reply 键，判断是否有未处理的消息。
5. 缓冲消息: 将新消息推送到 Redis 列表中，更新缓冲区。
6. 等待和检查: 如果有待处理的回复，工作流将等待指定的时间后再次检查。
7. 获取缓冲区内容: 从 Redis 获取所有待处理的消息，并通过信息提取器进行整合。
8. 生成响应: 使用 OpenAI 的聊天模型生成最终的回复。
9. 清理缓冲区: 在完成回复后，删除 Redis 中的相关键以释放资源。

自定义指南

用户可以根据以下方式自定义和适应此工作流：
- 修改等待时间: 在 get wait seconds 节点中调整字数阈值和对应的等待时间。
- 更改信息提取逻辑: 在 Information Extractor 节点中自定义系统提示模板，以适应不同的消息处理需求。
- 调整 Redis 键值: 在设置和获取 Redis 键时，可以根据实际需要修改键名和操作类型。
- 集成其他服务: 可以根据项目需求，替换或添加其他 API 调用节点，以实现更复杂的业务逻辑。