ELK之Logstash如何安装与导入数据

数据集下载

下载地址：https://grouplens.org/datasets/movielens/

 

Logstash 下载与安装

首先去官网下载 Logstash 安装包：https://www.elastic.co/downloads/logstash

 

如果下载速度太慢可以选用这个代理地址下载：http://mirror.azk8s.cn/elastic/logstash/

 

下载完安装包并解压进入 config 目录：

 

同时配置如下内容,你只需要按照你的数据集的路径改一下配置文件中最开始的path即可：

• logstash.conf

input {
  file {
    path => "/Users/tanjian/Desktop/logstash-7.6.1/movielens/ml-latest-small/movies.csv" # 这里指定数据集路径
    start_position => "beginning"
    sincedb_path => "/dev/null"
  }
}
filter {
  csv {
    separator => ","
    columns => ["id","content","genre"]
  }

  mutate {
    split => { "genre" => "|" }
    remove_field => ["path", "host","@timestamp","message"]
  }

  mutate {

    split => ["content", "("]
    add_field => { "title" => "%{[content][0]}"}
    add_field => { "year" => "%{[content][1]}"}
  }

  mutate {
    convert => {
      "year" => "integer"
    }
    strip => ["title"]
    remove_field => ["path", "host","@timestamp","message","content"]
  }

}
output {
   elasticsearch {
     hosts => "http://localhost:9200"
     index => "movies"
     document_id => "%{id}"
   }
  stdout {}
}

Logstash 运行

配置好上面的 logstash.conf 文件后，我们就可以启动 Logstash 并开始导入数据了：

sudo ./bin/logstash -f config/logstash.conf

如下图 Logstash 日志所示，正在导入数据集：

 

打开 Kibana 查看数据

在查看数据之前，我们需要打开 http://localhost:5601 通过 Kibana 创建一个 Index Pattern：

 

之后，我们就可以通过 Discover 去查看我们的数据了：

 

剩下的就交给你自己折腾吧，你可以去 Dev Tools 通过 QSL 语法搜索数据熟悉一下语法。