AI Agent Bus

多租户业务流程自动化平台，具有实时工作流执行、人工参与操作和AI驱动代理生成功能。

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

该项目包含的内容

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

• 实时工作流注册表：实时执行状态，带有视觉节点更新
• 人工参与节点：作为首要工作流参与者的人类，带有智能通知
• 自动生成的AI代理：从连接的MCP服务器自动创建专业代理
• 多租户代理存储：基于组织和用户的代理管理，采用S3/IAM安全措施
• 集成发现：连接应用程序并自动填充工作流能力
• 可视化画布：拖放界面用于设计混合人机自动化过程

当前功能：

• 多租户代理系统：基于组织和用户的AI代理，采用S3路径为基础的安全措施
• 实时工作流执行：通过事件流实现实时节点状态更新
• 人工工作流节点：作为工作流参与者的人员，带有可定制的通知偏好设置
• MCP集成发现：从连接的MCP服务器自动填充工作流节点
• 专业代理自动生成：根据MCP服务器的能力创建专门的代理
• 可视化画布设计：拖放界面用于混合人机自动化过程
• 版本化代理存储：完整的CRUD操作，采用S3版本控制和DynamoDB元数据

架构

核心组件

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

数据架构

代理存储：

S3: agents/
├── public/system/              # 从.claude/agents引导的代理
├── public/community/           # 社区共享的代理
├── organizations/{orgId}/
│   ├── shared/                # 组织范围内的代理
│   ├── generated/{mcpId}/     # 从MCP服务器自动生成
│   └── users/{userId}/        # 组织内用户私有代理
└── users/{userId}/            # 单个用户代理

多租户上下文：

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

技术栈

• 前端：SolidJS与TypeScript
• 后端：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

# 启动仪表板UI
cd dashboard-ui
npm install
npm run dev

# 启动MCP服务器（在单独的终端中）
cd ../mcp-server
npm install
npm start

2. 尝试界面

访问http://localhost:5173：

1. 可视化画布：使用拖放方式设计工作流
2. 商业模板：预构建的过程流
3. 聊天助手：获取AI建议（目前是模拟响应）
4. 过程库：浏览和管理工作流

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

# 部署MCP服务器的AWS组件
export WS=small/kv_store ENV=dev
npm run tf:init
npm run tf:apply

使用案例

人工参与操作

财务审批工作流：

API请求 → 数据验证 → 人工审批 → 支付处理 → 通知
    🤖             🤖               👤                🤖               🤖

• 财务经理收到超过10,000美元支付的Slack通知
• 移动友好的全上下文审批
• 如果两小时内没有响应，则自动升级

客户入职审查：

表单提交 → 数据丰富 → 合规检查 → 手动审查 → 账户创建
      🤖               🤖               🤖             👤              🤖

• 合规官审查标记的应用程序
• 按个人定制的通知偏好设置
• 实时工作流状态对所有利益相关者可见

自动生成集成工作流

连接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了解开发指南。

许可证

MIT许可证 - 详情见LICENSE。