“基于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"
 }
}