ClawHub

Event Orchestrator

Other

基于事件驱动架构的多技能编排器，支持事件发布订阅、中间件链处理及状态机管理，实现复杂业务流程协同。

Install

openclaw skills install event-orchestrator

event-orchestrator 技能

描述

基于事件驱动架构 (EDA) 的技能编排器，支持多技能协同、事件订阅发布、中间件链处理。

版本

v0.1.0

作者

王的奴隶 · 严谨专业版

创建日期

2026-04-10

功能

  1. 事件总线: 统一的事件发布/订阅机制，支持事件验证和历史记录
  2. 中间件链: 支持日志、验证、重试、速率限制等中间件
  3. 状态管理: 编排任务状态机（pending → running → completed/failed）
  4. 技能编排: 协调多个技能按事件触发执行

使用场景

  • 多技能协同工作流
  • 事件驱动的任务触发
  • 技能执行日志追踪
  • 错误处理与重试
  • 复杂业务流程编排

命令

# 发布事件
openclaw event publish <event-name> [payload]

# 订阅事件
openclaw event subscribe <event-name> <handler>

# 查看事件历史
openclaw event history [limit]

# 查看编排状态
openclaw orchestrator status

快速开始

1. 安装

cd ~/.openclaw/skills/event-orchestrator
npm install

2. 基本使用

const { EventOrchestrator } = require('./src/index');

const orchestrator = new EventOrchestrator();

// 订阅事件
orchestrator.subscribe('skill.completed', (event) => {
  console.log('技能完成:', event.payload.skillId);
});

// 发布事件
await orchestrator.publish('skill.completed', {
  skillId: 'my-skill',
  result: { success: true }
});

3. 添加中间件

const { LoggingMiddleware, RetryMiddleware } = require('./src/index');

orchestrator.useMiddleware(new LoggingMiddleware());
orchestrator.useMiddleware(new RetryMiddleware({ maxRetries: 3 }));

设计模式

  • 事件驱动架构 (EDA): 解耦事件生产者和消费者
  • Middleware 链模式: 灵活的事件处理管道
  • 状态机模式: 严格的状态转换控制

六维评估

维度得分说明
T (技术深度)0.75测试覆盖率 94.14%
C (认知增强)0.65提供编排可视化
O (编排能力)0.80核心优势
E (进化能力)0.70支持自优化触发器
M (市场验证)0.40待 ClawHub 上架
U (用户体验)0.70CLI + 状态查询
平均0.67B 级

测试

npm test
# 73 个测试用例，覆盖率 94.14%

文件结构

event-orchestrator/
├── SKILL.md           # 技能说明
├── README.md          # 详细文档
├── package.json       # 项目配置
├── src/
│   ├── index.js       # 主入口
│   ├── event-bus.js   # 事件总线
│   ├── middleware-chain.js  # 中间件链
│   └── state-machine.js     # 状态机
├── tests/             # 测试文件
└── docs/              # 文档

ClawHub 上架状态

  • 准备上架材料
  • 提交审核
  • 上架完成

许可证

MIT