ELK配置记录(filebeat+kafka+Logstash+Elasticsearch+Kibana)

2023-11-19

一、简介

elk日志平台 :日志收集、分析和展示的解决方案。满足用户对⽇志的查询、排序、统计需求。
elk架构: filebeat(采集)(+kafka)+Logstash(管道)+Elasticsearch(存储、搜索)+Kibana(日志应用)
各组件功能:
Filebeat:监听并收集日志数据
kafka:高吞吐量的分布式发布订阅消息,大吞吐数据的临时队列。Kafka的吞吐性能很好,可以对付N个filebeat,而且能持久化了日志数据,这样即便过程中存在某个处理点出故障,只要kafka机器好,数据就好。比直接推logstash要高可靠,性能还好。
Logstash:将收集数据汇总给Logstash,Logstash进行数据清洗,将结果再以流式方式推送给Kafka对应的过滤数据Topic,这样看Kafka既保存了原始数据,还保存了过滤数据。
Elasticsearch:分布式、高扩展、高实时的搜索与数据分析引擎,Logstash将数据写入Elasticsearch
Kibana:用Kibana进行可视化展示es中的数据

二、filebeat配置与使用(windows)

(1)下载地址:https://www.elastic.co/cn/downloads/beats/filebeat
在这里插入图片描述

(2)选择 windows zip x86_64,下载安装filebeat后找到安装位置打开filebeat.yaml文件进行编辑在这里插入图片描述

(3)找到filebeat inputs。配置如下图所示,将enabled设为true,并在paths填写要监听的日志文件地址。
在这里插入图片描述

如果直接将监听数据输出到logstash,找到output.logstash,如下图所示,删除output.logstash的注释,填写logstash的访问地址,可以填写多个,以逗号分隔。由于我在k8s集群中安装的logstash,填写的是可访问的外部地址。
在这里插入图片描述

如果直接将监听数据输出到kafka,找到 kafka output。如果没有可以自己添加在文件中。将enabled改为true,在hosts中填写kafka的访问地址,可以填写多个,以逗号分隔。填写topic的名字,kafka中的topic会自动创建。

在这里插入图片描述

官方说明文档:
https://www.elastic.co/guide/en/beats/filebeat/7.9/kafka-output.html

启动filebeat:
需要等elk中其他应用启动完毕后,修改filebeat.yaml中输入输出的访问地址,保存后在filebeat文件夹下打开cmd
输入命令并回车:filebeat -c filebeat.yml -e
在这里插入图片描述

三、logstash配置

官方文档:https://www.elastic.co/guide/en/logstash/current/plugins-inputs-beats.html
1.input
如果filebeat输出到logstash, logstash只需要监听自己的端口即可。

beats {
    port => 8080
  }

如果filebeat输出到kafka,logstash需要监听kafka,其他参数可查询logstash官方文档。

kafka {
  bootstrap_servers => "IP:PORT"
  codec => json
  topics => ["topic_name"]   #请填写对应topic
  decorate_events => true
}

2.filter根据需要填写
3.output
将过滤后的日志输出到es中(示例为https服务)
如果es服务为http服务,需要将https修改为https;如果es没有开启安全认证,可以注释掉用户与密码。 ssl_certificate_verification 设置false意为跳过ssl证书;manage_template为false意为禁用系统自动创建模版

elasticsearch {
  hosts => ["https://10.111.200.128:9200"]
  user => "elastic"
  password => "Dameng7777"
  ssl_certificate_verification => false
  manage_template => false
  index => "%{[@metadata][beat]}-%{+YYYY.MM.dd}"
}

四、启动

由于我已经在k8s集群中使用helm chart安装了 kafka 、logstash、es(已包含kibana),修改上述内容后即可测试改架构能否使用。
安装启动顺序
es -->kibana -->kafka(可省)–>logstash -->filebeat
全部启动完毕后在浏览器输入kibana的地址,输入es的账号密码,
选择”Esplore on my own”
在这里插入图片描述
点击Discover
在这里插入图片描述

点击 create view创建视图,可以看到右边已经读取到的日志数据,在左边依次填写视图名,es索引通配式,点击 ‘save data view kibana’
在这里插入图片描述
进入视图后即可查看匹配到的所有日志。
在这里插入图片描述

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

ELK配置记录(filebeat+kafka+Logstash+Elasticsearch+Kibana) 的相关文章

