Logstash 是 ELK Stack(Elasticsearch、Logstash、Kibana)的核心组件之一,用于数据采集、处理和传输。其功能可类比为「数据管道」,支持多种输入源、过滤器和输出目标,广泛应用于日志分析、监控告警等场景。
🧰 安装与配置
安装
- 下载 Logstash 官方安装包
- 使用
tar -xzf logstash-<版本>.tar.gz
解压并配置环境变量 - 验证安装:
logstash --version
基础配置
- 输入:
input { stdin { } }
或input { file { path => "/var/log/*.log" } }
- 过滤器:
filter { grok { match => { "message" => "%{COMBINEDAPACHELOG}" } }
- 输出:
output { elasticsearch { hosts => ["localhost:9200"] } }
- 示例配置文件:Logstash 配置模板
- 输入:
📈 使用场景
- 日志集中化管理:从多台服务器采集日志,统一处理后存储到 Elasticsearch
- 实时数据处理:通过
grok
、date
等插件解析和转换数据格式 - 流量监控:结合
tcp
或udp
输入监听网络流量,分析异常行为 - 数据清洗:去除无效字段、标准化时间戳等