基于 Redis Streams 实现多消费者组事件总线,支持 5 个内置消费者组 (ops-hub/leader-os-base/leader-vision-algo/leader-market/boss), 提供 publish/read_new/ack 核心接口及 task_done/task_failed/version_pass/alert 语义快捷方法。 依赖 fakeredis 实现无服务器测试,pyproject.toml 新增 redis>=5.0 依赖。 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>