Agent Cluster

👤 wangm-a3 📦 v3.0.4 ⭐ 4.3 ⬇️ 889 下载
🤖 AI-Agent 免费 🔑 需 API Key

📖 技能介绍


name: foreign-trade-silicon-army description: 亚马逊外贸B2B多CMS Agent协作系统。支持Shopify/WooCommerce/Magento三大平台,A2A架构协调库存/采购/财务/物流四大专家Agent,三层安全网保障审批合规。即装即用,零配置开箱。 version: 3.0.4 triggers: - "外贸" - "CMS" - "Shopify" - "WooCommerce" - "Magento" - "库存" - "采购" - "Amazon" - "B2B" tags: - agent - a2a - cms - ecommerce - b2b - foreign-trade - multi-agent requires: python_packages: - httpx - pyyaml - fastapi - uvicorn env: - SYSTEM_MODE - SAP_BASE_URL - SAP_API_KEY - YONYOU_BASE_URL - YONYOU_APPKEY - KINGDEE_BASE_URL - ANTHROPIC_API_KEY - DEEPSEEK_API_KEY homepage: https://github.com/WangM-A3/agent-cluster authors: - WangM-A3 pricing: free,pro=9.9,enterprise


产业互联网硅基军团 v2.0

企业级Multi-Agent智能体集群系统,基于1+N架构(1个幕僚长+20个专业Agent),参考OpenClaw Main Agent、腾讯ADP Router设计。v2.0全面升级:真实ERP API接入、协作流程细化、错误处理体系。

核心能力

v2.0三大升级

1. 真实API接入层(api_integration/) - 多ERP适配器:SAP S/4HANA、用友U8/NC/YonBIP、金蝶K3 Cloud/EAS、通用REST - 断路器模式(Circuit Breaker)+ 故障自动降级 - 健康检查轮询(10s间隔,自动摘除异常节点) - 演示模式保留(MockDataGenerator,variance=0.1随机波动)

2. 跨Agent协作细化(collaboration/) - 细粒度任务协议(TaskMessage):依赖声明、优先级、TTL - 状态同步(SharedStateManager):TTL+pub/sub通知机制 - 全链路追踪(CollaborationTracker):trace_id/span_id + Mermaid时序图可视化

3. 错误处理与状态管理(error_handling/) - 7状态任务状态机:pending→running→success/failed/retry/timeout/cancelled - 10类异常自动分类:VALIDATION/NETWORK/TIMEOUT/AUTH/RESOURCE/NOT_FOUND等 - 5种重试策略:FIXED/EXPONENTIAL/FIBONACCI/JITTER/ADAPTIVE - 敏感信息脱敏 + SOC2合规审计日志

系统架构

本技能来自小葱技能站7w4.net。

用户请求 → Orchestrator(意图识别→任务拆解→智能体调度)
    ↓
20个专业Agent:采购/生产/销售/财务/运营/战略/研发/人力/合规
    ↓
API Integration Layer(v2.0新增)
  ├─ SAP/用友/金蝶适配器(真实ERP)
  └─ 断路器+健康检查+Mock降级

目录结构

agent-cluster/
├── orchestrator.py              # 指挥智能体(核心调度器)
├── api_integration/              # v2.0新增:真实API接入层
│   ├── api_adapter.py           # 多ERP适配器(SAP/用友/金蝶)
│   ├── api_config.py            # 配置化管理
│   ├── api_health.py            # 健康检查+断路器
│   └── mock_data.py             # 模拟数据(开发/演示)
├── collaboration/                # v2.0新增:跨Agent协作
│   ├── task_protocol.py         # 细粒度任务协议
│   ├── state_sync.py            # 状态同步+TTL+pub/sub
│   ├── trace_tracker.py         # 全链路追踪+Mermaid
│   └── workflow_engine.py       # 混合执行引擎
├── error_handling/              # v2.0新增:错误处理
│   ├── task_state_machine.py    # 7状态任务状态机
│   ├── exception_middleware.py  # 统一异常处理
│   ├── retry_policy.py          # 5种重试策略
│   └── operation_log.py         # 操作日志+脱敏+合规
├── specialists/                 # 专业智能体
│   ├── inventory_agent.py      # 库存智能体
│   ├── logistics_agent.py       # 物流智能体
│   ├── procurement_agent.py     # 采购智能体
│   ├── finance_agent.py         # 财务智能体
│   └── doc_agent.py            # 工艺文档智能体
├── mcp_servers/                 # MCP协议封装
│   ├── erp_server.py           # ERP系统接口
│   ├── wms_server.py           # WMS仓库管理接口
│   └── srm_server.py           # SRM供应商管理接口
├── safety/                      # 安全围栏
│   ├── permission_manager.py    # RBAC权限管理
│   ├── audit_logger.py          # 全链路审计日志
│   └── human_loop.py            # 人机回环审批
└── config/                      # 配置文件
    ├── agents.yaml             # 智能体定义
    ├── workflows.yaml          # 工作流配置
    └── permissions.yaml        # 权限矩阵

快速开始

