SuperAPI AI 工具集

atlas-stream-processing

数据与分析

查看项目

更新于 10-16 05:46

技能介绍

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

主要能力:discover 负责全部读取操作,如 list-workspaces、inspect-workspace、list-connections、inspect-connection、list-processors、inspect-processor、diagnose-processor、get-networking;build 负责创建,涵盖 workspace(cloudProvider、region、tier 默认 SP10、includeSampleData)、connection(Kafka/Cluster/S3/Https/Kinesis/Lambda/SchemaRegistry/Sample 等类型)、processor(pipeline 须以 $source 开头,以 $merge/$emit 结束)以及 privatelink;manage 负责启动、停止、修改处理器与更新工作区/连接、管理 VPC 对等;teardown 负责删除处理器、连接、工作区及网络资源。

使用方式:按“发现现有资源→创建工作区→创建连接→校验连接→构建处理器→启动”的顺序操作;修改处理器前必须先停止;删除工作区前须先 inspect 并向用户确认。

限制:无免费层,处理器运行期间按秒计费;停止后状态保留 45 天;不支持在工作区之间迁移处理器;不支持 dry-run/模拟;networking 配置创建后不可修改。流处理中不可使用 $$NOW、$$ROOT、$$CURRENT 等;Kafka $source 必须包含 topic;$emit 到 S3 使用 path 而非 prefix;$emit 到 Kinesis 必须包含 partitionKey。部分细节与完整配置模式暂未在资料中提供。