ELK日志分析系统+部署ELK

时间:2021-09-27
本文章向大家介绍ELK日志分析系统+部署ELK,主要包括ELK日志分析系统+部署ELK使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

一、ELK组件

ELK平台是一套完整的日志集中处理解决方案,将ElasticSearch、Logstash和Kiabana三个开源工具配合使用,完成更强大的用户对日志的查询、排序、统计需求
1.ElasticSearch
(1)是基于Lucene(一个全文检索引擎的架构)开发的分布式存储检索引擎,用来存储各类日志
(2)Elasticsearch是用Java开发的,可通过RESTful Web接口,让用户可以通过浏览器与Elasticsearch通信
(3)Elasticsearch是个分布式搜索和分析引擎,优点是能对大容量的数据进行接近实时的存储、搜索和分析操作
(4)Elasticsearch可以划分为三种:主节点、数据节点和客户端节点

1.master主节点:
elasticsearch.yml:
node.master:true
node.data:false
主要功能:维护元数据,管理集群节点状态;不负责数据写入和查询
配置要点:内存可以相对小一些,但是机器一定要稳定,最好是独占的机器
2.data数据节点
elasticsearch.yml:
node.master:false
node.data:true
主要功能:负责数据的写入与查询,压力大
配置要点:大内存,最好是独占的机器
3.client客户端节点
elasticsearch.yml:
node.master:true
node.data:true
主要功能:综合上述三个节点的功能。
配置要点:大内存,最好是独占的机器。
特别说明:不建议这种配置,节点容易挂掉
4.一般配置主节点3台服务器,数据节点与客户端节点配置比例一般在3:1左右,根据实际情况调节

2.Logstash
(1)作为数据收集引擎。它支持动态的从各种数据源搜集数据,并对数据进行过滤、分析、丰富、统一格式等操作,然后存储到用户指定的位置,一般会发送给Elasticsearch
(2)Logstash由JRuby语言编写,运行在Java虚拟机(JVM)上,是一款强大的数据处理工具,可以实现数据传输、格式处理、格式化输出。Logstash具有强大的插件功能,常用于日志处理
3.Kibana
是基于Node.js开发的展示工具,可以为Logstash和ElasticSearch提供图形化的日志分析Web界面展示,可以汇总、分析和搜索重要数据日志
4.Filebeat
轻量级的开源日志文件数据搜集器。通常在需要采集数据的客户端安装 Filebeat,并指定目录与日志格式,Filebeat就能快速收集数据,并发送给logstash进行解析,或是直接发给Elasticsearch存储,性能上相比运行于JVM上的loqstash优势明显,是对它的替代

二、为什么要使用ELK

1.日志主要包括系统日志,应用程序日志和安全日志。系统运维和开发人员可以通过日志了解服务器软硬件信息、检查配置过程中的错误及。错误发生的原因。经常分析日志可以了解服务器的负荷,性能安全性,从而及时采取措施纠正错误
2.往往单台机器的日志我们使用grep、awk等工具就能基本实现简单析,但是当日志被分散的储存不同的设备上。如果你管理数十上百台服务器,你还在使用依次登录每台机器的传统方法查阅日志。这样感觉很繁琐和效率低下
3.当务之急我们使用集中化的日志管理,例如∶开源的syslog,将所有服务器上的日志收集汇总。集中化管理日志后,日志的统计和检索又成为一件比较麻烦的事情,一般我们使用grep、awk和wc等Linux命令能实现检索和统计,但是对于要求更高的查询、排序和统计等要求和庞大的机器数量依然使用这样的方法难免有点力不从心
4.一般大型系统是一个分布式部署的架构,不同的服务模块部署在不同的服务器上,问题出现时,大部分情况需要根据问题暴露的关键信息,定位到具体的服务器和服务模块,构建一套集中式日志系统,可以提高定位问题的效率

三、完整日志系统基本特征

1.收集∶能够采集多种来源的日志数据
2.传输∶能够稳定的把日志数据解析过滤并传输到存储系统
3.存储∶存储日志数据
4.分析∶支持UI分析
5.警告∶能够提供错误报告,监控机制

四、ELK的工作原理


1.在所有需要收集日志的服务器上部署Logstash;或者先将日志进行集中化管理在日志服务器上,在日志服务器上部署Loqstash
2.Logstash收集日志,将日志格式化并输出到Elasticsearch群集中
3.Elasticsearch对格式化后的数据进行索引和存储
4.Kibana从ES群集中查询数据生成图表,并进行前端数据的展示

五、部署ELK

5.1 服务器准备

主机 ip 安装包
node1 192.168.80.11 Elasticsearch、kibana、Elasticsearch-head(便于管理ES集群)
node2 192.168.80.12 Elasticsearch
apache 192.168.80.13 httpd、Logstash

5.2 部署Elasticsearch(在node1/2上)

5.2.1 关闭防火强和安全功能

systemctl stop firewalld.service
setenforce 0

5.2.2 更改主机名并配置域名解析

--------192.168.80.11--------
hostnamectl set-hostname node1
su 

--------192.168.80.12---------
hostnamectl set-hostname node2
su 

echo '192.168.80.11 node1' >> /etc/hosts
echo '192.168.80.12 node2' >> /etc/hosts

5.2.3 配置java环境

java -version #没有安装就用yum安装java

5.2.4 部署Elasticsearch软件

1)安装elasticsearch包并启动服务

将elasticsearch-5.5.0.rpm包移到/opt目录
cd /opt
rpm -ivh elasticsearch-5.5.0.rpm 

systemctl daemon-reload
systemctl enable elasticsearch.service	

2)修改主配置文件

rpm -qpl elasticsearch-5.5.0.rpm  #查看ES的配置目录
cp /etc/elasticsearch/elasticsearch.yml /etc/elasticsearch/elasticsearch.yml.bak   #备份配置文件

vim /etc/elasticsearch/elasticsearch.yml
#17行(修改集群名字)
cluster.name: my-elk-cluster
#23行(修改节点名字)
node.name: node1
#33行;(修改数据存放路径)
path.data: /data/elk_data
#37行(修改日志存放路径)
path.logs: /var/log/elasticsearch
#43行(不在启动的时候锁定内存)
bootstrap.memory_lock: false
#55行
network.host: 0.0.0.0
#59行(侦听端口为9200)
http.port: 9200
#68行(指定要发现的节点 node1、node2)
discovery.zen.ping.unicast.hosts: ["node1", "node2"]

grep -v "^#" /etc/elasticsearch/elasticsearch.yml





3)创建数据存放路径并授权

mkdir -p /data/elk_data
chown elasticsearch:elasticsearch /data/elk_data/

4)启动elasticsearch是否开启成功

systemctl start elasticsearch
netstat -antp |grep 9200

5)查看节点信息和集群健康状态

http://192.168.80.11:9200
http://192.168.80.12:9200
http://192.168.80.11:9200/_cluster/health?pretty
http://192.168.80.12:9200/_cluster/health?pretty

使用上述方式查看群集的状态对用户并不友好,可以通过安装Elasticsearch-head插件,可以更方便的管理群集


5.3 安装elasticsearch-head(node1和node2)

5.3.1 编译安装node

上传软件包node-v8.2.1.tar.gz到/opt目录中

yum -y install gcc gcc-c++ make 
cd /opt
tar xzvf node-v8.2.1.tar.gz
cd /opt/node-v8.2.1/
./configure 
make -j4 && make install

5.3.2 安装phantomjs

上传软件包phantomjs-2.1.1-linux-x86_64.tar.bz2到/opt目录中

cd /opt
tar jxvf phantomjs-2.1.1-linux-x86_64.tar.bz2 -C usr/local/src/
cd /usr/local/src/phantomjs-2.1.1-linux-x86_64/bin
cp phantomjs /usr/local/bin

5.3.3 安装Elasticsearch-head数据可视化工具

上传软件包 elasticsearch-head.tar.gz 到/opt
cd /opt
tar zxvf elasticsearch-head.tar.gz -C /usr/local/src/
cd /usr/local/src/elasticsearch-head/
npm install


5.3.4 修改Elasticsearch主配置文件

vim /etc/elasticsearch/elasticsearch.yml
......
--末尾添加以下内容--
http.cors.enabled: true				#开启跨域访问支持,默认为 false
http.cors.allow-origin: "*"			#指定跨域访问允许的域名地址为所有

systemctl restart elasticsearch

5.3.5 启动elasticsearch-head服务

必须在解压后的elasticsearch-head目录下启动服务,进程会读取该目录下的 gruntfile.js文件,否则可能启动失败
cd /usr/local/src/elasticsearch-head/
npm run start &

> elasticsearch-head@0.0.0 start /usr/local/src/elasticsearch-head
> grunt server

Running "connect:server" (connect) task
Waiting forever...
Started connect web server on http://localhost:9100

#elasticsearch-head 监听的端口是 9100
netstat -natp |grep 9100

5.3.6 浏览器访问测试

http://192.168.80.11:9100/地址并连接群集。如果看到群集健康值为green绿色,代表群集很健康。

5.3.7 插入索引

通过命令插入一个测试索引,索引为gxd,类型为ggg。
curl -X PUT 'localhost:9200/gxd/ggg/1?pretty&pretty' -H 'content-Type: application/json' -d '{"user":"dashuaibi","lk":"dsb"}'


5.4 部署Logstash(在apache节点)

5.4.1 更改主机名

hostnamectl set-hostname apache
su 

5.4.2 安装apache服务(httpd)

yum -y install httpd
systemctl start httpd

5.4.3 配置java环境

java -version #没有安装就用yum安装java

5.4.4 安装并启动logstash

上传软件包 logstash-5.5.1.rpm 到/opt目录下
cd /opt
rpm -ivh logstash-5.5.1.rpm                           
systemctl start logstash.service                      
systemctl enable logstash.service

ln -s /usr/share/logstash/bin/logstash /usr/local/bin/

5.4.5 测试Logstash

Logstash命令选项 说明
-f 通过这个选项可以指定 Logstash 的配置文件,根据配置文件配置 Logstash 的输入和输出流
-e 从命令行中获取,输入、输出后面跟着字符串,该字符串可以被当作 Logstash 的配置(如果是空,则默认使用 stdin 作为输入,stdout 作为输出)
-t 测试配置文件是否正确,然后退出
1.输入采用标准输入,输出采用标准输出(类似管道)
logstash -e 'input { stdin{} } output { stdout{} }'
......
输入:www.baidu.com
执行ctrl+c退出

2.使用 rubydebug 输出详细格式显示,codec为一种编解码器
logstash -e 'input { stdin{} } output { stdout{ codec=>rubydebug } }'
......
输入:www.baidu.com
执行ctrl+c退出

3.使用Logstash将信息写入Elasticsearch中
logstash -e 'input { stdin{} } output { elasticsearch { hosts=>["192.168.80.11:9200"] } }'



5.4.6 定义logstash配置文件

1)组成

Logstash 配置文件基本由三部分组成:input、output 以及 filter(可选,根据需要选择使用)

2)格式

1.input {...}
2.filter {...}
3.output {...}

若要指定两个日志来源文件,则格式如下:
input {
	file { path =>"/var/log/messages" type =>"syslog"}
	file { path =>"/var/log/httpd/access.log" type =>"apache"}
}

3)具体实操

修改Logstash配置文件,让其收集系统日志/var/log/messages,并将其输出到elasticsearch中

1.chmod +r /var/log/messages		#让Logstash可以读取日志
2.vim /etc/logstash/conf.d/messages.conf
input {
    file{
        path =>"/var/log/messages"						#指定要收集的日志的位置
        type =>"messages"								#自定义日志类型标识
        start_position =>"beginning"					#表示从开始处收集
    }
}
output {
    elasticsearch {										#输出到elasticsearch
        hosts => ["192.168.80.11:9200"]					#指定elasticsearch服务器的地址和端口
        index =>"messages-%{+YYYY.MM.dd}"				#指定输出到elasticsearch的索引格式
    }
}
3.systemctl restart logstash 
4.浏览器访问 http://192.168.80.11:9100/ 查看索引信息



5.5 部署Kibana(在Node1节点上操作)

5.5.1 安装Kibana

#上传软件包 kibana-5.5.1-x86_64.rpm 到/opt目录
cd /opt
rpm -ivh kibana-5.5.1-x86_64.rpm

5.5.2 设置Kibana的主配置文件

vim /etc/kibana/kibana.yml
--2--取消注释,Kiabana 服务的默认监听端口为5601
server.port: 5601
--7--取消注释,设置 Kiabana 的监听地址,0.0.0.0代表所有地址
server.host: "0.0.0.0"
--21--取消注释,设置和 Elasticsearch 建立连接的地址和端口
elasticsearch.url: "http://192.168.80.10:9200" 
--30--取消注释,设置在 elasticsearch 中添加.kibana索引
kibana.index: ".kibana"


5.5.3 启动Kibana服务

systemctl start kibana.service
systemctl enable kibana.service

netstat -natp | grep 5601

5.5.4 验证Kibana

浏览器访问 http://192.168.80.10:5601
第一次登录需要添加一个 Elasticsearch 索引:
Index name or pattern
//输入:messeges-*			#在索引名中输入之前配置的 Output 前缀“messeges”

单击 “create” 按钮创建,单击 “Discover” 按钮可查看图表信息及日志信息。
数据展示可以分类显示,在“Available Fields”中的“host”,然后单击 “add”按钮,可以看到按照“host”筛选后的结果

5.5.5 添加Apache服务器的日志(访问的、错误的)

1.将Apache服务器的日志(访问的、错误的)添加到 Elasticsearch 并通过Kibana显示
vim /etc/logstash/conf.d/apache_log.conf
input {
    file{
        path => "/etc/httpd/logs/access_log"
        type => "access"
        start_position => "beginning"
    }
    file{
        path => "/etc/httpd/logs/error_log"
        type => "error"
        start_position => "beginning"
    }
}
output {
    if [type] == "access" {
        elasticsearch {
            hosts => ["192.168.80.11:9200"]
            index => "apache_access-%{+YYYY.MM.dd}"
        }
    }
	if [type] == "error" {
        elasticsearch {
            hosts => ["192.168.80.11:9200"]
            index => "apache_error-%{+YYYY.MM.dd}"
        }
    }
}

cd /etc/logstash/conf.d/
/usr/share/logstash/bin/logstash -f apache_log.conf (可能要重启apache节点)

2.浏览器访问 http://192.168.80.11:9100 查看索引是否创建

3.登录 Kibana,单击“Create Index Pattern”按钮添加索引, 在索引名中输入之前配置的Output 前缀 apache_access-*,并单击“Create”按钮。在用相同的方法添加 apache_error-*索引。
选择“Discover”选项卡,在中间下拉列表中选择刚添加的 apache_access-* 、apache_error-* 索引, 可以查看相应的图表及日志信息





原文地址:https://www.cnblogs.com/guxd/p/15343308.html