“Spark：基于内容的推荐系统”的版本间的差异
来自CloudWiki
（→ElasticSearch后台） |
（→ElasticSearch后台） |
||
| （未显示同一用户的5个中间版本） | |||
| 第2行： | 第2行： | ||
==ElasticSearch后台== | ==ElasticSearch后台== | ||
| − | '''spark索引创建'''<br> | + | '''1.spark索引创建'''<br> |
| − | + | 我们这里使用logstash上传到ES，分为三个字段分别是"当前商品、其他商品、相似度"（"current merchandise","other commodities","similarity"）<br> | |
'''2.源数据格式'''<br> | '''2.源数据格式'''<br> | ||
[[文件:2020920.jpg]]<br> | [[文件:2020920.jpg]]<br> | ||
| 第26行： | 第26行： | ||
} | } | ||
} | } | ||
| + | '''4.运行logstash程序'''：<br> | ||
| + | 进入到logstash主目录(/usr/local/logstash)运行：./bin/logstash -f config/spak-tj.conf<br> | ||
| + | '''5.在ES中展示:'''<br> | ||
| + | [[文件:2020-09-20 225010.png]]<br> | ||
2020年9月20日 (日) 14:53的最新版本
vue前端
ElasticSearch后台
1.spark索引创建
我们这里使用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中展示:
