基于Centos搭建ELK环境指南
无论是甲方还是一方都需要面对大量日志处理的情况,之前分析的时候用基本的shell命令进行处理,但是面对大量数据的时候则有些力不从心,而且面对纯文字也不大直观。后来有人推荐了ELK,最近ELK升级到了版本五。E, L, K三大组件统一了版本号,花了一段时间总算搭好了。
基本环境信息:
操作系统:CentOS 6.9 x64
java版本号:1.8.0_131
ELK: 5.5
0×01 安装java
ELK需要最新的java1.8.CentOS自带了openjdk1.7,删了重新安装oracle java
yum remove java
然后从oracle官网( http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html )下载java的源码包
mkdir /usr/javatar -zxvf jdk-8u131-linux-x64.tar.gz -C /usr/java/
编辑/etc/profile
JAVA_HOME=/usr/java/jdk1.8.0_131JRE_HOME=/usr/java/jdk1.8.0_131/jrePATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/binCLASSPATH=:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/libexport PATH=$PATH:$JAVA_HOME:$JRE_HOME:$CLASSPATH
创建java的软连接
cd /usr/binln -s /usr/java/jdk1.8.0_131/bin/java java
如图,安装成功
2. 安装elasticsearch
去elk官网下载elasticsearch的rpm包,
直接安装
rpm -ivh elasticsearch-5.5.0.rpm
启动测试
/etc/init.d/elasticsearch start
如图,安装成功
清空elasticsearch的数据
curl -XDELETE 'http://127.0.0.1:9200/logstash-*'
配置一下权限
cd /var/libchmod -R 777 logstash
3. 安装kibana
还是从官网下载kibana的二进制包
rpm -ivh kibana-5.5.0-x86_64.rpm
启动
/etc/init.d/kibana start
如图所示,kibaba也安装成功了,现在kibana只能从本地访问,为了方便调试,利用nginx做一下反向代理
yum install nginx#/etc/nginx/conf.d/default.confserver { listen 80; location / { proxy_pass [http://localhost:5601](http://localhost:5601); }}
4. 安装logstash
安装logstash和之前的步骤一样,但是logstash是没有独立的守护服务的
安装后的路径
/usr/share/logstash/
创建config的软连接
cd /usr/share/logstashln -s /etc/logstash ./config
Logstash配置文件是JSON格式,放在/etc/logstash/conf.d 。 该配置由三个部分组成:输入,过滤器和输出。
input 数据输入端,可以接收来自任何地方的源数据。
file:从文件中读取
syslog:监听在514端口的系统日志信息,并解析成RFC3164格式。
redis:从redis-server list 中获取
beat:接收来自Filebeat的事件
Filter 数据中转层,主要进行格式处理,数据类型转换、数据过滤、字段添加,修改等,常用的过滤器如下。
grok: 通过正则解析和结构化任何文本。Grok 目前是logstash最好的方式对非结构化日志数据解析成结构化和可查询化。logstash内置了120个匹配模式,满足大部分需求。
mutate: 在事件字段执行一般的转换。可以重命名、删除、替换和修改事件字段。
drop: 完全丢弃事件,如debug事件。
clone: 复制事件,可能添加或者删除字段。
geoip: 添加有关IP地址地理位置信息。
output 是logstash工作的最后一个阶段,负责将数据输出到指定位置,兼容大多数应用,常用的有:
elasticsearch: 发送事件数据到 Elasticsearch,便于查询,分析,绘图。
file: 将事件数据写入到磁盘文件上。
mongodb:将事件数据发送至高性能NoSQL mongodb,便于永久存储,查询,分析,大数据分片。
redis:将数据发送至redis-server,常用于中间层暂时缓存。
graphite: 发送事件数据到graphite。 http://graphite.wikidot.com/
statsd: 发送事件数据到 statsd。
其中input和output是必须的,logstash由一个e参数,可以在终端调试配置文件
最简单的输入输出
/usr/share/logstash/bin# ./logstash -e 'input { stdin { } } output { stdout {} }'
采用格式化输出
logstash -e 'input { stdin { } } output { stdout { codec => rubydebug } }'
这边,我们是从终端输入,同时也从终端输出,但在实际状况中几乎不可能这么做,那先打通输出环节吧,把输出的内容发送到
Elasticsearch
首先启动Elasticsearch,确保9200端口开着,前边已经启动了。然后执行
./logstash -e 'input { stdin { } } output { elasticsearch { hosts => localhost } }'
确认一下
curl 'http://localhost:9200/_search?pretty'
logstash的e参数调试是很方便,但是内容多的话就不方便了,logstash还有一个f参数,用来从配置文件中读取信息,简单示例
#logstash_simple.confinput { stdin { } }output { elasticsearch { hosts => localhost }}# ./logstash -f ../config/logstash_simple.conf![75879570.png](http://image.3001.net/images/20170708/14995011356598.png!small)![75898507.png](http://image.3001.net/images/20170708/14995011414518.png!small)然后说一下过滤器#logstash.confinput { stdin {} }filter { grok { match => ["message", "%{COMBINEDAPACHELOG}"] }}output { elasticsearch { hosts => localhost } }
filter 以何种规则从字符串中提取出结构化的信息,grok是logstash里的一款插件,可以使用正则表达式匹配日志,上文中的%{COMBINEDAPACHELOG}是内置的正则,用来匹配apache access日志.
测试信息
127.0.0.1 - - [11/Dec/2013:00:01:45 -0800] "GET /xampp/status.php HTTP/1.1" 200 3891 "http://cadenza/xampp/navi.php" "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.9; rv:25.0) Gecko/20100101 Firefox/25.0"
curl 'http://localhost:9200/_search?pretty'
分析本地的apache日志文件
首先启动elasticsearch
/etc/init.d/elasticsearch start
然后创建logstash的json文件
#logstash_apache.confinput { file { path => "/tmp/access.log" type => "apache" start_position => "beginning" }}filter { grok { match => { "message" => "%{COMBINEDAPACHELOG}" } } date { match => [ "timestamp" , "dd/MMM/YYYY:HH:mm:ss Z"] }}output { elasticsearch { hosts => localhost }}
启动logstash
./logstash -f ../config/logstash_apache.conf
根据日志的时间修改一下时间段
然后是我最喜欢的功能,基于IP的地理位置显示
5.利用filebeat和redis搭建实时分析环境
下载安装redis
yum install redis/etc/init.d/redis start
filebeat从官网下载rpm包直接安装即可
在filebeat中,/var/lib/filebeat/registry是文件读取的记录,为了让filebeat从头开始读,把他删了
修改filebeat配置文件
filebeat.prospectors:- type: log paths: - /var/log/httpd/access_log tail_files: false#- input_type: log# paths:# - /var/log/nginx/*.log# encoding: utf-8# document_type: my-nginx-log# scan_frequency: 10s# harvester_buffer_size: 16384# max_bytes: 10485760# tail_files:output.redis: enabled: true hosts: ["127.0.0.1:6379"] key: "filebeat" db: 0 worker: 1 timeout: 5s max_retries: 3#output.console:# pretty: true
启动filebeat
filebeat -e -c /etc/filebeat/shadow.yml
去redis检查一下
有filebeat证明检查成功
既然redis和filebeat的通道打通了,然后就是打通redis和elasticsearch
#/usr/share/logstash/config/logstash_index.confinput { redis { #去redis队列取数据; host => "127.0.0.1" #连接redis服务器; port => 6379 #连接redis端口; data_type => "list" #数据类型; key => "filebeat" #队列名称; batch_count => 1 }}filter { grok { match => ["message", "%{COMBINEDAPACHELOG}"] } date { match => [ "timestamp" , "dd/MMM/yyyy:HH:mm:ss Z" ] }}output { elasticsearch { #Logstash输出到elasticsearch; hosts => ["localhost:9200"] #elasticsearch为本地; index => "logstash-apache-%{+YYYY.MM.dd}" #创建索引; document_type => "apache" #文档类型; workers => 1 #进程数量; flush_size => 20000 idle_flush_time => 10 }#stdout{codec => rubydebug}}
./logstash -f ../config/logstash_index.conf
访问一下apache服务器,请求变成了6个
6.配置守护进程
每次启动的程序和服务太多了,为了避免麻烦用supervisor放到后台
yum install supervisor
写配置文件
#/etc/supervisord.conf[program:iptables]command=/etc/init.d/iptables stopuser=rootstdout_logfile=/tmp/elk/iptables.log[program:nginx]command=nginxuser=rootstdout_logfile=/tmp/elk/nginx.log[program:redis]command=/etc/init.d/redis startuser=rootstdout_logfile=/tmp/elk/redis.log[program:kibana]command=/etc/init.d/kibana startuser=rootstdout_logfile=/tmp/elk/kibana.logstderr_logfile=/tmp/elk/kibana_error.log[program:filebeat]command=/usr/share/filebeat/bin/filebeat -c /etc/filebeat/shadow.ymluser=rootstdout_logfile=/tmp/elk/filebeat.log[program:logstash]command=/usr/share/logstash/bin/logstash -f /usr/share/logstash/config/logstash_index.confuser=rootstdout_logfile=/tmp/elk/logstash.log[program:elasticsearch]command=/etc/init.d/elasticsearch startuser=rootstdout_logfile=/tmp/elk/elasticsearch.logstderr_logfile=/tmp/elk/ela_err.log[supervisord]
开机一条命令搞定
supervisord -c /etc/supervisord.conf