研究与报告
规划者把一个问题拆成子任务,多个研究者并行工作,写作者再从共享记忆中整合结果。
规划、研究和写作智能体通过持久化任务流交接工作,共享结果和记忆,任务永不丢失。
规划者拆分工作,并向流中添加一个任务。
使用真实 HotKV 命令和示例回复的动画演示。点击任意步骤即可跳转。 命令和回复保持英文,与您在 HotKV 中输入和看到的完全一致。
智能体团队需要一种方式来相互传递工作、共享各自的发现,并在某个智能体中途崩溃时恢复。用临时拼凑的 HTTP 调用把这些串起来,会丢失任务、重复调用工具,而且没有任何记录说明谁做了什么。
带消费者组的流就是任务看板。每个智能体读取自己的任务,完成后确认,崩溃的智能体留下的待处理任务可以被其他智能体认领。发现写入共享的工作记忆,工具结果为所有智能体缓存,每个操作都会被记录。
规划者拆分工作,并向流中添加一个任务。
XADD tasks * type research topic "EU AI Act obligations"消费者组已事先用 XGROUP CREATE 创建一次。研究者作为组成员读取任务,任务在被确认之前一直处于待处理状态。
XREADGROUP GROUP agents researcher COUNT 1 BLOCK 5000 STREAMS tasks >另一个智能体今天已经执行过这次搜索。共享工具缓存直接返回结果。
TOOL.CACHE.GET web "search:EU AI Act obligations"结果写入该项目的工作记忆,每个智能体都能读取。
AMEM.WORK.SET project:9 findings "Providers of high-risk systems must ..."任务完成,离开待处理列表。如果研究者崩溃了,XAUTOCLAIM 会把任务交给另一个智能体。
XACK tasks agents 1790985600123-0写作者读取共享的发现,起草报告并记录这次操作。
AMEM.WORK.GET project:9 findings规划者把一个问题拆成子任务,多个研究者并行工作,写作者再从共享记忆中整合结果。
编码、测试和评审智能体通过流传递工作,它们做出的每项改动都记录在情景日志中。
发票提取、校验和入账智能体沿着一条能挺过重启的管道传递文档。
带消费者组、确认机制以及可认领被遗弃任务的流。
XADDXREADGROUPXACKXAUTOCLAIM每个智能体都能读取和更新的项目状态。
AMEM.WORK.SETAMEM.WORK.GET确定性的工具结果在智能体之间复用。
TOOL.CACHE.GETTOOL.CACHE.SET每个智能体一份情景日志,便于审计和调试。
AMEM.EPIS.LOG任务会留在消费者组的待处理列表中。空闲足够长时间后,另一个智能体可以用 XAUTOCLAIM 接管它。
可以。它们只需要连接到 HotKV。任何支持 Redis 协议的客户端都能使用。
流在所有套餐中均可使用。智能体记忆和工具缓存包含在 Performance 和 Scale 套餐中。