Spanner queues 正式商用并限定企业级版本
Google Cloud 已正式宣布其分布式数据库消息传递功能 Spanner queues 达到全面可用(GA)状态。官方博客文章于 2026 年 10 月 2 日正式发布,但官方发布说明与开发者社区记录显示,该功能在 2026 年 9 月中旬(文档概览标注为 9 月 17 日)已在技术层面上线 GA。
在可用范围方面,Spanner queues 并非适用于所有 Spanner 实例,官方明确限定该功能仅在 Spanner Enterprise 版本和 Enterprise Plus 版本中提供。
消除双写不一致,保障智能体决策与执行原子化
在构建复杂的 AI 智能体工作流时,智能体通常需要在操作型数据库中维护内部状态,同时通过独立的消息或事件队列系统分发异步操作。
管理两个具有不同提交点的系统会破坏智能体系统的事务一致性。如果数据库状态更新成功但动作分发失败,智能体会陷入决定行动却未执行的状况;若消息分发成功但状态事务回滚,智能体则会基于无效状态执行动作。
为应对这一挑战,Spanner queues 允许开发者在单个 Spanner 读写事务中原子化地结合消息发送、确认与常规数据库写入,状态变更和执行意图作为单个原子单元提交或完全失败。该功能旨在消除对独立外部消息基础设施的依赖,使开发者无需构建复杂的发件箱模式、幂等层和对账工作程序,从而减轻智能体架构的可靠性负担。
拉取模型与更广泛的事件驱动应用场景
Spanner queues 采用拉取模型进行消息消费,并为接收者暴露了 SQL 接口以请求和接收消息。同时,队列在 Spanner 中被定义为模式对象,其访问控制符合标准的 Spanner 数据库角色和权限。
队列消息支持在提交后立即分发,也支持计划在未来交付,可满足延迟重试、计划的智能体签到或 SLA 升级计时器等模式,无需外部 cron 调度器。在交付机制上,系统自动提供至少一次交付和至多一次确认;官方主张,通过在同一事务中保存状态修改和下游任务,开发者可以实现精确一次的处理逻辑。
在具体定位上,官方指出 Spanner queues 适用于事务性事件通知、未来计划的工作执行和单条消息确认逻辑,而现有的 Spanner change streams 则适用于高吞吐量数据复制、同步下游缓存或审计日志。除 AI 智能体外,Spanner queues 亦可作为多用途消息平台,支持社交应用实时活动流、新闻实时更新、零售订单处理及金融服务高吞吐量异步任务处理等传统事件驱动架构。

