使用Serilog/Elasticsearch/Kibana时，如何合并请求响应日志为单文档？

方法1：自定义Serilog请求日志配置（无需额外自定义中间件） #

Serilog.AspNetCore内置的UseSerilogRequestLogging支持扩展日志上下文，可将请求和响应的关键字段统一注入到同一条日志事件中，避免拆分多文档。

步骤1：配置请求日志增强 #

在Program.cs中，调整请求日志的配置，添加需要的请求/响应属性：

app.UseSerilogRequestLogging(options =>
{
    // 自定义日志消息模板
    options.MessageTemplate = "Request {RequestMethod} {RequestPath} completed with status {StatusCode}";
    
    // 扩展诊断上下文，注入请求/响应字段
    options.EnrichDiagnosticContext = (diagnosticContext, httpContext) =>
    {
        // 请求相关字段
        diagnosticContext.Set("RequestContentType", httpContext.Request.ContentType);
        diagnosticContext.Set("RequestAcceptLanguage", httpContext.Request.Headers["Accept-Language"].FirstOrDefault());
        
        // 响应相关字段（需先启用响应体缓冲）
        if (httpContext.Items.TryGetValue("ResponseBody", out var responseBody))
        {
            diagnosticContext.Set("ResponseBody", responseBody.ToString());
        }
        diagnosticContext.Set("ResponseContentType", httpContext.Response.ContentType);
    };
});

步骤2：启用响应体缓冲（轻量管道配置） #

要读取响应体内容，需让ASP.NET Core缓冲响应流，在UseSerilogRequestLogging之前添加：

// 启用响应体缓冲，以便后续读取并写入日志
app.Use(async (context, next) =>
{
    var originalResponseBody = context.Response.Body;
    using var responseStream = new MemoryStream();
    context.Response.Body = responseStream;

    await next();

    responseStream.Seek(0, SeekOrigin.Begin);
    var responseBody = await new StreamReader(responseStream).ReadToEndAsync();
    responseStream.Seek(0, SeekOrigin.Begin);
    
    // 将响应体存入HttpContext，供日志上下文读取
    context.Items["ResponseBody"] = responseBody;
    
    // 把缓冲内容写回原始响应流，保证正常返回
    await responseStream.CopyToAsync(originalResponseBody);
    context.Response.Body = originalResponseBody;
});

方法2：用关联ID聚合日志（无需合并文档） #

如果暂时无法合并日志，可通过Correlation ID将同一请求的所有日志文档关联，在Kibana中通过ID快速筛选所有相关日志：

配置关联ID增强器 #

builder.Host.UseSerilog((context, configuration) =>
{
    configuration
        .Enrich.WithCorrelationId() // 自动生成或从请求头读取Correlation ID
        .WriteTo.Elasticsearch(new ElasticsearchSinkOptions(new Uri("http://your-elasticsearch-url:9200"))
        {
            IndexFormat = "app-logs-{0:yyyy.MM.dd}",
            AutoRegisterTemplate = true
        });
});

之后在Kibana中，只需搜索CorrelationId:"xxx"就能定位到该请求的所有日志文档。

关键注意事项 #

• 确保使用**Serilog.AspNetCore 5.0+**版本，内置请求日志功能更完善
• 生产环境避免记录大体积响应体，可添加大小判断逻辑
• Elasticsearch Sink配置中，确保BatchPostingLimit等参数合理，避免日志意外拆分

内容的提问来源于stack exchange，提问作者Serdar Yiğit Yanık