“Spark:基于内容的推荐系统”的版本间的差异
来自CloudWiki
(→ElasticSearch后台) |
(→ElasticSearch后台) |
||
第26行: | 第26行: | ||
} | } | ||
} | } | ||
− | 4. | + | '''4.运行logstash程序''':<br> |
进入到logstash主目录(/usr/local/logstash)运行:./bin/logstash -f config/spak-tj.conf<br> | 进入到logstash主目录(/usr/local/logstash)运行:./bin/logstash -f config/spak-tj.conf<br> | ||
− | 5.在ES中展示:<br> | + | '''5.在ES中展示:'''<br> |
[[文件:2020-09-20 225010.png]]<br> | [[文件:2020-09-20 225010.png]]<br> |
2020年9月20日 (日) 14:52的版本
vue前端
ElasticSearch后台
spark索引创建
1.我们这里使用logstash上传到ES,分为三个字段分别是"当前商品、其他商品、相似度"("current merchandise","other commodities","similarity")
2.源数据格式
3.编写logstash配置文件
[root@master config]# cat spak-tj.conf input { file { path => ["/root/0920data.csv"] start_position => "beginning" } } filter { csv { separator => "," columns => ["current merchandise","other commodities","similarity"] } } output { elasticsearch { hosts => ["master:9200"] index => "spark-tj" } }
4.运行logstash程序:
进入到logstash主目录(/usr/local/logstash)运行:./bin/logstash -f config/spak-tj.conf
5.在ES中展示: