Aws AI Agent Bus

AI代理巴士

支持实时工作流执行、人机交互操作以及AI驱动的代理生成的多租户业务流程自动化平台。

一个智能工作流平台，它将自动化流程与人工决策点相结合，具备通过MCP服务器进行实时执行监控和自动集成发现的功能。

此项目包含的内容

一个全面的工作流自动化平台：

• 实时工作流注册表实时执行状态，支持可视化节点更新
• 人参与的节点人们作为一流的流程参与者，享受智能通知服务
• 自动生成的AI代理从连接的MCP服务器自动创建专业代理
• 多租户代理存储基于S3/IAM安全性的组织和用户范围代理管理
• 集成发现连接应用程序并自动填充工作流功能
• 视觉画布用于设计混合人工/自动化流程的拖放界面

当前能力：

• 多租户代理系统基于S3路径的安全机制下的组织级和用户级AI代理
• 实时工作流执行通过事件流实现实时节点状态更新
• 人类工作流节点作为工作流参与者，人们可以自定义通知偏好设置
• MCP（多渠道计划/管理控制协议等，具体含义根据上下文确定）集成发现从连接的MCP服务器自动填充工作流节点
• 专业代理自动生成功能利用MCP服务器功能创建专用代理
• 视觉画布设计混合人机自动化流程的拖放式界面
• 带版本控制的代理存储支持带有S3版本控制和DynamoDB元数据的完整CRUD操作

建筑学

核心组件

• 仪表盘用户界面 (SolidJS)：带实时执行监控的可视化工作流设计器
• 仪表板服务器 (Node.js)：基于WebSocket的发布/订阅后端，支持多租户代理管理
• MCP 服务器 (Node.js)：提供AI上下文和工具执行的模型上下文协议服务器
• 内部MCP注册表带有分支支持的连接MCP服务器的版本化注册表
• 多租户代理存储基于S3/DynamoDB的代理系统，采用路径基础的安全机制
• 实时工作流引擎使用事件流进行实时执行状态管理
• 人工通知系统针对人工工作流节点的多渠道通知（Slack、电子邮件、短信）

数据架构

代理存储:

S3: agents/
├── public/system/              # Bootstrap agents from .claude/agents
├── public/community/           # Community-shared agents
├── organizations/{orgId}/
│   ├── shared/                # Org-wide agents
│   ├── generated/{mcpId}/     # Auto-generated from MCP servers
│   └── users/{userId}/        # User private agents within org
└── users/{userId}/            # Individual user agents

多租户上下文：

• 组织多用户，资源共享，管理员控制
• 用户个人工作区、私人代理、个人集成
• MCP 租户隔离每个用户/组织都有独立的MCP服务器上下文

技术栈

• 前端：使用TypeScript的SolidJS
• 后端：基于Node.js的MCP服务器，带有stdio/HTTP接口
• 基础设施：AWS（DynamoDB、S3、EventBridge、Step Functions）
• AI集成：通过MCP协议接入OpenAI/Claude

快速入门

1. 克隆并设置

git clone https://github.com/your-org/aws-ai-agent-bus
cd aws-ai-agent-bus

# Start the dashboard UI
cd dashboard-ui
npm install
npm run dev

# Start the MCP server (separate terminal)
cd ../mcp-server
npm install
npm start

2. 试用界面

访问 http://localhost:5173：

1. 视觉画布设计工作流，使用拖放功能
2. 商务模板预构建的流程
3. 聊天助手获取AI建议（当前为模拟回复）
4. 过程库浏览和管理您的工作流程

3. 部署基础设施（可选）

# Deploy AWS components for MCP server
export WS=small/kv_store ENV=dev
npm run tf:init
npm run tf:apply

用例

人机交互式操作

财务审批工作流程：

API Request → Data Validation → Human Approval → Payment Processing → Notification
    🤖             🤖               👤                🤖               🤖

• 财务经理收到Slack通知，关于超过10,000美元的付款
• 支持移动设备的友好审批，提供完整上下文
• 若2小时内无响应，则自动升级处理

客户入职审查：

Form Submission → Data Enrichment → Compliance Check → Manual Review → Account Creation
      🤖               🤖               🤖             👤              🤖

• 合规官审查被标记的应用程序
• 个性化通知偏好设置（针对每个人）
• 所有利益相关者均可实时查看工作流程状态

自动生成的集成工作流

连接Stripe → 立即获取专业代理服务：

1. 用户将Stripe MCP服务器连接到租户上下文
2. 系统自动生成： stripe-payments-expert， stripe-webhooks-specialist， stripe-subscriptions-manager
3. 工作流节点填充了Stripe的功能
4. 预构建的支付处理工作流现已可用

GitHub 集成 → 开发工作流程：

1. 连接GitHub MCP服务器
2. 自动生成： github-pr-manager， github-deployment-specialist， github-issue-tracker
3. 包含人工审核环节的CI/CD工作流模板
4. 当MCP服务器版本发生变化时，自动代理更新

多租户代理管理

组织层面的共享:

• acme-corp 创建自定义（内容/设置/选项等） salesforce-lead-qualifier 代理
• 对所有人开放/可用 acme-corp 在工作流设计器中的用户
• 带有变更日志的版本控制

个人代理开发:

• 个人用户创建专属的私人智能体
• 为个人定制服务的分叉组织代理
• 带实时预览和模板的Markdown编辑器

项目状态

✅ 已实施：

• 多租户代理存储基于路径的安全性和版本控制的S3/DynamoDB
• 代理CRUD操作与AWS SDK集成，实现完整的创建、读取、更新、删除功能
• S3 安全架构支持用户/组织/公共代理隔离的IAM策略
• 封面解析（或前置内容解析）使用YAML元数据提取定义Markdown代理
• 版本管理代理更新的自动版本控制，支持变更日志

🚧 开发中：

• 功能标志认证开发用户注入（user-demo-123/acme) 用于立即测试
• WebSocket 代理操作用于实时代理管理的发布/订阅消息处理程序
• 内部MCP注册表支持分支和租户上下文的版本化注册表
• 自动代理生成从连接的MCP服务器功能中创建专业代理
• 实时工作流执行通过事件流实现节点状态的实时更新
• 人工工作流节点作为工作流参与者，人们通过智能通知进行互动

🎯 计划：

• Markdown智能体编辑器带模板、实时预览和语法高亮的通用编辑器
• MCP服务器发现与mcpservers.org集成以实现应用程序连接工作流
• 移动通知多通道人工节点通知（Slack、短信、电子邮件）
• 生产认证AWS Cognito 与基于 JWT 的用户上下文集成
• 工作流市场已发布的工作流共享与发现

做出贡献

请看 CLAUDE.md（文件名，可翻译为“克劳德文档”或保持原样，具体取决于上下文和用途） 用于开发指南和设置说明。

文档

• CLAUDE.md - 完整的代码库概览和架构
• mcp-rust/ - MCP服务器文档
• .claude/ - 代理编排系统
• infra/ - Terraform 基础设施模块

做出贡献

看 CLAUDE.md（可译为“克劳德文档”或根据上下文具体命名，但通常“md”表示Markdown格式的文件，所以也可直接保留为“CLAUDE（Markdown文件）”） 作为开发指南。

许可证

MIT 许可证 - 详见 许可证 详情如下。