1. 选题背景与整体设计思路拆解1.1 为什么“公共交通运营数据分析”是个好毕设选题公共交通数据天然具备“量大、维度多、时效性强”三个特征这恰好是Hadoop生态最擅长处理的场景。公交刷卡记录、地铁进出站日志、车辆GPS轨迹、线路调度表、天气数据这些数据源单独看都不复杂但一旦叠加到“全市全时段”这个尺度上传统单机MySQL加Python脚本的组合就会立刻暴露出瓶颈。我带过几届学生的毕设凡是选了“数据分析可视化”方向的只要数据量超过百万级用pandas直接读CSV基本都会卡在内存溢出这一步。这个选题的核心价值在于它强迫你走完一条完整的数据链路——从数据采集、清洗、存储、分布式计算到最终的可视化呈现。很多同学的毕设只做“调包跑个模型”答辩时被问“你的数据怎么存的”“计算在哪一层做的”就答不上来。而HadoopDjango这套组合正好能把“存储层、计算层、展示层”三层架构讲清楚答辩时逻辑链条完整老师想挑刺都难。适合谁来参考有一定Python基础、学过数据库原理、想做一个“看起来有工程含量”的毕设的本科生。如果你连Linux基本命令都不熟建议先花两天补一下否则伪分布式环境搭建那一步就会卡住你一周。1.2 技术选型的底层逻辑为什么是Hadoop而不是Spark这里必须说清楚一个常见误区。很多同学一上来就想用Spark觉得“Spark比MapReduce快”。但在毕设场景下Hadoop的MapReduce反而更合适原因有三第一答辩可解释性强。MapReduce的“分而治之”思想非常直观你可以用“先分组统计再汇总结果”这种生活化语言向评委解释。Spark的RDD血缘关系、惰性求值这些概念解释成本高得多。第二环境搭建资料多。Hadoop伪分布式搭建的教程铺天盖地遇到问题容易搜到答案。Spark虽然也能单机跑但和Hadoop整合时版本兼容问题会让新手崩溃。第三计算规模匹配。毕设数据量通常在几GB到几十GB之间MapReduce的磁盘IO开销在这个量级下完全可以接受。Spark的内存计算优势要到TB级才明显体现。当然如果你时间充裕可以在Hadoop之上再加一层Hive用SQL风格写分析逻辑代码量会少很多。但Hive的元数据服务配置又是一个坑建议量力而行。1.3 Django在架构中的角色定位Django在这里不是“主角”而是“翻译官”。它的任务是把Hadoop算完的结果通过Web接口暴露给前端可视化页面。具体来说Django负责三件事接收前端发来的查询请求比如“查询3号线早高峰客流”从HDFS或MySQL结果表中读取预计算好的数据以JSON格式返回给ECharts渲染为什么不直接用Python脚本读HDFS然后生成静态HTML因为毕设答辩需要展示“交互性”。评委点一个下拉框图表能动态变化这个体验分就上去了。Django的ORM和模板系统能让这个过程非常顺畅而且它的Admin后台可以让你快速管理线路、站点等基础数据省去大量增删改查的重复劳动。注意不要把Django当成计算引擎。所有重计算必须在Hadoop层完成Django只做轻量级查询和展示。我见过有同学在Django视图里用pandas读HDFS文件再聚合结果每次请求都要等十几秒答辩演示时尴尬得不行。2. 核心细节解析与实操要点2.1 数据源获取与预处理的关键细节公共交通数据不像电商数据那样容易从公开渠道下载。我的经验是走“模拟数据真实路网”的路线路网结构从OpenStreetMap导出客流数据用Python脚本按真实规律生成。这样既有真实感又避免了隐私问题。生成数据时要模拟几个关键特征时间规律早高峰7:00-9:00晚高峰17:00-19:00客流量呈双峰分布空间规律换乘站客流是普通站的3-5倍线路差异市区线路客流密度高于郊区线路随机噪声加入5%的异常值模拟刷卡设备故障或数据丢失数据字段至少包含卡号脱敏后、刷卡时间、线路编号、站点编号、交易类型进站/出站、金额。生成1000万条记录大约占用500MB文本空间压缩后约150MB完全在单机伪分布式环境的处理能力范围内。实操心得生成数据时用Python的faker库生成卡号但不要用真实身份证号格式。时间字段用datetime模块随机生成注意要覆盖至少30天否则做“月度趋势分析”时数据不够。2.2 Hadoop伪分布式环境搭建的避坑指南伪分布式搭建是第一个大坎。网上教程很多但坑也不少。我总结几个关键点JDK版本选择Hadoop 3.x需要JDK 8或11不要用JDK 17会有反射权限问题。安装后务必配置JAVA_HOME环境变量并在hadoop-env.sh中显式指定。SSH免密登录伪分布式也需要配置本机SSH免密。执行ssh-keygen -t rsa后用ssh-copy-id localhost把公钥加到authorized_keys。如果这一步失败后面start-dfs.sh会一直提示输入密码。核心配置文件需要修改四个文件——core-site.xml指定HDFS地址hdfs-site.xml设置副本数为1伪分布式不需要3副本mapred-site.xml指定使用YARNyarn-site.xml配置NodeManager。每个文件的具体参数网上都有模板但要注意路径要和你实际安装目录一致。格式化NameNode第一次启动前必须执行hdfs namenode -format。注意这个命令只能执行一次重复执行会导致集群ID不一致DataNode无法启动。如果手滑执行了两次删掉data和logs目录重新格式化。启动顺序先start-dfs.sh再start-yarn.sh。用jps命令检查进程应该看到NameNode、DataNode、SecondaryNameNode、ResourceManager、NodeManager五个进程。少一个都说明配置有问题。2.3 MapReduce作业设计的核心思路针对公共交通数据至少需要设计三个MapReduce作业作业一站点客流统计。Mapper读取每条刷卡记录输出站点编号, 1Reducer累加得到每个站点的总客流。这个作业最简单用来验证环境是否正常。作业二时段客流分析。Mapper提取刷卡时间的小时部分输出线路编号小时, 1Reducer按线路和小时聚合。这个作业的结果直接用于绘制“客流热力图”。作业三换乘行为识别。这个稍复杂需要识别同一张卡在短时间内如30分钟内在不同线路的刷卡记录。Mapper输出卡号, 时间线路Reducer按卡号分组后排序判断是否存在换乘。这个作业能体现你的逻辑设计能力答辩时是加分项。注意事项MapReduce作业的输入输出路径不能相同输出目录必须不存在否则作业会报错。调试时可以在代码里加一行判断如果输出目录存在就自动删除。2.4 Django与Hadoop的结果对接方案Hadoop算完的结果默认是part-r-00000这种文本文件Django不能直接读。我的做法是MapReduce作业输出到HDFS后用hdfs dfs -get下载到本地再用Python脚本解析并写入MySQL。Django通过ORM读取MySQL这样查询速度最快。具体流程MapReduce输出格式设为TextOutputFormat每行“key\tvalue”写一个Python脚本用subprocess调用hdfs命令下载文件解析每行数据用Django的bulk_create批量插入MySQL在Django中定义模型类字段与结果表对应视图函数中查询数据用JsonResponse返回这个方案的好处是解耦Hadoop负责算MySQL负责存Django负责查。任何一层出问题都不会影响其他层。3. 实操过程与核心环节实现3.1 从零搭建开发环境的完整步骤我按实际操作的顺序把关键命令和配置列出来。假设你用的是Ubuntu 20.04Hadoop版本3.3.1Python 3.8Django 3.2。第一步安装JDK和Hadoopsudo apt update sudo apt install openjdk-8-jdk -y java -version # 确认输出1.8.x下载Hadoop 3.3.1二进制包解压到/usr/local/hadoop。编辑~/.bashrc添加export HADOOP_HOME/usr/local/hadoop export PATH$PATH:$HADOOP_HOME/bin:$HADOOP_HOME/sbin export JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64执行source ~/.bashrc生效。第二步配置Hadoop核心文件core-site.xmlconfiguration property namefs.defaultFS/name valuehdfs://localhost:9000/value /property /configurationhdfs-site.xmlconfiguration property namedfs.replication/name value1/value /property /configurationmapred-site.xmlconfiguration property namemapreduce.framework.name/name valueyarn/value /property /configurationyarn-site.xmlconfiguration property nameyarn.nodemanager.aux-services/name valuemapreduce_shuffle/value /property /configuration第三步启动集群并验证hdfs namenode -format start-dfs.sh start-yarn.sh jps # 检查五个进程 hdfs dfs -mkdir /user hdfs dfs -mkdir /user/yourname第四步创建Django项目pip install django pymysql django-admin startproject transit_analysis cd transit_analysis python manage.py startapp dashboard在settings.py中配置MySQL数据库连接在__init__.py中添加pymysql.install_as_MySQLdb()。3.2 MapReduce代码实现与参数计算以“时段客流分析”为例展示核心代码结构。Mapper类public class TimeFlowMapper extends MapperLongWritable, Text, Text, IntWritable { private Text outputKey new Text(); private final static IntWritable one new IntWritable(1); public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { String[] fields value.toString().split(,); String lineId fields[2]; String time fields[1]; String hour time.substring(11, 13); outputKey.set(lineId _ hour); context.write(outputKey, one); } }Reducer类public class TimeFlowReducer extends ReducerText, IntWritable, Text, IntWritable { private IntWritable result new IntWritable(); public void reduce(Text key, IterableIntWritable values, Context context) throws IOException, InterruptedException { int sum 0; for (IntWritable val : values) { sum val.get(); } result.set(sum); context.write(key, result); } }参数计算方面需要根据数据量设置Reducer数量。1000万条记录默认一个Reducer大约处理100万条耗时约2-3分钟。如果设置3个Reducer总耗时可以降到1分钟左右。在Driver类中通过job.setNumReduceTasks(3)设置。实操心得调试MapReduce时先用小数据集比如1万条跑通逻辑再换全量数据。否则每次改代码都要等好几分钟效率太低。另外日志级别调到WARN可以减少控制台输出方便看关键信息。3.3 Django可视化接口开发Django部分的核心是三个接口接口一获取线路列表。从MySQL的线路表读取所有线路编号和名称返回JSON数组。前端用这个数据填充下拉框。接口二获取指定线路的时段客流。接收线路编号参数查询结果表返回24个小时的客流数组。前端用ECharts的折线图渲染。接口三获取站点客流排名。返回客流最高的前20个站点前端用柱状图展示。视图函数示例from django.http import JsonResponse from .models import TimeFlow def get_time_flow(request): line_id request.GET.get(line_id) data TimeFlow.objects.filter(line_idline_id).order_by(hour) result { hours: [item.hour for item in data], counts: [item.count for item in data] } return JsonResponse(result)前端用ECharts的官方CDN引入配置项里设置xAxis为小时yAxis为客流量series类型为line。整个页面用Bootstrap做响应式布局保证在答辩教室的投影仪上显示正常。3.4 可视化大屏的布局与交互设计毕设答辩时一个好看的大屏能显著提升印象分。我建议采用“三栏布局”左侧线路选择器、日期选择器、刷新按钮中间核心图表区上方是客流趋势折线图下方是站点排名柱状图右侧关键指标卡片显示总客流、平均客流、峰值时段配色方案用深色背景配亮色数据线参考百度可视化大屏的风格。ECharts的主题可以自定义把背景设为#1a1a2e数据线用#00d4ff和#ff6b6b这种高对比度颜色。交互方面至少实现两个联动选择线路后折线图和柱状图同时更新鼠标悬停在折线图某个点上显示具体数值。这些ECharts都原生支持只需要在配置项里开启tooltip和dataZoom。注意事项大屏页面不要用太多动画效果答辩电脑性能参差不齐动画卡顿反而减分。另外所有图表数据要提前预计算好不要在前端做聚合运算。4. 常见问题与排查技巧实录4.1 Hadoop集群启动失败排查表现象可能原因解决方法jps看不到NameNode未格式化或格式化失败删除data/logs目录重新formatDataNode启动后立即退出集群ID不一致删除data目录重新formatResourceManager未启动yarn-site.xml配置错误检查aux-services拼写无法访问9870端口防火墙未关闭sudo ufw disableSSH连接被拒绝免密登录未配置重新执行ssh-copy-id4.2 MapReduce作业报错速查错误一ClassNotFoundException。原因是Hadoop找不到你的Mapper/Reducer类。解决方法是把编译后的class文件打包成jar用hadoop jar命令提交而不是直接java运行。错误二Input path does not exist。检查HDFS路径是否正确注意伪分布式下路径是/user/yourname/input不是本地路径。错误三Reducer卡在66%不动。这是Shuffle阶段的正常现象如果超过10分钟不动可能是数据倾斜。检查Mapper输出的key分布如果某个key的记录数远超其他需要在代码中加随机前缀打散。错误四输出目录已存在。MapReduce不允许覆盖输出目录。在Driver代码中加一行FileSystem.get(conf).delete(new Path(outputPath), true)或者每次手动删除。4.3 Django对接HDFS的常见坑坑一hdfs命令在Django中执行失败。原因是Django运行环境的PATH没有包含Hadoop的bin目录。解决方法是在视图函数中用绝对路径调用hdfs命令或者在settings.py中设置HADOOP_HOME环境变量。坑二中文乱码。Hadoop输出文件默认UTF-8但MySQL连接需要设置charsetutf8mb4。在Django的DATABASES配置中加上OPTIONS: {charset: utf8mb4}。坑三查询速度慢。如果结果表没有索引每次查询都要全表扫描。在MySQL中给line_id和hour字段建联合索引查询速度能从2秒降到0.05秒。独家避坑技巧在Django的models.py中给所有结果表加一个class Meta: managed False这样Django不会尝试创建或修改这些表避免和Hadoop的输出流程冲突。4.4 答辩演示的应急预案答辩现场最怕演示翻车。我的建议是准备三套方案方案A现场实时演示。提前把Hadoop集群和Django服务都启动好用浏览器打开大屏页面。风险是现场网络或电脑性能问题。方案B录屏演示。提前用OBS录一段3分钟的操作视频展示从数据上传到图表生成的完整流程。如果现场演示失败直接播放视频。方案C静态截图代码讲解。把关键页面的截图放在PPT里配合代码片段讲解实现逻辑。这是最后的保底方案。另外答辩前一定要把Hadoop集群重启一次确认所有进程正常。我见过有同学答辩前一天集群崩了第二天现场修了半小时评委脸色很难看。5. 项目扩展方向与个人经验分享5.1 可以继续深挖的几个方向如果你做完基础版本还有时间可以考虑加一个“客流预测”模块。用MapReduce算完历史客流后把结果导出到本地用Python的scikit-learn训练一个简单的线性回归或ARIMA模型预测未来一周的客流趋势。这个模块不需要分布式计算单机就能跑但能让你的毕设从“数据分析”升级到“数据分析机器学习”选题档次立刻不一样。另一个方向是“换乘推荐”。基于历史换乘数据用协同过滤算法给用户推荐最优换乘方案。这个需要设计更复杂的MapReduce作业但逻辑上完全可行。还有一个讨巧的做法把Django的Admin后台利用起来做一个“数据管理”页面让评委看到你不仅能分析数据还能管理数据。Admin后台只需要注册模型类几乎不用写代码性价比极高。5.2 我在带毕设过程中总结的几条铁律铁律一先跑通再优化。不要一上来就追求“完美架构”。先用最简单的MapReduce作业把数据跑通哪怕只有一个统计指标。跑通之后再逐步加功能这样你永远有一个可演示的版本。铁律二数据量要控制。毕设不是生产环境1000万条记录足够了。数据太多跑一次作业要半小时调试效率极低。数据太少又体现不出Hadoop的价值。我的经验是500万到2000万之间最合适。铁律三文档和代码一样重要。答辩时评委不会仔细看你的代码但会看你的论文和PPT。把架构图、数据流图、关键代码片段整理清楚比多写200行代码更有用。铁律四提前模拟答辩提问。自己先想好可能被问的问题“为什么用Hadoop不用Spark”“MapReduce的Shuffle过程是什么”“Django在这里的作用是什么”“数据量有多大处理了多久”把答案写下来反复练几遍。最后分享一个小心得答辩PPT里放一张“系统架构图”用不同颜色标注存储层、计算层、展示层。评委看到这张图基本就能判断你的项目是“真做了”还是“纯调包”。这张图花你半小时画但能省下答辩时十分钟的解释时间。
1. 选题背景与整体设计思路拆解1.1 为什么“公共交通运营数据分析”是个好毕设选题公共交通数据天然具备“量大、维度多、时效性强”三个特征这恰好是Hadoop生态最擅长处理的场景。公交刷卡记录、地铁进出站日志、车辆GPS轨迹、线路调度表、天气数据这些数据源单独看都不复杂但一旦叠加到“全市全时段”这个尺度上传统单机MySQL加Python脚本的组合就会立刻暴露出瓶颈。我带过几届学生的毕设凡是选了“数据分析可视化”方向的只要数据量超过百万级用pandas直接读CSV基本都会卡在内存溢出这一步。这个选题的核心价值在于它强迫你走完一条完整的数据链路——从数据采集、清洗、存储、分布式计算到最终的可视化呈现。很多同学的毕设只做“调包跑个模型”答辩时被问“你的数据怎么存的”“计算在哪一层做的”就答不上来。而HadoopDjango这套组合正好能把“存储层、计算层、展示层”三层架构讲清楚答辩时逻辑链条完整老师想挑刺都难。适合谁来参考有一定Python基础、学过数据库原理、想做一个“看起来有工程含量”的毕设的本科生。如果你连Linux基本命令都不熟建议先花两天补一下否则伪分布式环境搭建那一步就会卡住你一周。1.2 技术选型的底层逻辑为什么是Hadoop而不是Spark这里必须说清楚一个常见误区。很多同学一上来就想用Spark觉得“Spark比MapReduce快”。但在毕设场景下Hadoop的MapReduce反而更合适原因有三第一答辩可解释性强。MapReduce的“分而治之”思想非常直观你可以用“先分组统计再汇总结果”这种生活化语言向评委解释。Spark的RDD血缘关系、惰性求值这些概念解释成本高得多。第二环境搭建资料多。Hadoop伪分布式搭建的教程铺天盖地遇到问题容易搜到答案。Spark虽然也能单机跑但和Hadoop整合时版本兼容问题会让新手崩溃。第三计算规模匹配。毕设数据量通常在几GB到几十GB之间MapReduce的磁盘IO开销在这个量级下完全可以接受。Spark的内存计算优势要到TB级才明显体现。当然如果你时间充裕可以在Hadoop之上再加一层Hive用SQL风格写分析逻辑代码量会少很多。但Hive的元数据服务配置又是一个坑建议量力而行。1.3 Django在架构中的角色定位Django在这里不是“主角”而是“翻译官”。它的任务是把Hadoop算完的结果通过Web接口暴露给前端可视化页面。具体来说Django负责三件事接收前端发来的查询请求比如“查询3号线早高峰客流”从HDFS或MySQL结果表中读取预计算好的数据以JSON格式返回给ECharts渲染为什么不直接用Python脚本读HDFS然后生成静态HTML因为毕设答辩需要展示“交互性”。评委点一个下拉框图表能动态变化这个体验分就上去了。Django的ORM和模板系统能让这个过程非常顺畅而且它的Admin后台可以让你快速管理线路、站点等基础数据省去大量增删改查的重复劳动。注意不要把Django当成计算引擎。所有重计算必须在Hadoop层完成Django只做轻量级查询和展示。我见过有同学在Django视图里用pandas读HDFS文件再聚合结果每次请求都要等十几秒答辩演示时尴尬得不行。2. 核心细节解析与实操要点2.1 数据源获取与预处理的关键细节公共交通数据不像电商数据那样容易从公开渠道下载。我的经验是走“模拟数据真实路网”的路线路网结构从OpenStreetMap导出客流数据用Python脚本按真实规律生成。这样既有真实感又避免了隐私问题。生成数据时要模拟几个关键特征时间规律早高峰7:00-9:00晚高峰17:00-19:00客流量呈双峰分布空间规律换乘站客流是普通站的3-5倍线路差异市区线路客流密度高于郊区线路随机噪声加入5%的异常值模拟刷卡设备故障或数据丢失数据字段至少包含卡号脱敏后、刷卡时间、线路编号、站点编号、交易类型进站/出站、金额。生成1000万条记录大约占用500MB文本空间压缩后约150MB完全在单机伪分布式环境的处理能力范围内。实操心得生成数据时用Python的faker库生成卡号但不要用真实身份证号格式。时间字段用datetime模块随机生成注意要覆盖至少30天否则做“月度趋势分析”时数据不够。2.2 Hadoop伪分布式环境搭建的避坑指南伪分布式搭建是第一个大坎。网上教程很多但坑也不少。我总结几个关键点JDK版本选择Hadoop 3.x需要JDK 8或11不要用JDK 17会有反射权限问题。安装后务必配置JAVA_HOME环境变量并在hadoop-env.sh中显式指定。SSH免密登录伪分布式也需要配置本机SSH免密。执行ssh-keygen -t rsa后用ssh-copy-id localhost把公钥加到authorized_keys。如果这一步失败后面start-dfs.sh会一直提示输入密码。核心配置文件需要修改四个文件——core-site.xml指定HDFS地址hdfs-site.xml设置副本数为1伪分布式不需要3副本mapred-site.xml指定使用YARNyarn-site.xml配置NodeManager。每个文件的具体参数网上都有模板但要注意路径要和你实际安装目录一致。格式化NameNode第一次启动前必须执行hdfs namenode -format。注意这个命令只能执行一次重复执行会导致集群ID不一致DataNode无法启动。如果手滑执行了两次删掉data和logs目录重新格式化。启动顺序先start-dfs.sh再start-yarn.sh。用jps命令检查进程应该看到NameNode、DataNode、SecondaryNameNode、ResourceManager、NodeManager五个进程。少一个都说明配置有问题。2.3 MapReduce作业设计的核心思路针对公共交通数据至少需要设计三个MapReduce作业作业一站点客流统计。Mapper读取每条刷卡记录输出站点编号, 1Reducer累加得到每个站点的总客流。这个作业最简单用来验证环境是否正常。作业二时段客流分析。Mapper提取刷卡时间的小时部分输出线路编号小时, 1Reducer按线路和小时聚合。这个作业的结果直接用于绘制“客流热力图”。作业三换乘行为识别。这个稍复杂需要识别同一张卡在短时间内如30分钟内在不同线路的刷卡记录。Mapper输出卡号, 时间线路Reducer按卡号分组后排序判断是否存在换乘。这个作业能体现你的逻辑设计能力答辩时是加分项。注意事项MapReduce作业的输入输出路径不能相同输出目录必须不存在否则作业会报错。调试时可以在代码里加一行判断如果输出目录存在就自动删除。2.4 Django与Hadoop的结果对接方案Hadoop算完的结果默认是part-r-00000这种文本文件Django不能直接读。我的做法是MapReduce作业输出到HDFS后用hdfs dfs -get下载到本地再用Python脚本解析并写入MySQL。Django通过ORM读取MySQL这样查询速度最快。具体流程MapReduce输出格式设为TextOutputFormat每行“key\tvalue”写一个Python脚本用subprocess调用hdfs命令下载文件解析每行数据用Django的bulk_create批量插入MySQL在Django中定义模型类字段与结果表对应视图函数中查询数据用JsonResponse返回这个方案的好处是解耦Hadoop负责算MySQL负责存Django负责查。任何一层出问题都不会影响其他层。3. 实操过程与核心环节实现3.1 从零搭建开发环境的完整步骤我按实际操作的顺序把关键命令和配置列出来。假设你用的是Ubuntu 20.04Hadoop版本3.3.1Python 3.8Django 3.2。第一步安装JDK和Hadoopsudo apt update sudo apt install openjdk-8-jdk -y java -version # 确认输出1.8.x下载Hadoop 3.3.1二进制包解压到/usr/local/hadoop。编辑~/.bashrc添加export HADOOP_HOME/usr/local/hadoop export PATH$PATH:$HADOOP_HOME/bin:$HADOOP_HOME/sbin export JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64执行source ~/.bashrc生效。第二步配置Hadoop核心文件core-site.xmlconfiguration property namefs.defaultFS/name valuehdfs://localhost:9000/value /property /configurationhdfs-site.xmlconfiguration property namedfs.replication/name value1/value /property /configurationmapred-site.xmlconfiguration property namemapreduce.framework.name/name valueyarn/value /property /configurationyarn-site.xmlconfiguration property nameyarn.nodemanager.aux-services/name valuemapreduce_shuffle/value /property /configuration第三步启动集群并验证hdfs namenode -format start-dfs.sh start-yarn.sh jps # 检查五个进程 hdfs dfs -mkdir /user hdfs dfs -mkdir /user/yourname第四步创建Django项目pip install django pymysql django-admin startproject transit_analysis cd transit_analysis python manage.py startapp dashboard在settings.py中配置MySQL数据库连接在__init__.py中添加pymysql.install_as_MySQLdb()。3.2 MapReduce代码实现与参数计算以“时段客流分析”为例展示核心代码结构。Mapper类public class TimeFlowMapper extends MapperLongWritable, Text, Text, IntWritable { private Text outputKey new Text(); private final static IntWritable one new IntWritable(1); public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException { String[] fields value.toString().split(,); String lineId fields[2]; String time fields[1]; String hour time.substring(11, 13); outputKey.set(lineId _ hour); context.write(outputKey, one); } }Reducer类public class TimeFlowReducer extends ReducerText, IntWritable, Text, IntWritable { private IntWritable result new IntWritable(); public void reduce(Text key, IterableIntWritable values, Context context) throws IOException, InterruptedException { int sum 0; for (IntWritable val : values) { sum val.get(); } result.set(sum); context.write(key, result); } }参数计算方面需要根据数据量设置Reducer数量。1000万条记录默认一个Reducer大约处理100万条耗时约2-3分钟。如果设置3个Reducer总耗时可以降到1分钟左右。在Driver类中通过job.setNumReduceTasks(3)设置。实操心得调试MapReduce时先用小数据集比如1万条跑通逻辑再换全量数据。否则每次改代码都要等好几分钟效率太低。另外日志级别调到WARN可以减少控制台输出方便看关键信息。3.3 Django可视化接口开发Django部分的核心是三个接口接口一获取线路列表。从MySQL的线路表读取所有线路编号和名称返回JSON数组。前端用这个数据填充下拉框。接口二获取指定线路的时段客流。接收线路编号参数查询结果表返回24个小时的客流数组。前端用ECharts的折线图渲染。接口三获取站点客流排名。返回客流最高的前20个站点前端用柱状图展示。视图函数示例from django.http import JsonResponse from .models import TimeFlow def get_time_flow(request): line_id request.GET.get(line_id) data TimeFlow.objects.filter(line_idline_id).order_by(hour) result { hours: [item.hour for item in data], counts: [item.count for item in data] } return JsonResponse(result)前端用ECharts的官方CDN引入配置项里设置xAxis为小时yAxis为客流量series类型为line。整个页面用Bootstrap做响应式布局保证在答辩教室的投影仪上显示正常。3.4 可视化大屏的布局与交互设计毕设答辩时一个好看的大屏能显著提升印象分。我建议采用“三栏布局”左侧线路选择器、日期选择器、刷新按钮中间核心图表区上方是客流趋势折线图下方是站点排名柱状图右侧关键指标卡片显示总客流、平均客流、峰值时段配色方案用深色背景配亮色数据线参考百度可视化大屏的风格。ECharts的主题可以自定义把背景设为#1a1a2e数据线用#00d4ff和#ff6b6b这种高对比度颜色。交互方面至少实现两个联动选择线路后折线图和柱状图同时更新鼠标悬停在折线图某个点上显示具体数值。这些ECharts都原生支持只需要在配置项里开启tooltip和dataZoom。注意事项大屏页面不要用太多动画效果答辩电脑性能参差不齐动画卡顿反而减分。另外所有图表数据要提前预计算好不要在前端做聚合运算。4. 常见问题与排查技巧实录4.1 Hadoop集群启动失败排查表现象可能原因解决方法jps看不到NameNode未格式化或格式化失败删除data/logs目录重新formatDataNode启动后立即退出集群ID不一致删除data目录重新formatResourceManager未启动yarn-site.xml配置错误检查aux-services拼写无法访问9870端口防火墙未关闭sudo ufw disableSSH连接被拒绝免密登录未配置重新执行ssh-copy-id4.2 MapReduce作业报错速查错误一ClassNotFoundException。原因是Hadoop找不到你的Mapper/Reducer类。解决方法是把编译后的class文件打包成jar用hadoop jar命令提交而不是直接java运行。错误二Input path does not exist。检查HDFS路径是否正确注意伪分布式下路径是/user/yourname/input不是本地路径。错误三Reducer卡在66%不动。这是Shuffle阶段的正常现象如果超过10分钟不动可能是数据倾斜。检查Mapper输出的key分布如果某个key的记录数远超其他需要在代码中加随机前缀打散。错误四输出目录已存在。MapReduce不允许覆盖输出目录。在Driver代码中加一行FileSystem.get(conf).delete(new Path(outputPath), true)或者每次手动删除。4.3 Django对接HDFS的常见坑坑一hdfs命令在Django中执行失败。原因是Django运行环境的PATH没有包含Hadoop的bin目录。解决方法是在视图函数中用绝对路径调用hdfs命令或者在settings.py中设置HADOOP_HOME环境变量。坑二中文乱码。Hadoop输出文件默认UTF-8但MySQL连接需要设置charsetutf8mb4。在Django的DATABASES配置中加上OPTIONS: {charset: utf8mb4}。坑三查询速度慢。如果结果表没有索引每次查询都要全表扫描。在MySQL中给line_id和hour字段建联合索引查询速度能从2秒降到0.05秒。独家避坑技巧在Django的models.py中给所有结果表加一个class Meta: managed False这样Django不会尝试创建或修改这些表避免和Hadoop的输出流程冲突。4.4 答辩演示的应急预案答辩现场最怕演示翻车。我的建议是准备三套方案方案A现场实时演示。提前把Hadoop集群和Django服务都启动好用浏览器打开大屏页面。风险是现场网络或电脑性能问题。方案B录屏演示。提前用OBS录一段3分钟的操作视频展示从数据上传到图表生成的完整流程。如果现场演示失败直接播放视频。方案C静态截图代码讲解。把关键页面的截图放在PPT里配合代码片段讲解实现逻辑。这是最后的保底方案。另外答辩前一定要把Hadoop集群重启一次确认所有进程正常。我见过有同学答辩前一天集群崩了第二天现场修了半小时评委脸色很难看。5. 项目扩展方向与个人经验分享5.1 可以继续深挖的几个方向如果你做完基础版本还有时间可以考虑加一个“客流预测”模块。用MapReduce算完历史客流后把结果导出到本地用Python的scikit-learn训练一个简单的线性回归或ARIMA模型预测未来一周的客流趋势。这个模块不需要分布式计算单机就能跑但能让你的毕设从“数据分析”升级到“数据分析机器学习”选题档次立刻不一样。另一个方向是“换乘推荐”。基于历史换乘数据用协同过滤算法给用户推荐最优换乘方案。这个需要设计更复杂的MapReduce作业但逻辑上完全可行。还有一个讨巧的做法把Django的Admin后台利用起来做一个“数据管理”页面让评委看到你不仅能分析数据还能管理数据。Admin后台只需要注册模型类几乎不用写代码性价比极高。5.2 我在带毕设过程中总结的几条铁律铁律一先跑通再优化。不要一上来就追求“完美架构”。先用最简单的MapReduce作业把数据跑通哪怕只有一个统计指标。跑通之后再逐步加功能这样你永远有一个可演示的版本。铁律二数据量要控制。毕设不是生产环境1000万条记录足够了。数据太多跑一次作业要半小时调试效率极低。数据太少又体现不出Hadoop的价值。我的经验是500万到2000万之间最合适。铁律三文档和代码一样重要。答辩时评委不会仔细看你的代码但会看你的论文和PPT。把架构图、数据流图、关键代码片段整理清楚比多写200行代码更有用。铁律四提前模拟答辩提问。自己先想好可能被问的问题“为什么用Hadoop不用Spark”“MapReduce的Shuffle过程是什么”“Django在这里的作用是什么”“数据量有多大处理了多久”把答案写下来反复练几遍。最后分享一个小心得答辩PPT里放一张“系统架构图”用不同颜色标注存储层、计算层、展示层。评委看到这张图基本就能判断你的项目是“真做了”还是“纯调包”。这张图花你半小时画但能省下答辩时十分钟的解释时间。
