4

是否可以在 Application Insights 中查看请求的响应正文？我看过很多关于请求正文的问题/文章，但没有发现有关响应正文的内容。

我正在构建一个 MVC 核心 2.1 Web Api。

相关文章：

在 Application Insights 中查看 POST 请求正文

这是我的代码，从流创建阅读器时出现异常，即“流不可读”。.

public class ResponseBodyInitializer : ITelemetryInitializer
{
    readonly IHttpContextAccessor httpContextAccessor;

    public ResponseBodyInitializer(IHttpContextAccessor httpContextAccessor)
    {
        this.httpContextAccessor = httpContextAccessor;
    }

    public void Initialize(ITelemetry telemetry)
    {
        if (telemetry is RequestTelemetry requestTelemetry)
        {
            HttpContext httpContext = httpContextAccessor.HttpContext;
            HttpRequest request = httpContext.Request;
            HttpResponse response = httpContext.Response;

            if (request.Method == HttpMethods.Post || 
                 request.Method == HttpMethods.Put)
            {
                //Log the response body
                if (httpContext.Response.HasStarted)
                {
                    const string responseBody = "ResponseBody";

                    if (requestTelemetry.Properties.ContainsKey(responseBody))
                    {
                        return;
                    }

                    try
                    {
                        var stream = new StreamReader(response.Body);
                        var body = stream.ReadToEnd();                            
                        response.Body.Position = 0;
                        requestTelemetry.Properties.Add(responseBody, body);
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
            }
        }
    }
}

- - - - - - - - - - - - - - - - - 更新 - - - - - - - - -----------------

这是我记录请求和响应正文的完整代码。请求正文已正确记录（使用 request.EnableRewind();），但是，响应部分在流读取器上引发异常Stream 不可读。

public class RequestBodyAndResponseBodyInitializer : ITelemetryInitializer
{
    readonly IHttpContextAccessor httpContextAccessor;

    public RequestBodyAndResponseBodyInitializer(IHttpContextAccessor httpContextAccessor)
    {
        this.httpContextAccessor = httpContextAccessor;
    }

    public void Initialize(ITelemetry telemetry)
    {
        if (telemetry is RequestTelemetry requestTelemetry)
        {
            HttpContext httpContext = httpContextAccessor.HttpContext;
            HttpRequest request = httpContext.Request;
            HttpResponse response = httpContext.Response;

            if (request.Method == HttpMethods.Post ||
                 request.Method == HttpMethods.Put)
            {
                //1- Log the request body
                if (request.Body.CanRead)
                {
                    const string requestBody = "RequestBody";
                    if (requestTelemetry.Properties.ContainsKey(requestBody))
                    {
                        return;
                    }

                    //Allows re-usage of the stream
                    request.EnableRewind();

                    var stream = new StreamReader(request.Body);
                    var body = stream.ReadToEnd();

                    //Reset the stream so data is not lost
                    request.Body.Position = 0;
                    requestTelemetry.Properties.Add(requestBody, body);
                }
                //2- Log the response body
                else if (httpContext.Response.HasStarted)
                {
                    //Allows re-usage of the stream
                    //request.EnableRewind();

                    const string responseBody = "ResponseBody";

                    if (requestTelemetry.Properties.ContainsKey(responseBody))
                    {
                        return;
                    }

                    try
                    {
                        //var stream = new StreamReader(response.Body);
                        //var body = stream.ReadToEnd();                            
                        //response.Body.Position = 0;
                        //requestTelemetry.Properties.Add(responseBody, body);

                        using (var memoryStream = new MemoryStream())
                        {
                            var stream = response.Body;
                            response.Body = memoryStream;

                            await next(context);

                            var body = new StreamReader(memoryStream).ReadToEnd();
                            //logger?.LogDebug($"Response: {responseBody}");

                            response.Body = stream;
                        }


                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
                else { }
            }
        }
    }
}
4

3 回答 3

1

你必须实施ITelemetryInitializer. 将 注入IHttpContextAccessor类并在方法中读取响应流Initialize。确保传递的ITelemetry对象来自类型RequestTelemetry并且 HttpRequest 是 Post 或 Put。然后，您可以使用该属性读取响应IHttpContext.HttpContext.Response.Body并使用 Application Insight 记录它。

最后，在 Startup.cs 的 ConfigureService 方法中注册您的类

于 2018-08-03T11:17:50.247 回答
0

我通过添加一个将请求正文保存为HttpContext. 之前注册中间件很重要，app.UseMvc()因为 Mvc 框架会处理流。

启动.cs

public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
{
    app.Use(async (httpContext, next) =>
        {
            var request = httpContext.Request;

            if (request.Method == HttpMethods.Post || request.Method == HttpMethods.Put && request.Body.CanRead)
            {
                //Allows re-usage of the stream
                request.EnableBuffering();
                request.Body.Seek(0, SeekOrigin.Begin);

                using (var stream = new StreamReader(request.Body, Encoding.UTF8, true, 1024, true))
                {
                    var body = await stream.ReadToEndAsync();
                    //Reset the stream so data is not lost
                    request.Body.Position = 0;
                    var bodyFeature = new RequestBodyFeature(body); // RequestBodyFeature is a simple POCO
                    httpContext.Features.Set(bodyFeature);
                }

                request.Body.Seek(0, SeekOrigin.Begin);
            }

            await next.Invoke();
        });

        app.UseMvc();
}

当我从我的 ExceptionFilter 登录到 ApplicationInsights 时，我会得到这样的身体：

context.HttpContext?.Features.Get<RequestBodyFeature>()?.Body

在阅读了 ApplicationInsights github 页面上的这个问题和 AspNetCore github 页面上的这个问题后，我得出了这个结论。

于 2019-10-09T10:18:30.907 回答
-1

我解决了上面的问题，我在下面的博客中解释了解决方案。基本上它涉及使用消息处理程序将响应存储在请求消息中，并在实现 ITelemetryInitialize 的类中检索相同的响应。

这是详细解释的博客。

https://thirum.wordpress.com/2019/08/19/logging-the-http-response-body-in-application-insights/

于 2019-08-21T17:20:38.020 回答