《基于Hadoop的智能家庭健康管理系统》

一、数据采集模块

功能目标

设备数据模拟生成智能穿戴设备（手环、体重秤）的健康数据（心率、体温、步数）

支持环境传感器数据（温湿度、空气质量） 可以用 Python Faker库生成虚拟数据

二、数据存储模块

功能目标

原始数据存储

使用HDFS存储原始非结构化数据（如设备上传的JSON日志）

文件分区策略：按日期/用户ID分区

结构化存储

HBase：存储实时查询数据（如用户当天心率）

表设计：user_health（RowKey=用户ID+时间戳）

Hive：离线分析数据仓库

关系型数据

MySQL：存储用户信息、设备绑定关系

三、数据处理模块

功能目标

实时处理

Spark Streaming：计算实时健康指标（如当前心率是否超阈值）

离线分析

MapReduce：统计每日/周/月健康指标（平均心率、步数排名）

HiveQL：生成用户健康报告（如睡眠质量分析）

预警引擎

规则引擎：基于阈值触发告警（如持续高心率）

四、数据分析模块

功能目标

统计分析

用户健康趋势分析（如心率随时间的波动）

家庭成员健康对比（如父母与子女的步数差异）

机器学习（可选）

Spark MLlib：聚类分析用户健康模式（健康/亚健康群体划分）

示例模型：K-Means聚类（根据心率、步数、睡眠划分群体）

五、可视化模块

功能目标

用户端界面

个人健康数据仪表盘（实时心率曲线、步数排行榜）

健康报告下载（PDF/Excel格式）

管理端界面

家庭健康概览（成员健康状态热力图）

预警记录查询（按时间/用户筛选）

技术实现

前端：Vue.js + ECharts

后端API：Spring Boot或Flask

六、系统管理模块

功能目标

用户权限管理

角色划分：管理员（家庭组长）、普通成员

功能权限控制（如仅管理员可查看全部成员数据）

设备管理

设备绑定/解绑（手环与用户关联）

设备状态监控（在线/离线）

日志审计

记录数据访问日志（谁在何时查询了哪些数据）

输出：RBAC（角色权限）设计表 + 设备管理界面截图