位置: IT常识 - 正文

Logstash 入门实战(4)--filter plugin 介绍(logstash gsub)

编辑:rootadmin
本文主要介绍 Logstash 的一些常用过滤插件;相关的环境及软件信息如下:CentOS 7.9、Logstash 8.2.2。 1、grok 过滤插件 grok 是一种将行与正则表达式匹配,将行的特定部分映射到专用字段中以及根据此映射执行操作的方法。Logstash 中内置了超过 200 种 L ...

推荐整理分享Logstash 入门实战(4)--filter plugin 介绍(logstash gsub),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:logstash好用不,logstash-plain.log,logstash ui,logstash用法,logstash.yml,logstash教程,logstash gsub,logstash gsub,内容如对您有帮助,希望把文章链接给更多的朋友!

本文主要介绍 Logstash 的一些常用过滤插件;相关的环境及软件信息如下:CentOS7.9、Logstash 8.2.2。

1、grok 过滤插件

grok 是一种将行与正则表达式匹配,将行的特定部分映射到专用字段中以及根据此映射执行操作的方法。Logstash 中内置了超过 200 种Logstash 模式,用于过滤单词、数字和日期等。 如果找不到所需的模式,可以自定义模式。 还有多个匹配模式的选项,可简化表达式的编写以捕获日志数据。

Logstash grok 过滤插件的基本语法格式:

%{PATTERN:FieldName}

grok 可以非结构化的数据转变为结构化数据,非常适用于各类系统日志;下面使用Grok 来处理 Nginx访问日志。

一行 Nginx 访问日志:

10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] "GET /favicon.ico HTTP/1.1" 404 555 "http://10.49.196.11:8066/" "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36"

配置 Logstash:

input { stdin { }}filter { grok { match => { "message" => "%{IP:ip} - %{USER:remoteUser} \[%{HTTPDATE:accessTimeStr}\] \"%{WORD:method} %{URIPATHPARAM:path} %{WORD:protocal}/%{NUMBER:version}\" %{INT:status} %{INT:bytes} \"%{DATA:referer}\" \"%{DATA:userAgent}\""} }}output { stdout { }}

运行 Logstash 后输入日志信息:

10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] "GET /favicon.ico HTTP/1.1" 404 555 "http://10.49.196.11:8066/" "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36"{ "method" => "GET", "host" => { "hostname" => "pxc2" }, "accessTimeStr" => "27/Sep/2022:10:16:15 +0800", "userAgent" => "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36", "referer" => "http://10.49.196.11:8066/", "ip" => "10.49.196.1", "message" => "10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] \"GET /favicon.ico HTTP/1.1\" 404 555 \"http://10.49.196.11:8066/\" \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36\"", "@timestamp" => 2022-09-27T02:31:13.852428Z, "bytes" => "555", "remoteUser" => "-", "@version" => "1", "event" => { "original" => "10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] \"GET /favicon.ico HTTP/1.1\" 404 555 \"http://10.49.196.11:8066/\" \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36\"" }, "path" => "/favicon.ico", "status" => "404", "version" => "1.1", "protocal" => "HTTP"}

可以看到各字段信息都解析出来了。

各正则表达式定义的详细信息,可以参考https://github.com/logstash-plugins/logstash-patterns-core/tree/main/patterns,如:

