(19)go-micro微服务filebeat收集日志

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
简介: (19)go-micro微服务filebeat收集日志

Filebeat介绍

filebeat是Beats中的一员。

Beats在是一个轻量级日志采集器,早期的ELK架构中使用Logstash收集、解析日志,但是Logstash对内存、cpu、io等资源消耗比较高。相比Logstash,Beats所占系统的CPU和内存几乎可以忽略不计。


Filebeat是用于转发和集中日志数据的轻量级传送工具。Filebeat监视您指定的日志文件或位置,收集日志事件,并将它们转发到Elasticsearch或 Logstash进行索引。


二 FileBeat基本组成

Prospector (勘测者) :负责管理Harvester并找到所有读取源。


Harvester (收割机) :负责读取单个文件内容,每个文件启动-个。


三 FileBeat工作原理

启动Filebeat时,它将启动一个或多个输入,这些输入将在为日志数据指定的位置中查找。对于Filebeat所找到的每个日志,Filebeat都会启动收集器。每个收集器都读取单个日志以获取新内容,并将新日志数据发送到libbeat,libbeat将聚集事件,并将聚集的数据发送到为Filebeat配置的输出。


12.png


四 Filebeat如何记录文件状态:

文件状态记录在文件中 (默认在/ar/ib/filebeat/registry )


Filebeat 会记录发送前的最后一行,并再可以连接的时候继续发送


每个 Prospector会为每个找到的文件记录一个状态


Filebeat 存储唯一标识符以检测文件是否先前被收集


五 Filebeat如何保证事件至少被输出一次

Filebeat 将每个事件的传递状态保存在文件中


在未得到输出方确认时, Filebeat 会尝试-直发送,直到得到回应


任何在Filebeat 关闭之前未确认的事件,都会在filebeat重启之后重新发送


可确保至少发送一次,但有可能会重复


六 安装Filebeat

下载链接:https://www.elastic.co/cn/downloads/past-releases/filebeat-7-9-3


记住选择对版本和系统(Filebeat版本和Elasticsearch版本一致)


下载后解压到项目目录下


启动命令:filebeat -e -c filebeat.yml


filebeat.yaml 是需要编写的,接下来一起来编写一下


七 使用Filebeat

filebeat.yml编写

在account目录下新建filebeat.yml ,输入以下代码:

# 输入
filebeat.inputs:
  - type: log
    enabled: true
    paths:
      - ./*.log
# 输出
output.logstash:
  hosts: ["localhost:5044"]
  • 这样,filebeat.yaml就完成了
  • filebeat.exe放到account目录下
  • 启动filebeat.exe:filebeat -e -c filebeat.yml
  • 同级目录下多了一个data文件夹,里面是:、、


8.png


  • 至此,filebeat收集日志工作就完成啦。


八 最后

  • 至此,go-micro微服务filebeat收集日志工作就正式完成。
  • 接下来就开始Elasticsearch使用的代码编写了,希望大家关注博主和关注专栏,第一时间获取最新内容,每篇博客都干货满满。
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
3天前
|
Go API Docker
热门go与微服务15
热门go与微服务15
14 2
|
1月前
|
监控 Go 微服务
带你十天轻松搞定 Go 微服务系列全集+勘误
带你十天轻松搞定 Go 微服务系列全集+勘误
|
1月前
|
存储 监控 Go
带你十天轻松搞定 Go 微服务系列(九、链路追踪)
带你十天轻松搞定 Go 微服务系列(九、链路追踪)
|
1月前
|
消息中间件 人工智能 供应链
go-zero 微服务实战系列(二、服务拆分)
go-zero 微服务实战系列(二、服务拆分)
|
26天前
|
缓存 安全 Java
如何利用Go语言提升微服务架构的性能
在当今的软件开发中,微服务架构逐渐成为主流选择,它通过将应用程序拆分为多个小服务来提升灵活性和可维护性。然而,如何确保这些微服务高效且稳定地运行是一个关键问题。Go语言,以其高效的并发处理能力和简洁的语法,成为解决这一问题的理想工具。本文将探讨如何通过Go语言优化微服务架构的性能,包括高效的并发编程、内存管理技巧以及如何利用Go生态系统中的工具来提升服务的响应速度和资源利用率。
|
1月前
|
监控 Go API
带你十天轻松搞定 Go 微服务之大结局(分布式事务)
带你十天轻松搞定 Go 微服务之大结局(分布式事务)
|
1月前
|
消息中间件 缓存 Kafka
go-zero微服务实战系列(八、如何处理每秒上万次的下单请求)
go-zero微服务实战系列(八、如何处理每秒上万次的下单请求)
|
1月前
|
缓存 NoSQL Redis
go-zero微服务实战系列(七、请求量这么高该如何优化)
go-zero微服务实战系列(七、请求量这么高该如何优化)
|
1月前
|
缓存 NoSQL 数据库
go-zero微服务实战系列(五、缓存代码怎么写)
go-zero微服务实战系列(五、缓存代码怎么写)
|
1月前
|
Prometheus 监控 Cloud Native
带你十天轻松搞定 Go 微服务系列(八、服务监控)
带你十天轻松搞定 Go 微服务系列(八、服务监控)