随机推荐

  • java以base64文件格式导出excel表格

    在项目中要求查询数据库并且用base64文件流的格式返回excel表格 自己试了好几种方法 最后找到的答案 错误方式 用HSSFWorkbook直接生成相对应的文件 然后用base64转化 这种解析出来的文件是打不开的 String enc
  • 上海万应云——大数据精准招商系统

    上海万应云数字科技有限公司 基于全国企业大数据与企业特有的经营数据 进行动态分析与整合 形成如下几个业务领域 1 针对地方政府 产业园 形成产业政策分析 产业链路图谱 区域经济报告 高潜企业挖掘 全面把握当地的产业经济状况 投融资实际落地情
  • [JAVA]将Set转换成int[]数组

    今天在写练习的时候 碰到了方法的返回值为int 可我却使用的是HashSet来实现 想return发现类型对不上的问题 于是尝试了toArray方法 但toArray方法返回的是Object类或者是一个包装类 就找到了这个set转换成int
  • 动态一键换肤实现思路和demo

    前言 浏览器切换样式无非是通过css 总共有以下三种方法 内联style 注入style 注入link 那么我们想要实现一键换肤 那么我们为了剥离干净dom和css 我们只能选择style和link这两种方法 核心思路 在html的head
  • Java反射机制和线程

    JAVA反射机制 已经加载过这个类 通过类名来找到这个类的所有相关信息 在运行时判断任意一个对象所属的类 在运行时构造任意一个类的对象 在运行时判断任意一个类所具有的成员变量和方法 在运行时调用任意一个对象的成员变量和方法 生成动态代理 反
  • 远程桌面dos开启

    lt DOCTYPE html PUBLIC WCDTD XHTML StrictEN httpwwwworgTRxhtmlDTDxhtml strictdtd gt 注册表内容 Windows Registry Editor Versio
  • 用 Java 实现的八种常用排序算法

    八种排序算法可以按照如图分类 前置知识 1 算法稳定性 在一个序列中 能保证两个相等的数 经过排序之后 其在序列的前后位置顺序不变 A1 A2 排序前 A1 在 A2 前面 排序后 A1 还在 A2 前面 2 时间复杂度 时间复杂度是用于衡
  • Sublimewebinspector 断点不能打上的解决方法

    最近老大在sublime上开发出了我们产品的开发包 这个开发包能像ZenCoding一样快速打出前端代码 这样开发者用我们产品的概率就大多了 但是对于产品中的js代码 现在还没有很好的工具 搬砖的我小有雄心壮志的想给我们的产品开发一个JS代
  • 生成专题4

    文章转自微信公众号 机器学习炼丹术 作者 陈亦新 欢迎交流共同进步 联系方式 微信cyx645016617 学习论文 Analyzing and Improving the Image Quality of StyleGAN 文章目录 4
  • vue学习语法校验笔记总结

    vue语法校验需要安装eslint plugins vue插件 插件安装完成后 进入 插件配置 即可找到刚才安装插件 它的对应的配置文件是 eslintrc js 选项对应说明如下 module exports extends plugin
  • ES6之Map和Set有什么不同?

    一 Map 1 定义 Map是ES6提供的一种新的数据结构 它是键值对的集合 类似于对象 但是键的范围不限于字符串 各种类型的值都可以当做键 Object结构是 字符串 值 的对应 Map结构则是 值 值 的对应 2 代码示例 Map本身是
  • Mybatis的注解方式开发

    目录 一 环境搭建与测试 二 注解方式的单表CRUD 三 注解方式的复杂关系映射 属性与列的对应关系 多表查询 一对一 一对多 四 注解方式使用二级缓存 前面的文章使用的都是XML配置的方式进行开发 当然 Mybatis也可以使用注解的方式
  • c++ for循环的新写法

    for循环遍历一个数组 string类 vector类等 老写法 include
  • gzip压缩的json文件在谷歌浏览器(chrome)中可以正常解析,但是在safari浏览器乱码

    gzip压缩的json文件在谷歌浏览器 chrome 中可以正常解析 但是在safari浏览器乱码 挺奇怪的一个问题 json数据通过gzip压缩之后 axios接收到的数据在chrome中是正常的 但是在safari中却是乱码 文件流 后
  • jsp页面中获取参数值

    1 GET方法用根据URL获取参数值 1 1 jsp页面 1 2 3 6 7 8 9 10
  • oracle 不完整恢复,Oracle——不完全恢复

    不完全恢复分为用户不完全恢复和RMAN不完全恢复 若联机重做日志文件或者归档日志文件有丢失 则只能进行不完全恢复 一 不完全恢复的分类 1 time recover选项 指定恢复到某个时间点 常用 2 cancel recover选项 停止
  • buuctf - crypto - Rabbit

    rabbit 加解密 在线Rabbit加密 Rabbit解密 在线工具
  • 把路由器设置为交换机或者二级路由设置联网

    五台电脑用了一个路由 还有一台没有连上 结果又买了一个路由 问问能把剩下的电脑接上吗 该怎么接法 1 做二级路由 把第二個路由器作为二级路由用 接线的方法就像你接第一个主路由器那样 从第一个路由器LAN口出来的一条网线接在第二个路由器的WA
  • 姿态估计之2D人体姿态估计 - (OpenPose) Realtime Multi-Person 2D Pose Estimation using Part Affinity Fields

    参见 论文翻译 openpose magic ll的博客 CSDN博客 OpenPose论文解读 知乎 Openpose论文阅读 jmucvm的博客 CSDN博客 openpose论文总结 htt789的博客 CSDN博客 OpenPifP
  • ELK配置记录(filebeat+kafka+Logstash+Elasticsearch+Kibana)

    一 简介 elk日志平台 日志收集 分析和展示的解决方案 满足用户对 志的查询 排序 统计需求 elk架构 filebeat 采集 kafka Logstash 管道 Elasticsearch 存储 搜索 Kibana 日志应用 各组件功