百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

第九节:日志管理:从ELK Stack到Fluentd

off999 2025-02-16 22:25 19 浏览 0 评论

1. 日志管理的核心目标与挑战

1.1 日志管理的四大目标

  1. 故障排查:通过日志快速定位问题根源。
  2. 性能分析:识别系统瓶颈,优化资源利用率。
  3. 安全审计:检测异常行为,满足合规要求。
  4. 业务洞察:分析用户行为,支持决策制定。

1.2 日志管理的三大挑战

  • 数据量爆炸:高频率日志生成导致存储与计算压力。
  • 格式多样性:结构化与非结构化日志并存。
  • 实时性要求:快速检索与分析能力。

2. 基础日志工具:从tail到grep

2.1 tail命令详解

常用选项

选项

描述

示例

-f

实时跟踪日志文件

tail -f /var/log/syslog

-n

显示最后N行

tail -n 100 access.log

--retry

文件不存在时重试

tail --retry error.log

多文件监控

# 同时监控多个日志文件
tail -f /var/log/nginx/access.log /var/log/nginx/error.log

2.2 grep命令进阶

正则表达式

# 匹配IP地址
grep -Eo '[0-9]{1,3}(\.[0-9]{1,3}){3}' access.log

# 排除空行
grep -v '^$' logfile

上下文显示

# 显示匹配行的前后5行
grep -C 5 "error" logfile

3. 日志轮转:logrotate配置实战

3.1 logrotate核心配置

配置文件结构

