SuperAPI AI 工具集

mongodb-atlas-stream-processing

数据与分析

查看项目

更新于 10-16 01:19

技能介绍

用途:基于 MongoDB MCP Server 的四个工具(atlas-streams-discover、atlas-streams-build、atlas-streams-manage、atlas-streams-teardown)构建、运行和调试 Atlas Stream Processing(ASP)管道。需连接 MCP Server 并提供 Atlas API 凭据(apiClientId、apiClientSecret),所有操作需 Atlas 项目 ID,未知时可先调用 atlas-list-projects。

主要能力:discover 负责全部读取操作,包括列出/检查工作区、连接、处理器,诊断处理器健康状态,查看 PrivateLink 与 VPC 对等连接信息;build 负责创建,包括工作区(cloudProvider、region、tier 默认 SP10、includeSampleData)、连接(Kafka/Cluster/S3/Https/Kinesis/Lambda/SchemaRegistry/Sample)、处理器(pipeline 必须以 $source 开头,以 $merge/$emit 结尾,可配 dlq、autoStart)及项目级 PrivateLink;manage 负责启动、停止、修改处理器,更新工作区与连接,接受或拒绝 VPC 对等连接;teardown 负责删除处理器、连接、工作区及网络资源。

使用方式:典型流程为先列出工作区,创建工作区与连接,校验连接,调用 search-knowledge 验证字段名并参考官方示例仓库 https://github.com/mongodb/ASP_example,再创建处理器并启动。修改处理器前必须先停止;删除工作区前须先检查其连接与处理器数量并向用户确认。

限制:流处理管道不支持 $$NOW、$$ROOT、$$CURRENT;HTTPS 不能作为 $source;Kafka $source 必须含 topic;已部署处理器必须有终止阶段;Lambda 使用 $externalFunction 而非 $emit;$validate 的 validationAction 应为 dlq;单条管道只能有一个终止 sink,多目标需用链式处理器。AWS 连接需先注册 IAM 角色 ARN。ASP 无免费层,处理器运行期间按小时计费、按秒计算,停止后状态保留 45 天;原型可用 mongosh 的 sp.process() 免部署运行。不支持在工作区之间迁移处理器,也不支持 dry-run 模拟。删除工作区会永久移除全部连接与处理器。部分细节(如具体价格、完整区域映射表)暂未提供。