logstash~logstash将本地文件中的日志作为input处理-Toy模板网

这篇具有很好参考价值的文章主要介绍了logstash~logstash将本地文件中的日志作为input处理。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一、场景

测试环境中频繁操作产生日志例如打印刻录日志会比较浪费时间，想到将日志保存到本地文件汇总，然后使用logstash将本地文件作为input输入，即可在不实际操作的情况下对日志进行格式分析

二、解决方案

先将产生的日志保存到本地文件中，这里为了测试我使用的是stdin输入插件获取内容；使用file输出插件保存日志到本地文件

input{
    stdin{}
}
output{
    file{
    	path=>"/export/server/logstash-8.1.2/test.txt"
    	# 这句的作用是将文件作为json格式保存
    	codec=>"json"
	}
}

logstash~logstash将本地文件中的日志作为input处理,Elastic,logstash,elasticsearch

2. 本地获取到日志之后再次启动logstash，使用file输入插件将本地文件输入，使用stdout将日志输出，测试配置文件效果(启动logstash之后没有输出，在test.txt文件后加或删一个换行)

input{
    file{
    	path=>"/export/server/logstash-8.1.2/test.txt"
    	# 以json格式解析数据
		codec=>"json"
	}
}
output{
    stdout{}
}

logstash~logstash将本地文件中的日志作为input处理,Elastic,logstash,elasticsearch
3. 检查发现还有很多冗余字段例如host.name、log等，使用mutate过滤插件对字段进行处理(当logstash不加载本地文件时，对文件进行简单操作即可，例如增加或删除一个空行)

input{
    file{
    	path=>"/export/server/logstash-8.1.2/test.txt"
    	# 以json格式解析数据
		codec=>"json"
	}
}
filter{
    mutate {
        remove_field =>[
            "[log][file]",
            "[host][name]"
        ]
        replace =>{
            "[event][original]"=>"%{message}"
        }
    }
}
output{
    stdout{}
}