文档索引
版本： 1.0.0 最后更新： 2025-10-06
📚 文档目录
1. 架构概述
推荐阅读顺序：第 1 篇
全面介绍 Weather Station 的整体架构、核心概念和设计模式。
主要内容：
Weather Syntax、DAG、Flow、Cycle、Node 核心概念
系统架构和分层设计
关键组件介绍
技术栈和设计模式
数据流概览
适合人群： 所有开发者、架构师、新成员
2. 消息队列详解
推荐阅读顺序：第 2 篇
深入讲解基于 RabbitMQ 的信号传递机制。
主要内容：
RabbitMQ Topic Exchange 架构
Routing Key 设计规范
Queue 命名和绑定
信号传递完整流程
Handle 匹配机制
特殊场景（聚合、通配符、停止信号）
实战示例
适合人群： 后端开发者、系统集成工程师
3. Redis 状态管理
推荐阅读顺序：第 3 篇
详细说明 Redis 状态存储的设计和使用。
主要内容：
Redis 架构和数据结构
Key 命名规范
Flow、Cycle、Node 状态管理
Worker 管理和心跳机制
状态查询接口
数据清理策略
适合人群： 后端开发者、运维工程师
4. 节点执行流程
推荐阅读顺序：第 4 篇
完整讲解节点从创建到清理的生命周期。
主要内容：
节点生命周期和状态转换
节点创建和实例化
信号等待机制
执行流程（数据处理、条件判断、交易执行）
信号发送机制
异常处理和资源清理
开发新节点指南
适合人群： 节点开发者、业务逻辑实现者
5. Flow 调度机制
推荐阅读顺序：第 5 篇
深入解析 FlowScheduler 的调度逻辑和 DAG 编排。
主要内容：
FlowScheduler 架构和职责
Flow 注册流程
DAG 分析（连通分量、环检测、入口节点）
周期调度循环
Cycle 执行和节点编排
状态管理和查询
日志系统
适合人群： 系统架构师、调度逻辑开发者
🚀 快速导航
按角色查看
新成员入门
节点开发者
节点执行流程 - 开发新节点
消息队列详解 - 理解信号传递
Redis 状态管理 - 使用状态存储
系统架构师
架构概述 - 整体架构
Flow 调度机制 - 调度设计
Redis 状态管理 - 状态设计
运维工程师
Redis 状态管理 - 状态存储运维
Flow 调度机制 - 调度监控
消息队列详解 - RabbitMQ 运维
按主题查看
通信机制
状态管理
编排调度
节点开发
📖 阅读建议
完整学习路径（推荐）
适合第一次接触 Weather Station 的开发者。
1. 架构概述 (30 分钟)
↓
2. 消息队列详解 (40 分钟)
↓
3. Redis 状态管理 (30 分钟)
↓
4. 节点执行流程 (40 分钟)
↓
5. Flow 调度机制 (40 分钟)总时长： 约 3 小时
快速上手路径
适合需要快速开始开发的人员。
1. 架构概述 - 核心概念 (15 分钟)
↓
2. 节点执行流程 - 开发新节点 (20 分钟)
↓
3. 消息队列详解 - 实战示例 (15 分钟)总时长： 约 50 分钟
问题驱动路径
根据具体问题快速定位文档。
如何开发新节点？
信号如何传递？
如何查询节点状态？
Flow 如何调度？
如何处理聚合数据？
DAG 如何分析？
节点如何停止？
Redis Key 设计？
📦 节点详情文档
Weather Station 提供 12+ 种节点类型，每个节点都有独立的详细文档页面。
🔗 节点文档索引
按分类浏览：
数据输入节点
Binance Price Node - 获取 Binance 交易所 K 线数据
X Listener Node - 监听 Twitter/X 平台动态
Dataset Input Node - 从 Google Sheets 读取数据
AI 处理节点
AI Model Node - 调用 LLM 进行智能分析和决策
Code Node - 执行自定义 Python 代码
交易执行节点
Vault 管理节点
Vault Node - 查询和管理 Vault 信息
数据输出节点
Dataset Output Node - 写入数据到 Google Sheets
通知节点
Telegram Sender Node - 发送 Telegram 通知
📖 查看完整节点列表
访问 节点文档索引 查看所有节点的详细文档，包括：
完整的参数说明
输入输出格式
执行流程图
实际使用示例
错误处理指南
性能优化建议
🔧 相关资源
代码位置
调度器:
tradingflow/station/flow/scheduler.pyFlow 解析器:
tradingflow/station/flow/flow_parser.py节点基类:
tradingflow/station/nodes/node_base.py节点执行器:
tradingflow/station/core/node_executor.py节点实现:
tradingflow/station/nodes/*_node.py消息队列:
tradingflow/depot/python/mq/状态存储:
tradingflow/station/common/state_store.py任务管理:
tradingflow/station/common/node_task_manager.py
API 文档
Weather Control API:
/api/v1/flow/*Worker API:
/execute节点列表 API:
/api/v1/nodes/types
配置文件
环境变量:
.envRabbitMQ 配置:
CONFIG.RABBITMQ_URLRedis 配置:
CONFIG.REDIS_URL
📝 文档更新日志
v1.0.0 (2025-10-06)
✅ 创建完整的 Weather Station 开发者文档
✅ 架构概述（17,500 字）
✅ 消息队列详解（22,000 字）
✅ Redis 状态管理（17,500 字）
✅ 节点执行流程（27,500 字）
✅ Flow 调度机制（24,500 字）
✅ 主文档索引（导航优化）
✅ 链接到已有节点详情文档（12+ 节点）
✅ 数据输入节点（3 个）
✅ AI 处理节点（2 个）
✅ 交易执行节点（3 个）
✅ Vault 管理节点（1 个）
✅ 数据输出节点（1 个）
✅ 通知节点（1 个）
🤝 贡献指南
如果您发现文档中的错误或有改进建议，请：
创建 Issue 描述问题
提交 PR 修复文档
联系文档维护者
维护者： TradingFlow 开发团队 联系方式： 通过项目 Issue 反馈 最后更新： 2025-10-06
Last updated