用途:该技能聚焦异步消息与事件模式,用于设计事件驱动架构,覆盖 Kafka、RabbitMQ、事件溯源、CQRS 与消息模式,并给出投递保证相关建议。
主要能力:支持发布订阅、工作队列、请求应答、死信队列等消息模式;提供事件溯源的事件存储、事件结构与投影思路;区分 CQRS 的命令侧与查询侧,并列出收益与权衡。内置参数校验,输入需包含 event_context,其中 use_case 可选 pub_sub、work_queue、event_sourcing、cqrs、saga,requirements 需给出吞吐、延迟、顺序、投递与保留期,producers 与 consumers 至少各一项。校验规则会在 exactly_once 时提示需幂等消费者,在 global 顺序时提示吞吐受限。输出包含 broker 选型与理由、拓扑(主题、分区、副本因子)、消息 schema 与版本、消费者配置(分组策略、错误处理、DLQ)。还提供重试配置、错误分类、熔断参数、日志 schema、指标定义与排障清单。
使用方式:通过 Skill("event-driven") 调用,按参数 schema 传入事件上下文。资料未提供具体安装命令或代码调用示例之外的运行环境要求。
适用场景:需要设计或评审消息中间件选型、分区与副本、投递语义、重试与死信、事件溯源与 CQRS 读写分离的工程场景。
限制:资料未提供实际性能基准的验证方法、价格或平台支持信息;exactly_once 与全局顺序存在明确约束提示;RabbitMQ 与 SQS 无原生重放,SQS 保留期最多 14 天;事件溯源与 CQRS 会带来最终一致性、复杂度、事件版本与调试挑战。