环境要求

  • Python 3.10+
  • 依赖:pip install pyyaml fastapi uvicorn httpx aiofiles

运行

cd agent-cluster
python orchestrator.py

配置(生产模式)

export SYSTEM_MODE=production
export SAP_BASE_URL=https://sap.example.com
export SAP_API_KEY=sk-xxx
export YONYOU_BASE_URL=https://yonyou.example.com

触发词

塑化报价 | 塑料原料采购 | 库存管理 | 生产排产 | 客户跟进 | 供应商比价 | B2B运营 | 工厂管理 | ERP集成 | 智能客服 | 行业KPI | 成本核算 | 硅基军团 | 工业Agent | 制造业AI | 产业互联网

标签

制造业AI, 产业互联网, Multi-Agent, ERP集成, 智能排产, 供应商管理, 报价系统, 智能工厂, AI运营, 企业数字化

分类

效率工具

版本

v2.0.0 - 三大升级:真实API接入层、协作流程细化、错误处理与状态管理

🤖 AI 评测

这个Skill功能很丰富,支持多个电商平台和多ERP系统接入,自动化程度较高,架构设计比较专业。优点是系统完整、配置灵活、支持多Agent协作;缺点是上手配置复杂,有些功能可能还不完善,对新手不太友好。适合有一定技术基础、需要复杂自动化流程的外贸企业使用。

📊 多维度评分

适应性4.4
规范性3.7
有效性4.6
可靠性4.6
可信度4.8

📁 包含文件 (144 个)

