MongoDB Atlas作为基于意图的代理网络的统一操作数据层,使AI代理能够实时自主配置、监控和修复复杂的网络。
使用案例: Gen AI
行业: 电信
产品: MongoDB Atlas、MongoDB Search、MongoDB Atlas Vector Search、Voyage AI
解决方案概述
电信和媒体以及软件和金融科技都是引领AI采用的行业。然而,领先者与其他公司之间的差距却在不断拉大:处于AI功能前沿的公司的收入增长大约是同行的两倍,而近四分之三的公司尚未从其AI投资中显示出任何有形价值。电信业在一个领域尤其领先——它的代理AI采用率是所有行业中最高的。差距不在于模型。这是代理处理实时网络数据所需的一切:
数据管道
Vector Search
嵌入
短期和长期记忆
实时处理
代理网络自动化弥补了这一差距。工程师无需手动将请求转换为设备配置,而是由自主代理解释目标、计划变更、作用于网络并验证结果。 IBN 是这种模式最清晰的表达式。您用通俗易懂的业务术语陈述网络结果,系统无需进一步干预即可交付和保护它。
通过 IBN,运营商的客户可以描述他们的需求,而不是如何构建需求。示例:新开一家旗舰存储。赋予 POS 流量优先级,严格隔离访客 WiFi,添加摄像头上行链路,并将 POS延迟控制在 40 毫秒以下。
一个中心代理将该意图转换为网络策略、预配服务并持续监控这些服务。当网络与承诺发生偏离时,代理会诊断原因并自行应用修复。
MongoDB Atlas 提供操作数据层,驱动此工作流。它将代理需要的所有资源整合到一个数据库中,实现对当前网络状态、客户协议、事件历史和操作员见解的实时查询。AI 层直接连接到数据,无需消息总线、缓存或 ETL 管道。“参考架构”部分详细介绍了该框架的工作原理。
参考架构
该解决方案在由 MongoDB Atlas 支持的单一代理上运行。图 1 显示主要组件:
基于 ReAct 的协调器
两阶段语义路由器
一设立专门的 MCP 微服务
Atlas 集合存储网络数据和代理内存
每个服务都从 Atlas 读取和向 Atlas 写入,无需维护消息总线、缓存或 ETL 管道。该基础可扩展:通过添加 MCP 服务和集合,相同的编排器、路由器和内存层可以承担新域。该框架为未来的使用案例奠定了基础,例如用于情况假设容量规划的数字网络双生。
图 1。编排器通过 MongoDB Atlas 路由每个查询,它存储服务目录、IBN 集合和代理的内存。
将查询路由到正确的服务
随着服务数量的增加,代理需要一种可靠的方式来选择正确的服务。路由分为两个阶段运行,两个阶段都由 MongoDB 提供支持。
首先,一个小型 LLM 使用每个域而不是每个服务的几行对短域分类法进行查询分类。随着服务的增加,该框架可以保持路由准确。其次,经过过滤到所选域的 Atlas $vectorSearch 检索最匹配的服务。服务目录存储在 Atlas 中,查询通过它进行路由。
意图生命周期
从初始请求到最终解决,网络结果意图会通过以下服务:
意图服务:使用 LLM 将自然语言请求解析为结构化字段。它会追踪意图在提交、可行、计划、活动、违规和关闭阶段中的状态。
库存服务:保存物理网络,将站点与地理空间坐标和每个位置的可用资源进行映射。当站点需要备用设备时,它会使用地理空间查询来找到最近的可用设备。
可行性服务:将意图与当前库存匹配,构建具体的服务计划,并写入该计划的不可变快照。每次更改都会创建一个新快照,因此可以对完整的规划历史进行审计。
保证服务:根据已同意的目标监控实时遥测数据。当指标超出阈值时,它会记录合规事件并实时将其推送到仪表盘。
遥测模拟器:按需注入事件,以便您可以在受控环境中测试完整的违规、诊断和修复周期。
在单一查询中诊断
实时违规会创造最严峻的时刻。假设新店的 POS 延迟超过其 40 毫秒的目标。保障代理不会打开工单,而是运行单个 Atlas 聚合管道,对知识库应用特定过滤器,对四个维度创建单个诊断查询:
语义相似度:
$vectorSearch找到说明与当前违规最接近的过去事件,例如队列调度冲突、严格客户分段激活、链路利用率低。结构化过滤器:将结果限制为过去事件,以便运行手册和策略模板不会冲淡匹配。
时间窗口:排除早于 180 天的事件,以免早期网络状态的结论误导结果。
地理空间边界:使搜索局部化,以便一个城市中的事件不会影响另一个城市中的诊断。
这些操作作为 Atlas Vector Search 索引内的预过滤器运行,在运行相似度计算之前缩小候选集。响应返回最近的过去事件、其根源及其经验证的运行手册。代理应用运行手册,记录恢复事件,仪表盘变为绿色。Atlas 中的一个管道可替换多个协调的查询通过不同系统。
数据模型方法
IBN 可以处理不同的数据形状,MongoDB Atlas 可以将它们全部存储在一个位置。以下每个集合都对应工作流的一个部分:
ibn_intents: 存储已解析的意图及其生命周期状态。它包含请求中指定的所有字段,例如延迟上限或分段策略。ibn_sites: 包含具有 2dsphere 索引坐标的网络站点,用于地理空间查询。ibn_resources: 包含每个站点可用的网络资源。ibn_policy_snapshots: 存储不可变的计划快照,保留完整的计划历史记录。ibn_telemetry. 将指标样本存储在时间序列集合中。ibn_compliance_events: 存储每次违规和恢复的记录。ibn_knowledge_chunks: 存储过去事件、运行手册和模板,并使用 Voyage AI 自动嵌入以进行向量搜索。
代理的内存也存储在 MongoDB 中,存储在专用集合中,与网络数据一起:
agent_workstreams: 为当前工作线程存储短期上下文。agent_memories: 在工作流关闭时提取长期事实,并对其进行向量索引,以便在会话之间进行回调。user_preferences: 存储工程师教给代理的指令。
单个 Atlas Vector Search 索引使四维诊断查询成为可能。借助 Atlas 自动嵌入,您可以将索引指向文本字段,Atlas 会为您生成并存储嵌入。您无需另外的嵌入管道或服务来运行。同一索引将自动嵌入的文本字段与结构化、时间和地理空间过滤器配对。因此,$vectorSearch 阶段可以完成多个查询引擎的工作:
{ "fields": [ { "type": "autoEmbed", "modality": "text", "path": "text", "quantization": "float", "model": "voyage-4" }, { "type": "filter", "path": "kind" }, { "type": "filter", "path": "segment" }, { "type": "filter", "path": "market" }, { "type": "filter", "path": "plan_id" }, { "type": "filter", "path": "ts" }, { "type": "filter", "path": "lng" }, { "type": "filter", "path": "lat" } ] }
构建解决方案
此 GitHub存储库提供了完整的演示。克隆存储库,然后按照以下步骤操作。
运行代理并实时观看
启动 Web 服务器并在浏览器中点 http://localhost:8070 / 以获取交互式Shell。
./bin/start.sh
顶部导航栏中的按钮允许您:
将种子数据馈送到 MongoDB 集合。
重置数据以重新进行演示。
打开另一个浏览器窗口以显示 IBN 仪表盘。
实时查看监控站点的实时状态。
尝试完整的意图生命周期
从浏览器中的聊天内容开始,引导代理完成一个完整的意图,从请求到恢复。诊断违规提示会触发四维诊断查询。
-I'm opening a new Alpenmarkt store at Marienplatz Munich. POS priority, guest WiFi strictly separated, camera uplink, online by 18:00, max 40ms POS latency, 99.95% availability -feasibility check -propose and activate -inject morning rush -diagnose violation -apply runbook
关键要点
将数据统一存储在一个存储库中:将意图记录、地理空间站点、时间序列遥测和向量索引知识保存在单个 MongoDB Atlas 数据库中,可使用一个驱动程序和一个管道进行查询。
在一次查询中跨维度检索:在单个 Atlas Vector Search 阶段中组合向量相似性、结构化过滤器、时间窗口和地理空间边界,无需应用程序侧协调。
流式实时更改:使用 MongoDB Change Streams 将意图激活、违规和恢复推送到仪表盘,而无需轮询。
为代理提供记忆:将短期上下文、长期事实和用户偏好存储为集合,以便代理可以随着使用而改进,而不是重新训练。
自动化完整的意图生命周期:让一个代理在实时数据的基础上端到端地解析、规划、激活、保证和修复网络意图。
作者
Benjamin Lorenz, MongoDB
Aditya Vikram Roy,MongoDB
Diego Canales, MongoDB