01
风电行业背景与大数据需求
全球风电发展现状 · 高维时序异构数据 · 预测性维护与功率预测
背景价值
02
平台总体架构设计
分层架构 · 开源优先 · 高可用与灾备设计
架构高可用
03
数据采集技术选型与部署
SCADA/CMS/气象接入 · Flume/Kafka 数据汇聚
采集Kafka
04
数据存储方案设计
时序数据库选型 · HDFS · 混合存储策略
存储InfluxDB
05
数据清洗与预处理
缺失值处理 · 异常检测(3σ/箱线图) · 标准化
清洗异常检测
06
实时计算引擎搭建
Flink 集群部署 · Flink SQL · CEP 告警
实时Flink
07
批处理计算引擎搭建
Spark 集群部署 · Spark SQL/MLlib
批处理Spark
08
数据仓库建模
星型/雪花模型 · 主题域划分 · 缓慢变化维
建模主题域
09
数据治理与元数据管理
数据血缘 · 质量监控 · Apache Atlas
治理Atlas
10
任务调度与工作流编排
Airflow 安装 · DAG 定义 · 重试机制
调度Airflow
11
数据可视化与BI报表
Grafana · Superset · 风电运营大屏
可视化BI
12
机器学习平台集成
MLflow · 模型版本管理 · 功率预测
MLflow模型
13
预测性维护模型实战
轴承剩余寿命 · LSTM · 模型调优
预测维护LSTM
14
功率预测模型实战
NWP超短期 · XGBoost/LightGBM · 集成策略
功率预测XGBoost
15
故障诊断与告警系统
规则引擎 · 孤立森林 · 告警收敛
故障诊断告警
16
平台安全与权限管理
Kerberos · Ranger · TLS/SSL
安全权限
17
日志收集与分析
ELK 栈 · 日志结构化 · 故障排查
ELK日志
18
容器化部署
Docker 镜像 · Compose · Kubernetes
容器K8s
19
CI/CD与DevOps
Jenkins · 自动化测试 · 蓝绿部署
DevOpsCI/CD
20
性能优化与调优
Spark Shuffle · Flink Checkpoint · Kafka 调优
性能调优
21
数据备份与恢复
HDFS 备份 · 冷备/热备 · 跨机房灾备
备份灾备
22
平台监控与告警
Prometheus+Grafana · 自定义告警 · SLA
监控Prometheus
23
多源数据融合
SCADA+CMS关联 · 时空对齐 · 故障诊断
融合关联分析
24
边缘计算与云端协同
边缘节点 · 数据压缩 · 模型下发
边缘计算协同
25
数据API服务开发
Flask/FastAPI · API版本管理 · Kong网关
APIFastAPI
26
数据湖架构演进
Delta Lake/Iceberg · 湖仓一体 · ACID
数据湖Iceberg
27
成本优化与资源管理
YARN队列 · Spot实例 · 冷热分层
成本资源
28
合规性与数据安全
GDPR/数据安全法 · 脱敏 · 审计日志
合规安全
29
实战案例：某风电场全流程
需求分析 · 架构设计 · 环境搭建 · 大屏展示
实战全流程
30
平台运维与持续优化
日常巡检 · 应急响应 · 版本升级 · 知识库
运维优化