📄 30-expansion/30-agents-design.md 50.7 KB
📄 30-expansion/IMPLEMENTATION_PLAN.md 13.4 KB
📄 30-expansion/agent_protocol.md 15.7 KB
📄 30-expansion/agent_registry.yaml 18.4 KB
📄 PRICING.md 1.1 KB
📄 README.md 18.1 KB
📄 SECURITY.md 1.3 KB
📄 SKILL.md 5.4 KB
📄 SOUL.md 3.8 KB
📄 __init__.py 406 B
📄 _meta.json 132 B
📄 api_integration/__init__.py 936 B
📄 api_integration/api_adapter.py 21 KB
📄 api_integration/api_config.py 9 KB
📄 api_integration/api_health.py 8.4 KB
📄 api_integration/deepseek_integration.md 11.6 KB
📄 api_integration/mock_data.py 13.8 KB
📄 cms-executor/README.md 12.3 KB
📄 cms-executor/connectors/__init__.py 457 B
📄 cms-executor/connectors/amazon_connector.py 25.8 KB
📄 cms-executor/connectors/base_connector.py 5.5 KB
📄 cms-executor/connectors/shopify_connector.py 25.3 KB
📄 cms-executor/connectors/wordpress_connector.py 8.4 KB
📄 cms-executor/engine/__init__.py 168 B
📄 cms-executor/engine/approval.py 9 KB
📄 cms-executor/engine/rollback.py 10.4 KB
📄 cms-executor/tests/test_cms_executor.py 12.9 KB
📄 cms-executor/tests/test_connectors.py 30.9 KB
📄 cms_approvals/04cf553c-e0c9-4732-870b-83f96e443b52.json 533 B
📄 cms_approvals/1c9e92a7-46f3-4a6d-a0d9-59c60ff0fee1.json 692 B
📄 cms_approvals/265648cd-fd95-4b2c-a1e7-4051cbe771cc.json 569 B
📄 cms_approvals/2c363c59-d353-4e3d-a2b6-aa4e321fa278.json 569 B
📄 cms_approvals/31ff6cde-b148-47d1-980f-6953a7e1fe98.json 569 B
📄 cms_approvals/326cf306-f324-478f-9abb-952657fd8a58.json 569 B
📄 cms_approvals/380f9c96-b301-4cbc-9a61-d508323241bf.json 717 B
📄 cms_approvals/5709cd14-a912-4bb9-a877-e8fd3c029ec2.json 569 B
📄 cms_approvals/a2941003-ecb3-41bc-8522-088b9bae1f41.json 701 B
📄 cms_approvals/b260ecbf-649d-4da4-b064-3093114d7ca7.json 704 B
📄 cms_approvals/d55ab274-327d-4090-985d-8c8c4d795c5c.json 683 B
📄 cms_approvals/de294f4f-a55b-43b2-bbae-3840b81f2e85.json 674 B
📄 cms_approvals/eb03a9c1-ecb6-4007-ada6-aaefd49ef4ac.json 533 B
📄 cms_executor/ARCHITECTURE.md 14.2 KB
📄 cms_executor/__init__.py 2.4 KB
📄 cms_executor/agent_integration.py 25.8 KB
📄 cms_executor/connectors/__init__.py 891 B
📄 cms_executor/connectors/amazon_connector.py 14.4 KB
📄 cms_executor/connectors/base_connector.py 26.7 KB
📄 cms_executor/connectors/magento_connector.py 16.3 KB
📄 cms_executor/connectors/shopify_connector.py 15.8 KB
📄 cms_executor/connectors/wordpress_connector.py 10.8 KB
📄 cms_executor/engine/__init__.py 642 B
📄 cms_executor/engine/approval.py 11.5 KB
📄 cms_executor/engine/audit.py 17.5 KB
📄 cms_executor/engine/executor.py 18.9 KB
📄 cms_executor/engine/rollback.py 14.9 KB
📄 cms_executor/tests/__init__.py 224 B
📄 cms_executor/tests/test_agent_integration.py 14 KB
📄 cms_executor/tests/test_approval.py 8.2 KB
📄 cms_executor/tests/test_base_connector.py 11.7 KB
📄 cms_executor/tests/test_connectors.py 14.5 KB
📄 cms_executor/tests/test_executor.py 13 KB
📄 cms_executor/tests/test_rollback.py 9.1 KB
📄 collaboration/__init__.py 1 KB
📄 collaboration/state_sync.py 10.7 KB
📄 collaboration/task_protocol.py 15 KB
📄 collaboration/tests/__init__.py 22 KB
📄 collaboration/trace_tracker.py 11.5 KB
📄 collaboration/workflow_engine.py 12.4 KB
📄 config/agents.yaml 3 KB
📄 config/engines.yaml 7.2 KB
📄 config/permissions.yaml 3.6 KB
📄 config/workflows.yaml 3.7 KB
📄 error_handling/__init__.py 1.2 KB
📄 error_handling/exception_middleware.py 11.1 KB
📄 error_handling/operation_log.py 15.5 KB
📄 error_handling/retry_policy.py 10.6 KB
📄 error_handling/task_state_machine.py 13.3 KB
📄 execution/__init__.py 1.5 KB
📄 execution/circuit_breaker.py 39.8 KB
📄 execution/claude_ma_engine.py 8.7 KB
📄 execution/deepseek_engine.py 37 KB
📄 execution/engine_base.py 22.6 KB
📄 execution/engine_router.py 37 KB
📄 execution/gpt6_engine.py 27.2 KB
📄 execution/local_engine.py 11.7 KB
📄 execution/tests/test_auth_profile.py 18.8 KB
📄 execution/tests/test_circuit_breaker.py 28.8 KB
📄 execution/tests/test_integration.py 23.5 KB
📄 intent/__init__.py 535 B
📄 intent/adjuster.py 19 KB
📄 intent/decomposer.py 21.9 KB
📄 intent/recognizer.py 30 KB
📄 intent/tests.py 28.4 KB
📄 mcp_servers/erp_server.py 21.7 KB
📄 mcp_servers/srm_server.py 16.9 KB
📄 mcp_servers/wms_server.py 12.7 KB
📄 memory/ARCHITECTURE.md 10.5 KB
📄 memory/P0-OPTIMIZATION.md 5.7 KB
📄 memory/__init__.py 1.1 KB
📄 memory/demo.py 8.2 KB
📄 memory/fts_search.py 23.1 KB
📄 memory/immediate_skill_hook.py 27.1 KB
📄 memory/memory_api.py 10.4 KB
📄 memory/memory_core.py 9.7 KB
📄 memory/memory_index.py 10.7 KB
📄 memory/memory_integration.py 16.9 KB
📄 memory/memory_router.py 15.4 KB
📄 memory/persistent_store.py 20.2 KB
📄 memory/private_memory.py 10.4 KB
📄 memory/session_sync.py 18.5 KB
📄 memory/shared_knowledge.py 10.8 KB
📄 memory/tests/test_fts_search.py 15.1 KB
📄 memory/tests/test_immediate_skill_hook.py 14.8 KB
📄 model_health.json 2.7 KB
📄 orchestrator.py 41.2 KB
📄 package.json 991 B
📄 personas/__init__.py 465 B
📄 personas/amazon_operator.py 3.7 KB
📄 personas/base.py 6.2 KB
📄 personas/chiefofstaff.py 3.2 KB
📄 personas/content_creator.py 3.6 KB
📄 personas/geo_analyst.py 3.3 KB
📄 personas/persona_manager.py 10.6 KB
📄 quality/__init__.py 1.1 KB
📄 quality/gate.py 11.5 KB
📄 quality/integration.py 4.9 KB
📄 quality/models.py 10 KB
📄 quality/retry_loop.py 18.4 KB
📄 quality/reviewer.py 11.7 KB
📄 quality/scorer.py 24 KB
📄 quality/tests.py 21 KB
📄 safety/audit_logger.py 21.8 KB
📄 safety/demo_validator.py 6.1 KB
📄 safety/human_loop.py 21.9 KB
📄 safety/permission_manager.py 19.2 KB
📄 specialists/doc_agent.py 19.6 KB
📄 specialists/finance_agent.py 19.9 KB
📄 specialists/inventory_agent.py 17.6 KB
📄 specialists/logistics_agent.py 19.6 KB
📄 specialists/procurement_agent.py 16.2 KB
📄 tests/deepseek_test_report.md 6.8 KB
📄 tests/test_deepseek_engine.py 31.2 KB
📄 tests/test_execution_engines.py 25.7 KB
📄 tests/test_gpt6_engine.py 13.4 KB