1 Star 0 Fork 1

赵欢/Movie_Recommendation

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README
1.爬虫文件需先新建数据库
在本地mysql创建test数据库,并创建internet,rate两个表。
CREATE TABLE `internet` (
  `ip` varchar(45) DEFAULT NULL,
  `port` varchar(45) DEFAULT NULL,
  `id` int(11) NOT NULL AUTO_INCREMENT,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=604 DEFAULT CHARSET=utf8

CREATE TABLE `rate` (
  `userid` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(45) DEFAULT NULL,
  `moiveid` int(11) NOT NULL,
  `rate` int(11) DEFAULT NULL,
  PRIMARY KEY (`userid`,`moiveid`)
) ENGINE=InnoDB AUTO_INCREMENT=4682 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci

更改项目下MysqlApi.py文件的MYSQL_DB, MYSQL_USER, MYSQL_PASS,  MYSQL_HOST四项配置的值
完成后运行IpSpider文件夹下的IpSpider.py文件,进行代理ip的爬取。
待上一步完成后运行RatingSpider文件夹下的RatingSpider.py即可。

并将数据写成文件存入HDFS中

2.使用spark-submit提交spark.py文件,默认参数为  --name demo  --master spark://master:7077
spark.py运行结果为 生成一个挖掘的关联数据csv文件到当前文件夹目录底下

空文件

简介

mysql+hdfs数据存储,spark sql数据清洗,spark streaming进行数据分析,Apriori数据挖掘算法 展开 收起
Python
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Python
1
https://gitee.com/xiaoqiSAMA/Movie_Recommendation.git
git@gitee.com:xiaoqiSAMA/Movie_Recommendation.git
xiaoqiSAMA
Movie_Recommendation
Movie_Recommendation
master

搜索帮助