Filebeat+kafka+logstash 多路径日志收集
发布日期:2022-04-22 13:46:58
浏览次数:10
分类:博客文章
本文共 2426 字,大约阅读时间需要 8 分钟。
一、准备日志环境
1.配置nginx日志为json格式
vim /usr/local/nginx/nginx.conf
log_format json '{"@timestamp":"$time_iso8601",' '"@version":"1",' '"client":"$remote_addr",' '"url":"$uri",' '"status":"$status",' '"domian":"$host",' '"host":"$server_addr",' '"size":"$body_bytes_sent",' '"responsetime":"$request_time",' '"referer":"$http_referer",' '"ua":"$http_user_agent"' '}'; #自定日志输出样式access_log logs/access.log json; #引用指定的日志
2.其他示例日志路径
/usr/local/nginx/logs/{access.log,error.log}/home/tomcat/logs/cata...out/var/log/message
二、修改filebeat配置文件
vim /etc/filebeat/filebeat.yml
filebeat.inputs:- type: log enabled: true paths: - /usr/local/nginx/logs/*.log fields: log_topics: nginx type: nginx ip: 192.168.137.125 fields_under_root: true - type: log enabled: true paths: - /home/tomcat/logs/catalina.out fields: log_topics: tomcat type: tomcat ip: 192.168.137.125 fields_under_root: true- type: log enabled: true paths: - /var/log/messages fields: log_topics: message type: message ip: 192.168.137.125 fields_under_root: truefilebeat.config.modules: path: ${path.config}/modules.d/*.yml reload.enabled: falsesetup.template.settings: index.number_of_shards: 1setup.kibana:output.kafka: hosts: ["192.168.137.25:9092","192.168.137.125:9092","192.168.137.126:9092"] enabled: true topic: '%{[fields][log_topics]}'processors: - add_host_metadata: ~ - add_cloud_metadata: ~ - add_docker_metadata: ~
注意点:其他一些filebeat的高级配置:
fields: #向输出的每一条日志添加额外的信息,比如“level:debug”,方便后续对日志进行分组统计。默认情况下,会在输出信息的fields子目录下以指定的新增fields建立子目录,例如fields.level。 log_topics: nginx type: nginx ip: 192.168.137.125 #根据该值可区分不同主机 fields_under_root: true #将fields下级的一些字段提升到上一级;如果该选项设置为true,则新增fields成为顶级目录,而不是将其放在fields目录下。自定义的field会覆盖filebeat默认的field。 ... ... topic: '%{[fields][log_topics]}' #根据上面的自定信息,创建相应的topic
三、配置logstash和kibana可视化
1.配置logstash
vim /etc/logstash/conf.d/test.yml
input { kafka { bootstrap_servers => ["192.168.137.125:9092,192.168.137.25:9092,192.168.137.126:9092"] topics => ["tomcat","nginx","message"] #filebeat里创建的topic consumer_threads => 1 codec => json }}output { elasticsearch { hosts => ["192.168.137.25:9200"] index => "filebeat-log-%{+YYYY.MM.dd}" }}
2.配置kibana可视化
3.根据字段检索日志
转载地址:https://www.cnblogs.com/yhy223/p/14465022.html 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
感谢大佬
[***.8.128.20]2024年03月25日 08时09分24秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
C++_类和对象_对象特性_初始化列表---C++语言工作笔记045
2019-04-26
kivy制作安卓APP--简单音乐播放器
2019-04-26
Angular2工程部署到Tomcat服务器,第一次访问正常,刷新浏览器后报404错误
2019-04-26
【力扣】155. 最小栈
2019-04-26
【力扣】160. 相交链表
2019-04-26
【力扣】167. 两数之和 II - 输入有序数组
2019-04-26
【力扣】168. Excel表列名称
2019-04-26
【力扣】456. 132 模式
2019-04-26
【力扣】82. 删除排序链表中的重复元素 II
2019-04-26
【剑指OFFER】 41. 数据流中的中位数
2019-04-26
【力扣】83. 删除排序链表中的重复元素
2019-04-26
【剑指OFFER】 43. 1~n 整数中 1 出现的次数
2019-04-26
【剑指OFFER】44. 数字序列中某一位的数字
2019-04-26
【剑指OFFER】45. 把数组排成最小的数
2019-04-26
【区块链】使用JAV简易A模拟创建区块链及挖矿
2019-04-26
【力扣】74. 搜索二维矩阵
2019-04-26
【剑指OFFER】46. 把数字翻译成字符串
2019-04-26