SuperAPI AI 工具集

atlas-stream-processing

数据与分析

查看项目

更新于 10-16 01:19

技能介绍

用途:通过 MongoDB MCP Server 的四个工具构建、运行和调试 Atlas Stream Processing(ASP)管道。

主要能力:atlas-streams-discover 负责所有读取操作(列出/检查工作区、连接、处理器,诊断处理器,查看 PrivateLink 与 VPC 对等网络);atlas-streams-build 负责所有创建操作(工作区、连接、处理器、PrivateLink);atlas-streams-manage 负责更新与状态操作(启动/停止/修改处理器、更新工作区与连接、接受或拒绝对等连接);atlas-streams-teardown 负责删除操作。

使用方式:需先连接 MongoDB MCP Server,配置 Atlas API 凭据(apiClientId、apiClientSecret),并具备上述四个工具。所有操作需 Atlas 项目 ID,未知时先调用 atlas-list-projects。创建处理器前必须先调用 search-knowledge 校验字段,并可从官方示例仓库 https://github.com/mongodb/ASP_example 获取管道示例。

限制:ASP 无免费层,处理器运行期间按小时计费、按秒计算;停止后状态保留 45 天。管道不支持 $$NOW、$$ROOT、$$CURRENT;HTTPS 不能作为 $source;Kafka $source 必须含 topic;部署的处理器必须有终止阶段;Lambda 使用 $externalFunction 而非 $emit;$validate 的 validationAction 应为 dlq。单个管道只能有一个终止 sink,多目标需用链式处理器。删除工作区会级联删除全部连接与处理器,删除前须先检查并确认。不支持在工作区之间移动处理器,也不支持 dry-run 模拟。