本案例于2022年9月更新生成了第2.0版本，欢迎访问新版本案例
免费为全国高校提供大数据教学案例
建设者：厦门大学计算机科学系 林子雨 博士/助理教授
(E-mail: ziyulin@xmu.edu.cn, 个人主页：http://www.cs.xmu.edu.cn/linziyu)
（版权声明：本平台所有资源有版权，请勿用于商业用途）
（未经授权，其他网站请勿转载）
扫一扫手机访问本主页
案例简介 | 案例目的 | 软件工具 | 案例任务 | 实验步骤 | 开发团队 | 版本历史 | 联系人
相关其他案例推荐：Spark课程综合实验案例：淘宝双11数据分析与预测
点击这里观看厦门大学林子雨老师主讲《大数据技术原理与应用》课程视频
大数据课程实验案例：Spark+Kafka构建实时分析Dashboard案例，由厦门大学数据库实验室团队开发，旨在满足全国高校大数据教学对实验案例的迫切需求。本案例涉及数据预处理、消息队列发送和接收消息、数据实时处理、数据实时推送和实时展示等数据处理全流程所涉及的各种典型操作，涵盖Linux、Spark、Kafka、Flask、Flask-SocketIO、Highcharts.js、sockert.io.js、PyCharm等系统和软件的安装和使用方法。案例适合高校（高职）大数据教学，可以作为学生学习大数据课程后的综合实践案例。通过本案例，将有助于学生综合运用大数据课程知识以及各种工具软件，实现数据全流程操作。各个高校可以根据自己教学实际需求，对本案例进行补充完善。
- 熟悉Linux系统、Spark、Kafka、Flask、Flask-SocketIO、Highcharts.js、socket.io.js等系统和软件的安装和使用；
- 了解Spark+Kafka实时处理数据的基本流程；
- 熟悉Python操作Kafka的方法；
- 熟悉Spark Streaming程序编写；
- 熟悉Spark操作Kafka的方法；
- 熟悉Python构建Web程序；
- 熟悉SocketIO实时推送消息；
- 熟悉Highcharts.js展示数据。
适用对象
- 高校（高职）教师、学生
- 大数据学习者
时间安排
本案例可以作为《大数据处理技术Spark》课程在学期结束后的“大作业”，或者可以作为学生暑期或寒假大数据实习实践基础案例，完成本案例预计耗时7天。
预备知识
需要案例使用者，已经学习过大数据相关课程（比如入门级课程《大数据技术原理与应用》），了解Spark Streaming的基本概念与原理、Linux操作系统、Kafka消息队列发送和接收消息操作、Python构建Web应用，Socket.IO框架的应用以及前端JavaScript基础用法。
不过，由于本案例提供了全部操作细节，包括每个命令和运行结果，所以，即使没有相关背景知识，也可以按照操作说明顺利完成全部实验。
硬件要求
本案例可以在单机上完成，也可以在集群环境下完成。
单机上完成本案例实验时，建议计算机硬件配置为：500GB以上硬盘，8GB以上内存。
本案例所涉及的系统及软件：
- Linux系统
- Spark
- Kafka
- Flask
- Flask-SocketIO
- Highcharts.js
- Socket.io.js
- PyCharm
图 案例所涉及软件总体概览图
数据集
淘宝购物行为数据集 (5000万条记录，数据有偏移，不是真实的淘宝购物交易数据，但是不影响学习)
- 安装Linux操作系统
- 安装Spark
- 安装Kafka
- 安装Python依赖库
- 安装PyCharm
- 对文本文件形式的原始数据集进行预处理
- 将预处理后的数据发送至Kafka
- Spark从Kafka获取数据，实时处理，结果发送至Kafka
- Flask构建的Web程序从Kafka获取处理后的数据
- Flask-SockerIO实时推送数据至客户端
- 客户端Socket.io.js实时获取数据
- 客户端Highcharts.js实时展示数据
图 案例所涉及操作总体概览图
| 步骤零：案例介绍 | 查看实验指南 |
| 步骤一：实验环境准备 | 查看实验指南 |
| 步骤二：数据处理和Python操作Kafka | 查看实验指南 |
| 步骤三：Spark Streaming实时处理数据 | 查看Scala版实验指南 查看Python版实验指南 |
| 步骤四：结果展示 | 查看实验指南 |
每个实验步骤所需要的知识储备、训练技能和任务清单如下：
步骤零：案例介绍
| 所需知识储备 | 无 |
| 训练技能 | 了解本案例整体框架和所用到的工具 |
| 任务清单 | 无 |
步骤一：实验环境准备
| 所需知识储备 | Linux系统命令使用、了解如何安装Python库 |
| 训练技能 | 熟悉Linux基本操作、Pycharm的安装、Spark安装，Kafka安装，PyCharm安装 |
| 任务清单 | 1. 安装Linux系统；2. Spark安装；3.Kafka安装；4. Python安装；5. Python依赖库；6. PyCharm安装 |
步骤二：数据处理和Python操作Kafka
| 所需知识储备 | 简单使用Python，了解Kafka的使用 |
| 训练技能 | Python基本使用，Python操作Kafka代码库kafka-python使用 |
| 任务清单 | 1. 利用Python预处理数据；2. Python操作Kafka |
步骤三：Spark Streaming实时处理数据
| 所需知识储备 | 使用Scala编写Spark Streaming程序，Kafka原理 |
| 训练技能 | 编写Spark Streaming程序，熟悉Spark操作Kafka |
| 任务清单 | 1. Spark Streaming实时处理Kafka数据；2. 将处理后的结果发送给Kafka； |
步骤四：结果展示
| 所需知识储备 | 了解Flask创建web程序，了解如何在html编写js代码 |
| 训练技能 | 利用Flask创建web程序，利用Flask-SocketIO实现实时推送数据，利用socket.io.js实现实时接收数据，hightlights.js展现数据 |
| 任务清单 | 1. 利用Flask-SocketIO实时推送数据；2. socket.io.js实时获取数据；3. highlights.js展示数据 |
开发团队
为了解决高校大数据教学需要综合实验案例的迫切需求，2017年2月，厦门大学数据库实验室组建了由林子雨老师和罗道文（厦大数据库实验室2014级研究生）、阮榕城（厦大数据库实验室2015级研究生）、薛倩（厦大数据库实验室2015级研究生）、魏亮（厦大数据库实验室2016级研究生）、曾冠华（厦大数据库实验室2016级研究生）同学组成的案例开发小组，通过大量调研学习网络资料和相关案例，开发了本教学案例。期间，多次举行小组会议，讨论案例制作思路和技术细节。最终，经过近1个月的团队努力，于2017年4月23日顺利完成案例第1版的开发并上线发布。
本案例主创人员 罗道文
图（摄影 夏小云） 大数据案例开发团队合影
（人员从左到右名单：魏亮、阮榕城、林子雨、薛倩、曾冠华）
2017年4月23日，发布案例V1.0版本。
本案例相关事宜，欢迎联系厦门大学数据库实验室林子雨老师：E-mail: ziyulin@xmu.edu.cn