将应用日志集成到 ELK 系统中，不同类型的应用有不同的集成方法： ### Python 应用 可使用 Logstash 收集 Python 日志，不过文档未提及具体收集方法，可参考通用的 Logstash 配置思路。先确保 Logstash 已正确安装和配置，在 Logstash 的配置文件里，定义输入部分指向 Python 应用日志文件路径，使用`file`插件读取日志；过滤部分按需对日志进行处理，例如用`grok`插件解析日志格式；输出部分将处理后的日志数据发送到 Elasticsearch 中存储。示例配置如下： ``` input { file { path => "/path/to/your/python/app.log" start_position => "beginning" } } filter { grok { match => { "message" => "%{COMBINEDAPACHELOG}" } } } output { elasticsearch { hosts => ["localhost:9200"] index => "python_app_logs" } } ``` ### Spring Boot 应用 1. **添加依赖**：在系统中添加 maven 依赖。在`pom.xml`文件里添加如下代码： ```xml <dependency> <groupId>net.logstash.logback</groupId> <artifactId>logstash-logback-encoder</artifactId> <version>6.6</version> </dependency> ``` 2. **配置 logback.xml**：对系统中的`logback.xml`进行配置，让 Spring Boot 应用的日志输出到 Logstash。示例配置如下： ```xml <appender name="LOGSTASH" class="net.logstash.logback.appender.LogstashTcpAppender"> <destination>localhost:9250</destination> <encoder class="net.logstash.logback.encoder.LogstashEncoder"> </encoder> </appender> <root level="info"> <appender-ref ref="LOGSTASH" /> </root> ``` ### Typer 应用 借助 Typer 的参数系统动态控制日志级别，同时可将日志集成到 ELK 系统。示例代码如下： ```python import typer import logging from enum import Enum class LogLevel(str, Enum): DEBUG = "DEBUG" INFO = "INFO" WARNING = "WARNING" ERROR = "ERROR" CRITICAL = "CRITICAL" app = typer.Typer() def setup_logging(level: LogLevel = LogLevel.INFO): """配置日志系统""" logging.basicConfig( level=level.value, format='%(asctime)s - %(levelname)s - %(message)s', datefmt='%Y-%m-%d %H:%M:%S' ) return logging.getLogger(__name__) @app.command() def run_task( task_name: str, log_level: LogLevel = typer.Option(LogLevel.INFO, help="设置日志级别") ): """运行指定任务""" logger = setup_logging(log_level) logger.info(f"开始执行任务: {task_name}") # 任务执行逻辑 logger.debug("任务详细执行信息") logger.info("任务执行完成") ``` 要把 Typer 应用的日志集成到 ELK，可使用 Logstash 收集日志，在 Logstash 配置文件中定义输入部分为 Typer 应用的日志文件路径，过滤和输出部分与上述 Python 应用配置类似。