# 全局配置
/var/log/nginx/*.log {
    daily
    rotate 7
    compress
    missingok
    notifempty
    create 0640 www-data adm
    sharedscripts
    postrotate
        /usr/sbin/nginx -s reload
    endscript
}

关键指令

指令

描述

daily

每天轮转日志

rotate

保留的日志文件数量

compress

压缩旧日志

postrotate

轮转后执行的脚本

3.2 生产案例:Nginx日志轮转

# 创建Nginx日志轮转配置
cat > /etc/logrotate.d/nginx <

4. 集中式日志管理:ELK Stack

4.1 ELK Stack架构

组件功能

  • Logstash:日志收集、过滤、转发。
  • Elasticsearch:日志存储与检索。
  • Kibana:日志可视化与分析。

4.2 ELK Stack部署

安装与配置

# 安装Elasticsearch
wget https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.10.0-amd64.deb
sudo dpkg -i elasticsearch-7.10.0-amd64.deb

# 安装Logstash
wget https://artifacts.elastic.co/downloads/logstash/logstash-7.10.0.deb
sudo dpkg -i logstash-7.10.0.deb

# 安装Kibana
wget https://artifacts.elastic.co/downloads/kibana/kibana-7.10.0-amd64.deb
sudo dpkg -i kibana-7.10.0-amd64.deb

Logstash配置

input {
  file {
    path => "/var/log/nginx/access.log"
    start_position => "beginning"
  }
}

filter {
  grok {
    match => { "message" => "%{COMBINEDAPACHELOG}" }
  }
}

output {
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "nginx-access-%{+YYYY.MM.dd}"
  }
}

4.3 Kibana可视化

创建仪表盘

  1. 添加Elasticsearch数据源。
  2. 导入官方仪表盘(如Nginx Access Logs)。
  3. 自定义面板,设置过滤条件。

5. 现代日志管理:Fluentd与EFK Stack

5.1 Fluentd核心概念

插件架构

  • Input插件:从文件、TCP/UDP、HTTP等来源收集日志。
  • Filter插件:解析、转换日志格式。
  • Output插件:将日志发送到Elasticsearch、Kafka等目标。

配置示例


  @type tail
  path /var/log/nginx/access.log
  pos_file /var/log/nginx/access.log.pos
  tag nginx.access
  format apache2



  @type elasticsearch
  host localhost
  port 9200
  logstash_format true

5.2 EFK Stack部署

架构图

安装与配置

# 安装Fluentd
curl -L https://toolbelt.treasuredata.com/sh/install-ubuntu-bionic-td-agent4.sh | sh

# 配置Fluentd
cat > /etc/td-agent/td-agent.conf <
  @type tail
  path /var/log/nginx/access.log
  pos_file /var/log/nginx/access.log.pos
  tag nginx.access
  format apache2



  @type elasticsearch
  host localhost
  port 9200
  logstash_format true

EOF

# 启动Fluentd
systemctl start td-agent

6. 日志安全与合规

6.1 日志加密

TLS传输

# Logstash配置TLS
output {
  elasticsearch {
    hosts => ["https://localhost:9200"]
    ssl => true
    ssl_certificate_verification => true
    cacert => "/path/to/ca.crt"
  }
}

磁盘加密

# 使用LUKS加密日志存储
cryptsetup luksFormat /dev/sdb1
cryptsetup open /dev/sdb1 encrypted_logs
mkfs.ext4 /dev/mapper/encrypted_logs
mount /dev/mapper/encrypted_logs /var/log/secure

6.2 日志保留策略

Elasticsearch索引生命周期管理

PUT _ilm/policy/logs_policy
{
  "policy": {
    "phases": {
      "hot": {
        "actions": {
          "rollover": {
            "max_size": "50GB",
            "max_age": "30d"
          }
        }
      },
      "delete": {
        "min_age": "90d",
        "actions": {
          "delete": {}
        }
      }
    }
  }
}

7. 生产级日志管理案例

7.1 案例一:Kubernetes日志收集

架构图

Fluentd配置


  @type tail
  path /var/log/containers/*.log
  pos_file /var/log/fluentd-containers.log.pos
  tag kubernetes.*
  format json
  time_key time
  time_format %Y-%m-%dT%H:%M:%S.%NZ



  @type elasticsearch
  host elasticsearch
  port 9200
  logstash_format true

7.2 案例二:微服务日志追踪

OpenTelemetry集成

# 配置OpenTelemetry Collector
receivers:
  otlp:
    protocols:
      grpc:
        endpoint: 0.0.0.0:4317

exporters:
  logging:
    loglevel: debug
  elasticsearch:
    endpoints: ["http://elasticsearch:9200"]

service:
  pipelines:
    traces:
      receivers: [otlp]
      exporters: [logging, elasticsearch]

8. 未来趋势:日志分析与AI运维

8.1 日志分析平台

  • Splunk:企业级日志分析与监控。
  • Graylog:开源日志管理平台。

8.2 AI驱动的日志分析

异常检测

  • Elastic Machine Learning:基于机器学习的异常检测。
  • Prometheus + Cortex:实时日志分析与告警。

根因分析

  • OpenTelemetry:分布式追踪与日志关联分析。
  • Jaeger:微服务链路追踪。

相关推荐

一招实现让Python Numpy快到飞起!

在本文中,笔者将介绍Numexpr这个强大的Python库,它可以显著提升NumPy数组的计算性能。Numexpr是一个专门用于提高NumPy数组计算性能的工具。它通过避免为中间结果分配内存,提高了缓...

通过anaconda安装python及人工智能框架pytorch安装

专栏推荐python2和python3的切换Linux安装好了之后,一般有python2和python3,linux默认的是python2,但是现在python可能马上就要被淘汰了,所以我们平时都是使...

VBA宏总崩溃?Python脚本老闪退?这招让你的代码从此“抗摔”!

导语:上周有个读者急吼吼地私信我:“老师,我写了个VBA宏整理半年数据,结果跑到第800行的时候弹出个Error1004,前功尽弃!有没有办法让宏‘抗摔’?”还有位Python新手更崩溃:“明明写了...

六种程序设计语言的循环及循环嵌套之比较(周兴富)

我在《72岁老翁学python》(六)一文里展示了仿写的第一个python程序zxf-python-cx01.py,以及试写的一个程序zxf-python-cx02.py,虽然错误多多,但是万里长征第...

简单学Python——关键字6——break和continue

Python退出循环,有break语句和continue语句两种实现方式。break语句和continue语句的区别:break语句作用是终止循环。continue语句作用是跳出本轮循环,继续下一次循...

Python循环的简单写法_python 循环写法

在之前的短文里归纳总结了Shell的循环写法,里面也提到了Python的循环,这里也对Python的循环做个简单的说明。Python的循环基本上2种:while循环和for-in循环,和Shell还是...

Python循环语句:从基础到进阶_python里面的循环语句

在Python编程语言中,循环语句是必不可少的控制流工具。它们允许重复执行一段代码,直到满足特定条件。本文将介绍Python中的两种主要循环类型:for循环和while循环,并分别结合实例来说明其用法...

Python教程(十):for循环和range()函数

今天我们将深入探讨非常有用的**for循环和内置的range()函数**—这两个工具让您能够重复执行操作并高效地遍历序列。让我们探索如何使用它们以及它们在哪些地方表现出色。今天您将学习什么什么...

《循环(for/while)》_循环for的用法

循环(for/while)循环是编程中处理重复任务的核心工具,Python提供了两种主流循环结构:for循环(遍历可迭代对象)和while循环(根据条件重复执行)。本节将系统讲解两者的语法、使用场景及...

Python循环结构精解:掌握while循环与累加算法

循环结构是程序三大基本结构之一,其本质是反复执行相同操作直到满足特定条件。现实世界中的循环无处不在:旋转的车轮人体的血液循环每日重复的学习过程Python循环分类while循环:基于条件判断的循环fo...

Python教程(十一):循环控制 – break、continue和pass

昨天,我们探索了for循环和range()函数。今天,我们将更进一步,学习如何使用三个强大的工具来控制循环内部的流程:break、continue和pass。这些命令让您能够:停止循环(break)...

AI最火语言python之循环结构_python语言中的循环结构

循环结构是指在某种情况下反复执行某段代码,其中被反复执行的代码段称之为循环体,循环结构主要负责完成重复性的工作。有for循环语句和while循环语句实现循环结构。1.for循环语句for语句主要用于实...

Python入门学习教程:第 5 章 循环语句

5.1什么是循环语句?在编程中,我们经常需要重复执行某段代码。例如,计算1到100的总和、打印列表中的所有元素等。如果手动编写每一次的执行代码,不仅繁琐,还容易出错。循环语句就是用来解决这种...

Python之Web开发框架学习-Django基础及安装

Django是一个高级PythonWeb框架,鼓励快速开发和简洁实用的设计。Django使使用更少的代码快速构建更好的Web应用程序变得更加容易。注-Django是DjangoSoftware...

Python基础入门- Python编程环境搭建-Python编译器安装

Python3下载访问https://www.python.org/进行下载Python安装双击下载的“.exe”文件即可安装手动配置python环境变量如果是在安装过程中,勾选了配置环境变量...

取消回复欢迎 发表评论: