【分布式应用】ELFK集群部署(Filebeat+ELK)Logstash的过滤模块

一、ELFK集群部署(Filebeat+ELK)

ELFK= ES + logstash+filebeat+kibana

实验环境

服务器类型系统和IP地址需要安装的组件硬件方面
node1节点192.168.126.21JDK、elasticsearch-6.7.2、kibana-6.7.22核4G
node2节点192.168.126.22JDK、elasticsearch-6.7.22核4G
apache节点192.168.126.23JDK、apache、logstash-6.7.2、filebeat-6.7.22核4G

注意:ELFK各安装包的版本要一致,或相近

实验步骤:

1.1 部署ELK集群

注意:ELFK集群环境下,Logstash 组件所在节点的/etc/logstash/conf.d目录下,不需要创建system.conf配置文件,即Logstash不需要收集系统日志,因为系统日志将由filebeat收集后发送给Logstash。(安装filebeat后,Logstash会创建filebeat.conf配置文件获取filebeat传来的数据)

1.2 安装 Filebeat(在apache节点操作)

 #上传软件包 filebeat-6.7.2-linux-x86_64.tar.gz 到/opt目录tar zxvf filebeat-6.7.2-linux-x86_64.tar.gzmv filebeat-6.7.2-linux-x86_64/ /usr/local/filebeat

1.3 设置 filebeat 的主配置文件

 cd /usr/local/filebeat​vim filebeat.ymlfilebeat.prospectors:- type: log         #指定 log 类型,从日志文件中读取消息enabled: truepaths:- /var/log/messages       #指定监控的日志文件- /var/log/*.logtags: ["sys"]     #设置索引标签fields:           #可以使用 fields 配置选项设置一些参数字段添加到 output 中service_name: filebeatlog_type: syslogfrom: 192.168.126.23​--------------Elasticsearch output-------------------(全部注释掉)​----------------Logstash output---------------------output.logstash:hosts: ["192.168.126.23:5044"]      #指定 logstash 的 IP 和端口​#启动 filebeatnohup ./filebeat -e -c filebeat.yml > filebeat.out &#-e:输出到标准输出,禁用syslog/文件输出#-c:指定配置文件#nohup:在系统后台不挂断地运行命令,退出终端不会影响程序的运行

1.4 在 Logstash 组件所在节点上新建一个 Logstash 配置文件

 cd /etc/logstash/conf.d​vim filebeat.confinput {beats {port => "5044"}}#filebeat发送给logstash的日志内容会放到message字段里面,logstash使用grok插件正则匹配message字段内容进行字段分割
#Kibana自带grok的正则匹配的工具:http://<your kibana IP>:5601/app/kibana#/dev_tools/grokdebugger
# %{IPV6}|%{IPV4} 为 logstash 自带的 IP 常量
filter {grok {match => ["message", "(?<remote_addr>%{IPV6}|%{IPV4})[\s\-]+\[(?<logTime>.*)\]\s+\"(?<method>\S+)\s+(?<url_path>.+)\"\s+(?<rev_code>\d+) \d+ \"(?<req_addr>.+)\" \"(?<content>.*)\""]}
}output {elasticsearch {hosts => ["192.168.126.21:9200","192.168.126.22:9200"]index => "%{[fields][service_name]}-%{+YYYY.MM.dd}"}stdout {codec => rubydebug}}​#启动 logstashlogstash -f filebeat.conf

5、浏览器访问

 浏览器访问 http://192.168.126.21:5601 登录 Kibana,单击“Create Index Pattern”按钮添加索引“filebeat-*”,单击 “create” 按钮创建,单击 “Discover” 按钮可查看图表信息及日志信息。

二、Logstash的过滤模块

2.1 Logstash配置文件中的模块

1、input { }

  • 指定输入流,通过file、beats、kafka、redis中获取数据

2、filter { }

常用插件:

  • grok:对若干个大文本字段进行再分割,分割成一些小字段 (?<字段名>正则表达式) 字段名:正则表示匹配到的内容
  • date:对数据中的时间进行统一格式化
  • mutate:对一些无用的字段进行剔除,或增加字段
  • mutiline:对多行数据进行统一编排,多行合并和拆分

3、ourput { }

  • elasticsearch stdout

2.2 Filter(过滤模块)中的插件

而对于 Logstash 的 Filter,这个才是 Logstash 最强大的地方。Filter 插件也非常多,我们常用到的 grok、date、mutate、mutiline 四个插件。

对于 filter 的各个插件执行流程,可以看下面这张图:

grok插件(通过grok插件实现对字段的分割,使用通配符)

这里就要用到 logstash 的 filter 中的 grok 插件。filebeat 发送给 logstash 的日志内容会放到message 字段里面,logstash 匹配这个 message 字段就可以了。

格式:

 匹配格式:(?<字段名>正则表达式)​# 字段名:正则表达式匹配到的内容

例: 

 (?<remote_addr>%{IPV6}|%{IPV4} )(?<other_info>.+)#对数据进行分割ip字段名为remote_addr, 其他字段名为other_info(?<remote_addr>%{IPV6}|%{IPV4} )[\s-]+[(?<log_time>.+)](?<other_info>.+)#添加匹配时间字段(?<remote_addr>%{IPV6}|%{IPV4})[\s-]+[(?<log_time>.+)]\s+"(?<http_method>\S+)\s+(?<url-path>.+)"\s+(?<rev_code>\d+)(?<other_info>.+)#分割多个字段

实例:

 cd /etc/logstash/conf.d/cp filebeat.conf filter.conf​vim filter.confinput {beats {port => "5044"}}filter {grok {match =>["message","(?<remote_addr>%{IPV6}|%{IPV4} )[\s-]+[(?<log_time>.+)]\s+"(?<http_method>\S+)\s+(?<url-path>.+)"\s+(?<rev_code>\d+)(?<other_info>.+)"]}}output {elasticsearch {hosts => ["192.168.126.21:9200","192.168.126.22:9200"]index => "{[filter][service_name]}-%{+YYYY.MM.dd}"}stdout {codec => rubydebug}}logstash -f filter.conf   #启动

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://xiahunao.cn/news/255757.html

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

录制软件obs的使用方法

软件界面 打开OBS可以看到软件界面分为上中下三个部分&#xff0c;上部是菜单栏&#xff0c;中间是内容显示区&#xff0c;下面是功能区。下面从左往右又分为场景&#xff0c;来源&#xff0c;混音器&#xff0c;转场特效和控件。 场景 首先看场景&#xff0c;场景可以理解为可…

OBS使用教程

1、下载OBS 官网地址&#xff1a;https://obsproject.com/ 下载windows系统上的安装包&#xff1a; 下载成功后&#xff0c;本地会出现如下安装包&#xff0c;然后双击进行安装即可。 2、OBS参数设置 输出设置&#xff1a;&#xff08;录制格式改成mp4&#xff0c;就不用后续转…

OBS Studio(obs录屏软件)官方中文版V27.2.4 | 最新obs中文版百度云下载

obs中文版是一款完全免费且开源的专业电脑屏幕录制软件&#xff0c;功能强大且易于使用的配置选项&#xff0c;完整适配所有主流的流媒体平台&#xff0c;大家可以轻松调整其属性并自由添加新来源、复制现有来源&#xff0c;适用于视频录制和直播推流的高性能实时视频/音频捕获…

OBS安装下载使用

OBS安装包 1、资源的获取 安装包获取 2、使用教程 直播 首先我们先在“来源”下的空白处进行右击&#xff0c;选择“添加-显示器捕获”。 弹出的窗口显示点击“确定”。 再次点击“确定”。 点击右下角的“设置”。 左侧选择“流”&#xff0c;“流类型”选择“自定义流…

华为云对象存储服务OBS,海量存储安全可靠,让云存储更加简单

随着产业数字化转型大潮的到来&#xff0c;企业生产经营过程中产生的数据也越来越多&#xff0c;不管是大型企业还是小微企业对数据存储备份的要求也越来越高&#xff0c;有的企业选择自购硬件设备进行存储&#xff0c;一方面需要付出高昂的成本&#xff0c;另一方面如果遇到意…

华为云OBS对象存储服务:值得拥有的贴心的存储管家

对象存储服务&#xff08;Object Storage Service,OBS&#xff09;是一个基于对象的存储服务&#xff0c;为客户提供海量、安全、高可靠、低成本的数据存储能力&#xff0c;使用时无需考虑容量限制&#xff0c;并且提供多种存储类型供选择&#xff0c;满足客户各类业务场景诉求…

OBS相关

zhulc2001的博客_V南瓜哥V_CSDN博客-视频网络直播,电视技术领域博主 求助&#xff01;&#xff01;&#xff01;麦克风滤镜里的增益效果和高级音频属性里直接将麦克风音量拉高有区别吗&#xff1f;还是同样的效果&#xff1f;只是增加了麦克风音量【obs吧】_百度贴吧 两个效果…

华为云OBS数据桶使用

华为云OBS数据桶的使用模式和AWS类似&#xff0c;可以参考这个链接 入门总览_对象存储服务 OBS_快速入门_华为云 (huaweicloud.com) 概览 OBS最基础的入门操作包括创建桶、上传对象和下载对象&#xff0c;通过这三个操作就能完成数据上传和下载。 图1为OBS大致的入门使用流…

obs有没有android版本,obs插件手机版下载-obs插件 安卓版v1.0.0-pc6手机下载

obs直播软件手机版是一款实用的直播辅助软件。obs插件手机版能够为主播提供屏幕录像、礼物显示等功能&#xff0c;协助主播更好的完成现场直播&#xff01; 软件介绍 OBS插件手机版是一款主播手机直播必备的插件工具&#xff0c;基于OBS软件给主播提供一键安装OBS、测速器、实用…

使用obs直播

前言&#xff1a; 最后有详细视频教程&#xff0c;可直接跳到最后查看 工具&#xff1a; obs下载&#xff1a;地址 Proxifier下载&#xff1a;地址 T子&#xff1a;地址&#xff08;或其它&#xff09; 一、获取直播码 1、打开油管 2、创建直播&#xff08;需要50个订阅&…

华为云OBS究竟是什么?

所谓对象存储服务&#xff08;OBS&#xff09;是一种以对象为中心的存储服务&#xff0c;它向用户提供大量安全、高可靠和低成本的数据存储&#xff0c;在使用过程中不需要考虑容量限制并提供了多种存储类型选择以满足用户对各种业务场景的诉求。而在OBS领域上&#xff0c;如今…

多行文字cad提取数据_CAD机械教程之批量数据提取图文详解

要调用此功能&#xff0c;我们可以依次点击【浩辰机械】—【辅助工具】—【批量数据提取】&#xff0c;软件会弹出对话框(如图1) 图1 在对话框中&#xff0c;我们可以变更关联字段配置、数据汇总类型。其中&#xff0c;在关联字段配置中&#xff0c;由于浩辰CAD机械软件执行数据…

怎么批量提取网站中的内容-免费网页数据提取软件

如何从网站中提取内容并将其保存为文本?单击并拖动选择要提取的网页上的文本&#xff0c;然后按“Ctrl-C”复制文本。打开文本编辑器或文档程序&#xff0c;然后按“Ctrl-V”将网页中的文本粘贴到文本文件或文档窗口中。将文本文件或文档保存到您的计算机。少量的话还好&#…

多行文字cad提取数据_中望CAD如何快速批量提取txt文本数据

数据提取及导入导出在CAD绘图中十分常见。中望CAD机械版辅助功能中的【批量数据提取】功能可以在不打开DWG文件的情况下&#xff0c;将图纸中的标题栏和明细表的内容进行批量提取&#xff0c;以供后续绘图的再次利用&#xff0c;帮助节省了大量时间。 中望CAD如何快速批量提取t…

PDF中批量数据的提取与处理

1. 背景 在当下的大数据时代中&#xff0c;各行各业都同时面临大数据所带来的数据规模大和数据来源繁多的机遇与挑战。如何更好的获取数据、处理数据和合并数据对于提高工作效率是至关重要的。 PDF是非常常见的数据来源&#xff0c;尤其见于公司的各种报告和报表中。将PDF中的…

时间序列数据特征提取TsFresh

文章目录 1. 源码和数据地址2. TsFresh安装3. 代码部分说明3.1 数据下载3.2 从文件读取数据 4. 特征拓展4.1 默认参数4.2 ComprehensiveFCParameters参数4.3 EfficientFCParameters参数4.4 MinimalFCParameters参数 5. 特征过滤5.1 默认参数5.2 ComprehensiveFCParameters参数5…

Python数据获取——图片数据提取

图片数据提取 一、利用exifread提取图片的EXIF信息二、循环遍历图片信息 比如我随便从手机上传一张图片到我的电脑里&#xff0c;通过python可以获取这张照片的所有信息。如果是数码相机拍摄的照片&#xff0c;我们在属性里可以找到照片拍摄的时间&#xff0c;拍摄的经纬度&…

SQL数据分析之数据提取、数据查询、数据清洗【MySQL速查】

文章目录 一、数据提取二、数据查询1、选取数据&#xff08;select&#xff09;2、筛选&#xff08;where&#xff09;3、范围匹配&#xff08;IN&#xff09;4、排序&#xff08;order by&#xff09;5、条件筛选&#xff08;case when&#xff09; 三、数据清洗四、数据分组五…