AI 与 LLM智能体Performance 和 Scale 套餐

多智能体编排

规划、研究和写作智能体通过持久化任务流交接工作,共享结果和记忆,任务永不丢失。

智能体崩溃时丢失的任务
0
份共享记忆
1
个智能体并行
N
步骤 1 / 6
发布任务

规划者拆分工作,并向流中添加一个任务。

示例会话playing
# 发布任务
hotkv> XADD tasks * type research topic "EU AI Act obligations"
"1790985600123-0"

使用真实 HotKV 命令和示例回复的动画演示。点击任意步骤即可跳转。 命令和回复保持英文,与您在 HotKV 中输入和看到的完全一致。

问题所在

智能体团队需要一种方式来相互传递工作、共享各自的发现,并在某个智能体中途崩溃时恢复。用临时拼凑的 HTTP 调用把这些串起来,会丢失任务、重复调用工具,而且没有任何记录说明谁做了什么。

HotKV 如何解决

带消费者组的流就是任务看板。每个智能体读取自己的任务,完成后确认,崩溃的智能体留下的待处理任务可以被其他智能体认领。发现写入共享的工作记忆,工具结果为所有智能体缓存,每个操作都会被记录。

逐步演示

逐条命令,看看发生了什么

  1. 01

    发布任务

    规划者拆分工作,并向流中添加一个任务。

    XADD tasks * type research topic "EU AI Act obligations"
  2. 02

    由 worker 认领

    消费者组已事先用 XGROUP CREATE 创建一次。研究者作为组成员读取任务,任务在被确认之前一直处于待处理状态。

    XREADGROUP GROUP agents researcher COUNT 1 BLOCK 5000 STREAMS tasks >
  3. 03

    复用工具结果

    另一个智能体今天已经执行过这次搜索。共享工具缓存直接返回结果。

    TOOL.CACHE.GET web "search:EU AI Act obligations"
  4. 04

    共享发现

    结果写入该项目的工作记忆,每个智能体都能读取。

    AMEM.WORK.SET project:9 findings "Providers of high-risk systems must ..."
  5. 05

    确认

    任务完成,离开待处理列表。如果研究者崩溃了,XAUTOCLAIM 会把任务交给另一个智能体。

    XACK tasks agents 1790985600123-0
  6. 06

    写作者接手

    写作者读取共享的发现,起草报告并记录这次操作。

    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 套餐中。

相关用例

在您自己的工作负载上试试

HotKV 兼容 Redis 协议,您可以把现有客户端指向它,运行这些相同的命令。