IPV6 ((([0-9A-Fa-f]{1,4}:){7}([0-9A-Fa-f]{1,4}|:))|(([0-9A-Fa-f]{1,4}:){6}(:[0-9A-Fa-f]{1,4}|((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){5}(((:[0-9A-Fa-f]{1,4}){1,2})|:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){4}(((:[0-9A-Fa-f]{1,4}){1,3})|((:[0-9A-Fa-f]{1,4})?:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){3}(((:[0-9A-Fa-f]{1,4}){1,4})|((:[0-9A-Fa-f]{1,4}){0,2}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){2}(((:[0-9A-Fa-f]{1,4}){1,5})|((:[0-9A-Fa-f]{1,4}){0,3}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){1}(((:[0-9A-Fa-f]{1,4}){1,6})|((:[0-9A-Fa-f]{1,4}){0,4}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(:(((:[0-9A-Fa-f]{1,4}){1,7})|((:[0-9A-Fa-f]{1,4}){0,5}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:)))(%.+)?IPV4 (?<![0-9])(?:(?:[0-1]?[0-9]{1,2}|2[0-4][0-9]|25[0-5])[.](?:[0-1]?[0-9]{1,2}|2[0-4][0-9]|25[0-5])[.](?:[0-1]?[0-9]{1,2}|2[0-4][0-9]|25[0-5])[.](?:[0-1]?[0-9]{1,2}|2[0-4][0-9]|25[0-5]))(?![0-9])IP (?:%{IPV6}|%{IPV4})2、dissect 过滤插件Logstash 入门实战(4)--filter plugin 介绍(logstash gsub)

基于分隔符原理解析数据,解决grok解析时消耗过多cpu资源的问题。使用分隔符将非结构化事件数据提取到字段中。 解剖过滤器不使用正则表达式,速度非常快。 但是,如果数据的结构因行而异,grok 过滤器更合适。dissect 的应用有一定的局限性:主要适用于每行格式相似且分隔符明确简单的场景。

dissect 语法比较简单,有一系列字段(field)和分隔符(delimiter)组成

%{}字段%{}之间是分隔符

使用 Dissect 处理 Nginx 访问日志:

input { stdin { }}filter { dissect { mapping => { "message" => '%{ip} - %{remoteUser} [%{accessTimeStr} %{+accessTimeStr}] "%{method} %{path} %{protocal}/%{version}" %{status} %{bytes} "%{referer}" "%{userAgent}"'} }}output { stdout { }}

结果如下,与使用 grok 处理 Nginx 访问日志的结果一致:

10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] "GET /favicon.ico HTTP/1.1" 404 555 "http://10.49.196.11:8066/" "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36"{ "path" => "/favicon.ico", "status" => "404", "protocal" => "HTTP", "host" => { "hostname" => "pxc2" }, "bytes" => "555", "userAgent" => "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36", "@version" => "1", "event" => { "original" => "10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] \"GET /favicon.ico HTTP/1.1\" 404 555 \"http://10.49.196.11:8066/\" \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36\"" }, "referer" => "http://10.49.196.11:8066/", "accessTimeStr" => "27/Sep/2022:10:16:15 +0800", "message" => "10.49.196.1 - - [27/Sep/2022:10:16:15 +0800] \"GET /favicon.ico HTTP/1.1\" 404 555 \"http://10.49.196.11:8066/\" \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36\"", "method" => "GET", "version" => "1.1", "@timestamp" => 2022-09-27T09:28:36.042881Z, "remoteUser" => "-", "ip" => "10.49.196.1"}

dissect 除了字段外面的字符串定位功能以外,还通过几个特殊符号来处理字段提取的规则:

%{+key}+代表该匹配值追加到 key 字段下%{ts} %{+ts} %{+ts}Apr 26 12:20:02{ "ts":"Apr 26 12:20:02"}%{+key/2}后面的数字代表拼接的次序%{+order/2} %{+order/3} %{+order/1} %{+order/4}two three one go{ "order": "one two three go"}%{} 表示一个空的跳过字段%{a} %{} %{b}1 2 3{"a":"1","b":"3"}%{?key} ?表示,这块只是一个占位,并不会实际生成捕获字段存到事件里面。%{?key} %{&key}当同样捕获名称都是string,但是一个?一个&的时候,表示这是一个键值对。%{?key1}=%{&key1}&%{?key2}=%{&key2}a=1&b=2{"a":"1","b":"2"}%{key->},表示忽略它右边的填充,否则右边的多余填充将拆分到下一个字段中。%{a} %{b->} %{c}1 2 3{"a":"1","b":"2","c":"3"}#去除->后,会把多余的空格匹配到 c 中%{a} %{b} %{c}1 2 3{"a":"1","b":"2","c":" 3"}3、date 过滤插件

date 过滤插件可以把字符串的日期字段转为日期类型。

input { stdin { codec => "json" }}filter { date { match => ["accessTimeStr", "dd/MMM/yyyy:HH:mm:ss Z"] target => "accessTime" }}output { stdout { }}

上述配置把 accessTimeStr 字段的值转成日期类型,并写入accessTime 字段(默认为 @timestamp 字段)。运行 Logstash:

{"accessTimeStr": "27/Sep/2022:10:16:15 +0800"}{ "event" => { "original" => "{\"accessTimeStr\": \"27/Sep/2022:10:16:15 +0800\"}\n" }, "host" => { "hostname" => "pxc2" }, "@timestamp" => 2022-09-27T07:21:00.181981Z, "accessTime" => 2022-09-27T02:16:15Z, "@version" => "1", "accessTimeStr" => "27/Sep/2022:10:16:15 +0800"}4、mutate 过滤插件

mutate 插件可以对字段进行重命名、删除、替换、更新等操作:

convert 类型转换gsub 字符串替换split 字符串分割join 数组合转为字符串merge 数组合并为数组rename 字段重命名update 字段内容更新,如果字段不存在,则不处理replace 字段内容替换,如果字段不存在,则新增字段input { stdin { codec => "json" }}filter { mutate { convert => {"a" => "integer"} gsub => ["b", "_", "|"] #"_"替换为"|" split => {"c" => ","} join => {"d" => ","} merge => {"e1" => "e2"} #数组e2的元素合并到e1数组中 rename => {"f" => "ff"} update => {"g" => "new value"} replace => {"h" => "new value"} }}output { stdout { }}

启动 Logstash 并在控制输入测试数据:

{"a":"1","b":"A_B_C","c":"X,Y,Z","d":[1,2,3],"e1":[1,2,3],"e2":[4,5,6],"f":"ABC","g":"123"}{ "d" => "1,2,3", "e1" => [ [0] 1, [1] 2, [2] 3, [3] 4, [4] 5, [5] 6 ], "e2" => [ [0] 4, [1] 5, [2] 6 ], "c" => [ [0] "X", [1] "Y", [2] "Z" ], "event" => { "original" => "{\"a\":\"1\",\"b\":\"A_B_C\",\"c\":\"X,Y,Z\",\"d\":[1,2,3],\"e1\":[1,2,3],\"e2\":[4,5,6],\"f\":\"ABC\",\"g\":\"123\"}\n" }, "ff" => "ABC", "@timestamp" => 2022-09-28T02:45:26.305729Z, "b" => "A|B|C", "@version" => "1", "host" => { "hostname" => "pxc2" }, "h" => "new value", "g" => "new value", "a" => 1}5、json 过滤插件

json 插件可以把内容为 json 字符串的字段转换为 json 格式数据。

input { stdin { }}filter { json { source => "message" target => "result" }}output { stdout { }}

启动 Logstash 并在控制输入测试数据:

{"a":"1","b":"2"}{ "message" => "{\"a\":\"1\",\"b\":\"2\"}", "event" => { "original" => "{\"a\":\"1\",\"b\":\"2\"}" }, "@version" => "1", "@timestamp" => 2022-09-28T03:20:35.827102Z, "result" => { "b" => "2", "a" => "1" }, "host" => { "hostname" => "pxc2" }}6、ruby 过滤插件

ruby 插件时最灵活的插件,可以使用 ruby 来随心所欲的修改 Logstash Event 对象。

input { stdin { codec = "json" }}filter { ruby { code => 'a = event.get("a");event.set("a", a + 123")' }}output { stdout { }}

启动 Logstash 并在控制输入测试数据:

{"a":"1","b":"2"}{ "host" => { "hostname" => "pxc2" }, "b" => "2", "a" => "1abc", "@version" => "1", "event" => { "original" => "{\"a\":\"1\",\"b\":\"2\"}\n" }, "@timestamp" => 2022-09-28T06:01:35.180939Z}

本文中介绍的插件只是 Logstash 输入插件的很小的一部分,可查看Logstash 官方文档了解更多信息。

本文链接地址:https://www.jiuchutong.com/zhishi/312918.html 转载请保留说明!

上一篇:DedeCMS安装完成 Deprecated: Function ereg_replace(dedecms下载)

下一篇:织梦如何修改中英文模板的当前位置(织梦如何使用)

  • 微信怎样发平均红包(微信怎样发平均红包_生活知识)

    微信怎样发平均红包(微信怎样发平均红包_生活知识)

  • cpu属于外部设备吗(cpu以外的设备都称为什么)

    cpu属于外部设备吗(cpu以外的设备都称为什么)

  • 为什么ipad充电器发烫(为什么ipad充电一会充一会断)

    为什么ipad充电器发烫(为什么ipad充电一会充一会断)

  • 天猫退款商家不处理怎么办(天猫申请退款商家拒绝了怎么还交易成功了)

    天猫退款商家不处理怎么办(天猫申请退款商家拒绝了怎么还交易成功了)

  • 台式机自带摄像头吗(台式电脑摄像机在哪里)

    台式机自带摄像头吗(台式电脑摄像机在哪里)

  • 抖音怎么点红心(抖音怎么点红心多)

    抖音怎么点红心(抖音怎么点红心多)

  • b站下载视频导出没有声音(b站下载视频导入电脑)

    b站下载视频导出没有声音(b站下载视频导入电脑)

  • 芒果tv怎样赠片给好友(芒果tv如何赠片给好友)

    芒果tv怎样赠片给好友(芒果tv如何赠片给好友)

  • 抖音里面的超级乐迷是什么意思(抖音里面的超级驾驶玩不了)

    抖音里面的超级乐迷是什么意思(抖音里面的超级驾驶玩不了)

  • 微信总有人登录怎么办(微信总有人登录过怎么办)

    微信总有人登录怎么办(微信总有人登录过怎么办)

  • qq显示忙碌还能聊天吗(qq显示忙碌是啥意思)

    qq显示忙碌还能聊天吗(qq显示忙碌是啥意思)

  • 苹果闹钟会一直响吗(苹果闹钟会一直响多少次)

    苹果闹钟会一直响吗(苹果闹钟会一直响多少次)

  • 滴滴为什么会有预付款(滴滴为什么会有远途费)

    滴滴为什么会有预付款(滴滴为什么会有远途费)

  • 一加卡券卸载了怎么办(一加卡券app不能安装)

    一加卡券卸载了怎么办(一加卡券app不能安装)

  • redmik20有dc调光吗(redmik20pro有dc调光吗)

    redmik20有dc调光吗(redmik20pro有dc调光吗)

  • 投屏为什么没有声音(投屏为什么没有歌词啊)

    投屏为什么没有声音(投屏为什么没有歌词啊)

  • led显示屏安装(led显示屏安装方式)

    led显示屏安装(led显示屏安装方式)

  • pctal10是荣耀v20么(荣耀v20型号pct al10和tl10的区别)

    pctal10是荣耀v20么(荣耀v20型号pct al10和tl10的区别)

  • 20000毫安充电宝能充手机几次(20000毫安充电宝能充几次手机)

    20000毫安充电宝能充手机几次(20000毫安充电宝能充几次手机)

  • p30pro广角怎么开启(p30pro广角摄像头是哪个)

    p30pro广角怎么开启(p30pro广角摄像头是哪个)

  • qq会员怎么取消自动续费(话费qq会员怎么取消)

    qq会员怎么取消自动续费(话费qq会员怎么取消)

  • 计算机蓝屏的原因及解决方法(计算机蓝屏的故障的分析方法)

    计算机蓝屏的原因及解决方法(计算机蓝屏的故障的分析方法)

  • 华硕P8H61主板升级BIOS图文教程(华硕p8h61主板升级更换什么主板合适)

    华硕P8H61主板升级BIOS图文教程(华硕p8h61主板升级更换什么主板合适)

  • 电脑任务栏消失解决方法(电脑任务栏消失怎么把它显示出来)

    电脑任务栏消失解决方法(电脑任务栏消失怎么把它显示出来)

  • 学习C++这几个网站足矣(c++好学)

    学习C++这几个网站足矣(c++好学)

  • 企业所得税和预提所得税
  • 城镇土地使用税的征税范围有哪些
  • 母子公司换股协议
  • 未交增值税借方表示什么
  • 出口货物不能退税的原因
  • 货物运输代理费用会计分录
  • 反写了可以重新申报吗
  • 市政押金无法收回的损失可以税前扣除吗
  • 向香港公司支付服务费税率
  • 其他应付款计入资本公积
  • 开票有误的具体
  • 计入当期损益的利得
  • 无形资产研发成功并申请专利
  • 建筑施工外包
  • 计提和缴纳税会计分录
  • 原材料暂估分录
  • 委托、受托出口做账有哪些事项?
  • 境内机构经常项目外汇账户
  • 劳务公司开票是开劳务费还是工程服务
  • 没有发票的费用计入什么科目
  • 代开专用发票缴纳的增值税需要计提吗?
  • 普通机打发票可以抵税吗
  • 本期免税收入是什么
  • 补提的增值税应该记在哪里
  • 坏账收不回怎么做账
  • windows10如何切屏
  • 保护电脑安全的主要方式
  • 上市公司的股份可以转卖吗
  • uefiu盘安装系统步骤win10
  • mac教程视频
  • 汇算清缴期结束后
  • 按实际成本结转6日和7日的材料采购成本
  • php输入月份输出天数
  • [ChatGPT] 从 GPT-3.5 到 GPT-5 的进化之路 | ChatGPT和程序员 : 协作 or 取代
  • 工资必须走银行卡吗
  • 深度学习中的FPN详解
  • vue国际化占位符
  • ps怎么把多余的p掉
  • 结转销售成本的方法
  • 利润分配反映什么
  • 固定资产加速折旧是什么意思
  • mongodb4.4.2安装教程
  • 不良贷款转让怎么操作
  • 起重机属于固定资产中什么设备类型
  • 根据《中华人民共和国食品安全法》
  • 在excel中怎么制作
  • sql语句求中位数
  • 金税四期怎么监管消费和发票
  • 研发支出如何做账
  • 应付职工薪酬如何结转
  • 收到客户承兑怎么做账
  • 购买材料没开票怎么做账
  • 银行存款支付投资者投入的款项54万
  • 为什么生产经营许可证要第三方代办
  • 小规模纳税人增值税计算公式
  • 兼职会计如何做账报税
  • 金蝶财务软件服务器
  • 会务费入哪个科目
  • 卖出去的货没有发票怎么给人家解释
  • 防止服务器断电
  • 数据库复制数据sql语句
  • 利用的英文
  • ubuntu flash player
  • linux操作系统主要学什么
  • 屏蔽触摸按键什么意思
  • fetch怎么用
  • cocos3.0
  • 浏览器firefox
  • ajax动态加载json数据
  • python中的类怎么理解
  • 使用js如何创建元素
  • 用vue做项目加入购物车是怎么做到的
  • 深入探讨换个说法怎么说
  • android四大组件五大布局
  • jQuery soColorPacker 网页拾色器
  • android回调函数
  • 专票购买方是对方公司吗
  • 河北省税务局对外公开电话
  • 电信业务发票
  • 社保并入税务局的时间
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设