Logstash 是开源的服务器端数据处理管道，能够同时从多个来源采集数据，转换数据，然后将数据发送到 Elasticsearch 中。

这篇文章你会学习到：

• 安装
• 使用
• 配置

安装

• java: sudo yum install java-1.8.0
• yum
  • sudo rpm --import https://artifacts.elastic.co/GPG-KEY-elasticsearch
  • add /etc/yum.repos.d/logstash.repo
  • sudo yum install logstash
• logstash.repo

[logstash-6.x]
name=Elastic repository for 6.x packages
baseurl=https://artifacts.elastic.co/packages/6.x/yum
gpgcheck=1
gpgkey=https://artifacts.elastic.co/GPG-KEY-elasticsearch
enabled=1
autorefresh=1
type=rpm-md

使用

• 启动：
  • cd /usr/share/logstash
  • ./bin/logstash -e 'input { stdin { } } output { stdout {} }'
• sudo /usr/share/logstash/bin/logstash -f /etc/logstash/conf.d/
• or sudo nohup /usr/share/logstash/bin/logstash -f /etc/logstash/conf.d/ &> /dev/null
• 做成服务：
  • cd /etc/init.d
  • l
  • ln -sf /etc/init.d/logstash /etc/rc3.d/S50logstash

配置

普通文本日志收集

# test-log.conf

input {
    file {
        path => ["/var/log/logstash/messages"]
        type => "system"
        start_position => "beginning"
    }
}

filter {

}
 
output {
    elasticsearch {
        hosts => "10.5.11.234:9200"
        index => "testlog-%{+YYYY.MM.dd}"
    }
}

Nginx 收集

# sudo /usr/share/logstash/bin/logstash -f /etc/logstash/conf.d/

input {
    file {
        path => "/var/log/nginx/*access*.log"
        start_position => beginning
    }
}
 
filter {
    grok {
        match => [ "message" , "%{COMBINEDAPACHELOG}+%{GREEDYDATA:extra_fields}"]
        overwrite => [ "message" ]
    }
    mutate {
        convert => ["response", "integer"]
        convert => ["bytes", "integer"]
        convert => ["responsetime", "float"]
    }
    #geoip {
    #    source => "clientip"
    #    target => "geoip"
    #    add_tag => [ "nginx-geoip" ]
    #}
    date {
        match => [ "timestamp" , "dd/MMM/YYYY:HH:mm:ss Z" ]
        remove_field => [ "timestamp" ]
    }
    useragent {
        source => "agent"
    }
}
 
output {
    elasticsearch {
        hosts => ["0.5.11.234:9200"]
        index => "nginxlog-%{+YYYY.MM.dd}"
    }
    stdout { codec => rubydebug }
}

总结

Logstash 的确是一个非常好的日志搜集解决方案，但是它的耗资源较大，运行占用CPU和内存高，再加上它没有消息队列缓存，存在数据丢失隐患。Elasticsearch 团队也在找一些轻量级的日志搜集工具解决这一问题，例如：Filebeat、Logagent、Rsyslog 等等，当然它作出的贡献也是有目共睹的，技术在发展，社会在进步，新技术会越来越多越来越好。

〖坚持的一俢〗