基于Hadoop大数据的出行方式推荐系统
文末获取联系
开发语言：Python
框架：flask
Python版本：python3.7.7
数据库：mysql 5.7、8.0
数据库工具：Navicat11
开发软件：PyCharm
浏览器：谷歌浏览器
项目介绍
1. 数据采集与处理：系统应能从多个出行相关数据源（如交通部门、航空公司、铁路公司等）采集出行数据，并对其进行清洗、转换和压缩等预处理操作，确保数据质量。
2. 数据存储与大数据处理：利用Hadoop的分布式文件系统（HDFS）存储大规模数据，并通过MapReduce框架进行数据分析和处理，提取出行偏好、用户行为模式等信息。
3. 出行方式推荐：根据用户的个人信息、历史出行数据和实时路况等信息，为用户提供个性化的出行方式推荐，包括高铁、地铁、飞机等。
4. 可视化展示：通过可视化工具（如ECharts）展示出行数据和推荐结果，以便用户快速理解推荐内容，提高系统的交互性和易用性。
5. 系统功能模块实现：包括用户注册与登录、个人信息管理、出行规划与导航、出行历史记录查询等功能模块，确保系统的完整性和可用性。
6. 性能优化与安全性：确保系统具有高效的处理能力，能够处理大规模数据；同时保障用户数据的安全性和系统的稳定性。
功能截图
代码实现
def jubaoxinxi_register(request): if request.method in ["POST", "GET"]: msg = {'code': normal_code, "msg": mes.normal_code} req_dict = request.session.get("req_dict") req_dict['mima'] = Common.md5(Common, req_dict.get('mima')) error = jubaoxinxi.createbyreq(jubaoxinxi, jubaoxinxi, req_dict) if error is Exception or (type(error) is str and "Exception" in error): msg['code'] = crud_error_code msg['msg'] = "用户已存在,请勿重复注册!" else: msg['data'] = error return JsonResponse(msg, encoder=CustomJsonEncoder) def jubaoxinxi_login(request): if request.method in ["POST", "GET"]: msg = {'code': normal_code, "msg": mes.normal_code} req_dict = request.session.get("req_dict") req_dict['password'] = Common.md5(Common, req_dict.get('password')) datas = jubaoxinxi.getbyparams(jubaoxinxi, jubaoxinxi, req_dict) if not datas: msg['code'] = password_error_code msg['msg'] = mes.password_error_code return JsonResponse(msg, encoder=CustomJsonEncoder) try: __sfsh__= jubaoxinxi.__sfsh__ except: __sfsh__=None if __sfsh__=='是': if datas[0].get('sfsh')!='是': msg['code']=other_code msg['msg'] = "账号已锁定，请联系管理员审核!" return JsonResponse(msg, encoder=CustomJsonEncoder) req_dict['id'] = datas[0].get('id') return Auth.authenticate(Auth, jubaoxinxi, req_dict) def jubaoxinxi_logout(request): if request.method in ["POST", "GET"]: msg = { "msg": "登出成功", "code": 0 } return JsonResponse(msg, encoder=CustomJsonEncoder) def jubaoxinxi_resetPass(request): ''' ''' if request.method in ["POST", "GET"]: msg = {"code": normal_code, "msg": mes.normal_code} req_dict = request.session.get("req_dict") columns= jubaoxinxi.getallcolumn( jubaoxinxi, jubaoxinxi) try: __loginUserColumn__= jubaoxinxi.__loginUserColumn__ except: __loginUserColumn__=None username=req_dict.get(list(req_dict.keys())[0]) if __loginUserColumn__: username_str=__loginUserColumn__ else: username_str=username if 'mima' in columns: password_str='mima' else: password_str='password' init_pwd = '123456' init_pwd = Common.md5(Common, init_pwd) recordsParam = {} recordsParam[username_str] = req_dict.get("username") records=jubaoxinxi.getbyparams(jubaoxinxi, jubaoxinxi, recordsParam) if len(records)<1: msg['code'] = 400 msg['msg'] = '用户不存在' return JsonResponse(msg, encoder=CustomJsonEncoder) eval('''jubaoxinxi.objects.filter({}='{}').update({}='{}')'''.format(username_str,username,password_str,init_pwd)) return JsonResponse(msg, encoder=CustomJsonEncoder)