MarcoFPO/n8n-Workflows

GitHub: MarcoFPO/n8n-Workflows

一个基于事件驱动架构的交易智能系统,整合了 AI 预测、实时数据分析和微服务编排能力,适用于金融量化场景。

Stars: 0 | Forks: 0

<<<<<<< HEAD # 🚀 事件驱动交易智能系统 v8.0 合并版 **状态**: ✅ 生产就绪 - 前端表格已修复 **部署**: 10.1.1.174 (LXC 174) **性能**: 通过事件驱动架构实现 95% 优化 **最后更新**: 2025年8月24日 ## 🔧 **当前修复 v8.0:** - ✅ **AI预测表格** - 功能完全正常 - ✅ **目标-实际对比表格** - 功能完全正常 - ✅ **CSV转JSON解析** - 后端集成已修复 - ✅ **菜单统一** - 相同的设计和行为 - ✅ **4个时间框架同步** - 两个菜单中的1W, 1M, 3M, 1Y ======= # 📚 事件驱动交易智能系统 v6.0.0 **状态**: ✅ 整洁架构 - 全面合并 **部署**: 10.1.1.174 (LXC 174) **性能**: 完整的系统重构和文档合并 **最后更新**: 2025年8月23日 (主要版本 v6.0.0) ## 🎯 **主要版本 v6.0.0 亮点** # 生产系统: 事件驱动的交易智能系统,包含 **9个微服务**、PostgreSQL 事件存储、Redis 事件缓存以及带有结构化 CSV 数据集成的优化 GUI。 ### 🏗️ **实现大规模合并:** - **文档**: 150多个混乱的 MD 文件 → 10个结构化文档 - **代码清理**: 删除了449个过时文件 (-121,477 行) - **架构**: 整洁、可维护、零技术债务 - **专业文档**: `/documentation/` 中的完整技术文档 ### 📚 **新的文档结构:** | 文档 | 内容 | 状态 | |----------|---------|--------| | 📋 [需求文档](documentation/REQUIREMENTS.md) | 40多项功能/非功能需求 | ✅ 完成 | | 🎯 [系统概览](documentation/SYSTEM_OVERVIEW.md) | 架构图及服务交互 | ✅ 完成 | | 🏗️ [HLD.md](documentation/HLD.md) | 高层设计及服务架构 | ✅ 完成 | | 🔧 [LLD.md](documentation/LLD.md) | 底层实现细节 | ✅ 完成 | | 📡 [通信文档](documentation/COMMUNICATION.md) | API 端点及事件流 | ✅ 完成 | | 🔗 [资源文档](documentation/RESOURCES.md) | 端口、数据库、配置 | ✅ 完成 | | 📦 [模块文档](documentation/MODULES.md) | 所有11个服务和函数 | ✅ 完成 | | 🧪 [测试文档](documentation/TESTING.md) | 综合测试框架 | ✅ 完成 | <<<<<<< HEAD ## 🏗️ **服务架构 (11个服务)** ### **核心服务:** # | 服务 | 端口 | 状态 | 描述 | |---------------------------------|------|------------|-------------------------------------------| | 🧠 **智能核心** | 8001 | ✅ 运行中 | AI 分析与 ML 引擎 | | 📡 **经纪商网关** | 8012 | ✅ 运行中 | 交易 API 集成 | | 🎨 **前端服务** | 8080 | ✅ 运行中 | Web UI v8.0.1 表格已修复 | | 🚌 **事件总线** | 8014 | ✅ 运行中 | 事件驱动通信 | | 🔍 **监控** | 8015 | ✅ 运行中 | 系统健康与指标 | | 🔧 **诊断服务** | 8013 | ✅ 运行中 | 系统诊断 | | 📈 **数据处理** | 8017 | ✅ 运行中 | CSV 中间件 v4.2.0 | | 🎯 **预测追踪** | 8018 | ✅ 运行中 | 目标-实际分析 | | 💰 **统一利润引擎** | 8025 | ✅ 运行中 | 合并利润分析 v3.0.0 | | 🤖 **ML 分析服务** | 8021 | ✅ 运行中 | 高级 ML 流水线与模型版本控制 | | 📊 **市值服务** | 8011 | ✅ 运行中 | 市值数据提供者 | ## 🚀 **系统架构** **事件驱动交易智能系统**,包含 **11个生产服务**: ### **🏗️ 核心服务:** | 服务 | 端口 | 状态 | 描述 | |---------|------|--------|--------------| | 🧠 **智能核心** | 8001 | ✅ 运行中 | AI 分析与 ML 引擎 | | 📡 **经纪商网关** | 8011 | ✅ 运行中 | 交易 API 集成 | | 🎨 **前端服务** | 8080 | ✅ 运行中 | 具有实时更新的 Web UI | | 🚌 **事件总线** | 8014 | ✅ 运行中 | 事件驱动通信 | | 🔍 **监控** | 8015 | ✅ 运行中 | 系统健康与指标 | | 🔧 **诊断服务** | 8012 | ✅ 运行中 | 系统诊断 | | 📈 **数据处理** | 8017 | ✅ 运行中 | 数据集成与处理 | | 🎯 **预测追踪** | 8018 | ✅ 运行中 | ML 模型性能 | | 🤖 **ML 分析** | 8021 | ✅ 运行中 | 高级 ML 流水线 | | 📊 **计算引擎** | 8025 | ✅ 运行中 | 财务计算 | | 🌐 **数据源** | 8013 | ✅ 运行中 | 外部 API 集成 | ## 🎯 **快速访问链接** <<<<<<< HEAD ### **包含5列的新CSV表格:** | 列 | 数据源 | 格式 | 描述 | |-----------------------------------|----------------------------|------------|-----------------------------| | **📅 日期** | CSV Timestamp | YYYY-MM-DD | 预测日期 | | **🏷️ 代码** | CSV Symbol | 徽章 | 股票代码 | | **🏢 公司** | CSV Company | 文本 | 完整公司名称 | | **📈 预期利润** | CSV Prediction_% | +/- % | 颜色编码的利润预测 | | **🛡️ 风险** | 从置信度计算 | 徽章 | 低/中/高 | ### **风险评估:** - **🟢 低**: 置信度 ≥ 80% (绿色徽章) - **🟡 中**: 置信度 60-80% (橙色徽章) - **🔴 高**: 置信度 < 60% (红色徽章) ## 🔄 **事件驱动流程** ### **实时示例 - 真实交易智能:** ``` 1. analysis.state.changed (AAPL: Score 18.5) → 2. portfolio.performance.updated (Portfolio: +12.8%) → 3. intelligence.triggered (Correlation detected) → 4. auto.import.recommendation (NVDA better than worst position) → 5. trading.order.executed (Auto-import with 0 balance) → 6. All systems updated in real-time (0.12s response) ``` ### **8种核心事件类型:** - `📈 analysis.state.changed` - 股票分析生命周期 - `💼 portfolio.state.changed` - 投资组合绩效更新 - `📊 trading.state.changed` - 交易活动事件 - `🧠 intelligence.triggered` - 跨系统智能 - `🔄 data.synchronized` - 数据同步事件 - `🚨 system.alert.raised` - 健康与警报事件 - `👤 user.interaction.logged` - 前端交互 - `📋 config.updated` - 配置更改 ## 🗄️ **事件存储架构** ### **PostgreSQL 唯一真相来源:** ``` -- Event-Store mit 0.12s Query-Performance event_store_db: ├── events # Chronological Event Log ├── materialized_views/ # Ultra-fast Query Views │ ├── stock_analysis_unified # Real-time Analysis + Performance │ ├── portfolio_unified # Real-time Portfolio Metrics │ ├── trading_activity_unified# Real-time Orders + Trades │ └── system_health_unified # Cross-Service Health Status └── indexes/ # Performance-optimierte Indizes ├── event_type_time_idx # Event-Type + Timestamp ├── entity_id_time_idx # Entity-ID + Timestamp └── correlation_id_idx # Event-Correlation Tracking ``` ## 📊 **API 端点** ### **前端服务 API (端口 8080):** ======= ### **📊 Web 界面:** ``` # 所有服务状态: https://10.1.1.174 # HTTPS (Nginx Proxy) http://10.1.1.174:8080 # Direct HTTP Access ``` ### **📚 文档:** - **[📋 完整需求](documentation/REQUIREMENTS.md)** - 所有功能与非功能需求 - **[🎯 系统概览](documentation/SYSTEM_OVERVIEW.md)** - 架构图及服务交互 - **[🔧 技术细节](documentation/LLD.md)** - 底层实现细节 - **[📡 API 文档](documentation/COMMUNICATION.md)** - 所有端点及通信模式 - **[🧪 测试框架](documentation/TESTING.md)** - 综合测试策略 ## 🎨 **主要特性** ### **📈 事件驱动架构:** - **响应时间**: 0.12秒优化性能 - **事件处理**: 每秒可处理1000+事件能力 - **实时更新**: 基于 WebSocket 的实时数据 - **可扩展设计**: 带有事件总线的微服务 ### **🤖 AI 与 ML 能力:** - **LSTM 模型**: 多周期预测 - **XGBoost 集成**: 高级特征工程 - **实时分析**: 实时市场数据处理 - **性能追踪**: 目标-实际对比 ### **🗄️ 数据架构:** - **PostgreSQL 事件存储**: 唯一真相来源 - **Redis 缓存**: 高速操作 - **物化视图**: 超快查询 (<50ms) - **多源集成**: 各种数据提供商 ## 🔧 **系统管理** ### **服务控制:** ``` # 单独服务管理: systemctl status aktienanalyse-*.service # 系统健康检查: systemctl restart aktienanalyse-frontend.service systemctl restart aktienanalyse-event-bus-modular.service # 系统健康: curl http://localhost:8001/health # Intelligent Core curl http://localhost:8017/health # Data Processing curl http://localhost:8018/health # Prediction Tracking ``` <<<<<<< HEAD ### **3. 健康检查:** ``` # 服务概览: curl http://localhost:8001/health # Intelligent-Core curl http://localhost:8017/health # Data-Processing curl http://localhost:8018/health # Prediction-Tracking curl http://localhost:8025/api/v1/profit/health # Unified-Profit-Engine ``` ======= ### **📊 性能指标:** - **响应时间**: 0.12秒 (事件驱动优化) - **内存使用**: 总计约 400MB (11个服务) - **CPU 使用率**: 满载下 <50% - **正常运行时间目标**: 99.9% 可用性 ## 🏆 **v6.0.0 成就** ### ✅ **已完成的转变:** - [x] **大规模清理**: 删除了449个文件,共121,477行 - [x] **文档合并**: 从 150+ 个精简为 10个专业文档 - [x] **模块版本控制**: 100% 符合命名约定 - [x] **零技术债务**: 整洁、可维护的代码库 - [x] **生产就绪**: 所有11个服务运行在 10.1.1.174 上 - [x] **专业文档**: 完整的技术覆盖 ### 🎯 **系统状态:** **事件驱动交易智能系统 v6.0.0 代表了项目历史上最大规模的合并和清理。从混乱的 150+ 文件结构转变为专业的、可维护的、完整文档化的生产系统。** ## 📖 **获取详细信息:** **请访问 [`/documentation/`](documentation/) 目录中的完整文档,以获取全面的技术细节、API 规范、部署指南和测试框架。** <<<<<<< HEAD ## 🔧 **Systemd 集成** ### **服务状态:** ``` # 服务日志: ● aktienanalyse-intelligent-core-eventbus-first.service - AI Analytics ● aktienanalyse-broker-gateway-eventbus-first.service - Trading Gateway ● aktienanalyse-frontend.service - Web Interface v7.0.1 ● aktienanalyse-event-bus-modular.service - Event Communication ● aktienanalyse-monitoring-modular.service - Health Monitor ● aktienanalyse-diagnostic.service - System Diagnostics ● aktienanalyse-data-processing-modular.service - CSV Middleware v4.2.0 ● aktienanalyse-prediction-tracking.service - SOLL-IST Analysis ``` ### **自动启动与恢复:** - ✅ `WantedBy=multi-user.target` (自动启动) - ✅ `Restart=always` (自动恢复) - ✅ `RestartSec=5` (恢复延迟) - ✅ 资源限制 (内存/CPU) ## 🎯 **部署详情** ### **部署环境:** - **服务器**: Proxmox LXC Container 174 - **操作系统**: Debian 12 (Bookworm) - **IP**: 10.1.1.174 (内部网络) - **反向代理**: Nginx (HTTPS 终止) ### **目录结构:** ``` /opt/aktienanalyse-ökosystem/ ├── services/ # All Microservices │ ├── frontend-service-modular/ # Web UI v7.0.1 │ ├── intelligent-core-service/ # AI Engine │ ├── event-bus-service-modular/ # Event Communication │ ├── data-processing-service/ # CSV Middleware v4.2.0 │ └── [other services]/ ├── venv/ # Python Virtual Environment ├── data/ # SQLite Databases └── logs/ # Service Logs ``` ## 📋 **维护** ### **日志:** ``` # 系统健康: journalctl -u aktienanalyse-frontend.service -f journalctl -u aktienanalyse-event-bus-modular.service -f # 数据库备份: systemctl list-units 'aktienanalyse*' --failed ``` ### **备份:** ``` # 代码备份: pg_dump event_store_db > backup_$(date +%Y%m%d).sql # 项目概览: git push origin main # Automated via this documentation update ``` ## 🏆 **项目状态** ### ✅ **已完成功能:** - [x] **事件驱动架构** 包含 8 个服务 - [x] **CSV中间件集成** 包含结构化表格 - [x] **目标-实际对比分析** 功能正常 - [x] **GUI 增强** 包含所需列 - [x] **服务合并** (10→8 个服务) - [x] **systemd 集成** 已完成 - [x] **健康监控** 已激活 - [x] **性能优化** 已完成 ### 🎯 **系统就绪:** **事件驱动交易智能系统已完全部署、测试,并满足所有要求!** # *最后更新:2025年8月24日 - 生产就绪 v8.0 合并版 - 前端表格已修复* *主要版本 v6.0.0 - 整洁架构合并* *最后更新:2025年8月23日 - 达到生产卓越*
标签:CSV转JSON, n8n, PostgreSQL, Redis, 事件存储, 事件缓存, 事件驱动架构, 交易智能系统, 子域名变形, 微服务架构, 搜索引擎查询, 数据解析, 无线安全, 更新管理, 测试用例, 生产环境, 系统优化, 系统架构, 运维管理, 逆向工具, 风险控制