“基于elsearch比价引擎”的版本间的差异
来自CloudWiki
(→基于elsearch比价引擎) |
(→基于elsearch比价引擎) |
||
第6行: | 第6行: | ||
解压软件包:tar -zxvf logstash-7.3.2.tar.gz<br> | 解压软件包:tar -zxvf logstash-7.3.2.tar.gz<br> | ||
将安装包移动到 mv logstash-7.3.2 /usr/local/<br> | 将安装包移动到 mv logstash-7.3.2 /usr/local/<br> | ||
− | 重命名: mv | + | cd /usr/local/ |
+ | 重命名: mv logstash-7.3.2 logstash | ||
+ | 进入配置文件目录:/usr/local/logstash/config | ||
+ | |||
+ | input { | ||
+ | file { | ||
+ | path => ["/root/sj.txt"] | ||
+ | start_position => "beginning" | ||
+ | } | ||
+ | } | ||
+ | filter { | ||
+ | csv { | ||
+ | separator => "," | ||
+ | columns => | ||
+ | ["productId","productPage","categoryOne","categoryTwo","categoryThr","productImg","productName","productPrice","productPrices","productUnit","companyName","companyUrl","address","year","tags"] | ||
+ | } | ||
+ | } | ||
+ | output { | ||
+ | elasticsearch { | ||
+ | hosts => ["master:9200"] | ||
+ | index => "flight" | ||
+ | } | ||
+ | } |
2020年9月5日 (六) 08:29的版本
基于elsearch比价引擎
csv文件上传到Elsearch
1.安装Logstash
解压软件包:tar -zxvf logstash-7.3.2.tar.gz
将安装包移动到 mv logstash-7.3.2 /usr/local/
cd /usr/local/
重命名: mv logstash-7.3.2 logstash
进入配置文件目录:/usr/local/logstash/config
input { file { path => ["/root/sj.txt"] start_position => "beginning" } } filter { csv { separator => "," columns => ["productId","productPage","categoryOne","categoryTwo","categoryThr","productImg","productName","productPrice","productPrices","productUnit","companyName","companyUrl","address","year","tags"] } } output { elasticsearch { hosts => ["master:9200"] index => "flight" } }