ELK——Logstash部署及介绍-蒲公英云

ELK——Logstash部署及介绍

Logstash简介

官网地址：https://www.elastic.co/products/logstash

Logstash is an open source data collection engine with real-time pipelining capabilities。简单来说logstash就是一根具备实时数据传输能力的管道，负责将数据信息从管道的输入端传输到管道的输出端；与此同时这根管道还可以让你根据自己的需求在中间加上滤网，Logstash提供里很多功能强大的滤网以满足你的各种应用场景，Logstash常用于日志关系系统中做日志采集设备；

Logstash基于java开发的开源项目，是一个数据收集处理转发系统，Logstash的事件（logstash将数据流中等每一条数据称之为一个event）处理流水线有三个主要角色完成：inputs –> filters –> outputs：

inpust：必须，负责产生事件（Inputs generate events），常用：File、syslog、redis、beats（如：Filebeats）
filters：可选，负责数据处理与转换（filters modify them），常用：grok、mutate、drop、clone、geoip
outpus：必须，负责数据输出（outputs ship them elsewhere），常用：elasticsearch、file、graphite、statsd

其中inputs和outputs支持codecs（coder&decoder）在1.3.0 版之前，logstash 只支持纯文本形式输入，然后以过滤器处理它。但现在，我们可以在输入期处理不同类型的数据，所以完整的数据流程应该是：input | decode | filter | encode | output；codec 的引入，使得 logstash 可以更好更方便的与其他有自定义数据格式的运维产品共存，比如：graphite、fluent、netflow、collectd，以及使用 msgpack、json、edn 等通用数据格式的其他产品等

Logstash最常用于ELK（elasticsearch + logstash + kibane）中作为日志收集器使用

Logstash安装指南

Logstash安装环境：

支持系统	centos6.10
Logstash使用版本	Logstash-7.2.0
java使用版本	1.8.0+

1.　 java安装环境可参考：https://www.cnblogs.com/Huang-Niu/p/11250268.html（[ELK——ElasticSearch部署及介绍][ELK_ElasticSearch]）

2.　 Logstash安装（二进制包）

2.1　将Logstash包上传至服务器，解压

tar xf logstash-7.2.0.tar.gz -C /usr/local

2.2　修改配置文件（需要新写一个配置文件，因为对接的是filebeat，所以不单独写Logstash的配置文件）

vim /usr/local/logstash-7.2.0/confignginxlog.conf

input {
　　beats {
　　　　port => 5044
　　}
}
output {
　　elasticsearch {
　　　　hosts => "192.168.1.130:9200"
　　　　index => "nginx-accesslog-%{+YYYY.MM.dd}"
　　}
}

2.3　收集增加redis配置文件修改

input {
　　redis {
　　　　host => "192.168.1.128"
　　　　port => 6379
　　　　data_type => "list"
　　　　key => "test"
　　}
}
output {
　　elasticsearch {
　　　　hosts => "192.168.1.130:9200"
　　　　index => "nginx-accesslog-%{+YYYY.MM.dd}"
　　}
}

2.4　配置文件修改完成后，指定配置文件进行启动（可直接使用root启动）

/usr/local/logstash-7.2.0/bin/logstash -f /usr/local/logstash-7.2.0/config/nginxlog.conf
/usr/local/logstash-7.2.0/bin/logstash -f /usr/local/logstash-7.2.0/config/nginxlog.conf > /dev/null 2>&1 &     #第一条命令无报错结束后，在执行此命令