卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章34806本站已运行393

使用 gRPC 中间件中的 Uber/Zap 日志记录获取 Go 中的实际错误源

使用 grpc 中间件中的 uber/zap 日志记录获取 go 中的实际错误源

php小编子墨在本文中将介绍如何在使用gRPC中间件时,利用Uber/Zap日志记录来获取Go语言中的实际错误源。通过使用该中间件,我们可以更好地了解和追踪代码中出现的错误,从而更快地定位和解决问题。本文将详细介绍如何配置和使用Uber/Zap日志记录,以及如何在gRPC请求和响应中捕获和记录错误信息。通过掌握这些技巧,我们可以提高我们在gRPC应用程序中的调试和错误处理能力。

问题内容

我正在使用 uber/zap 包进行日志记录。 在我的设计中,我记录了 grpc 包的中间件中的所有错误。 我想记录错误来自哪个文件和行号。 但是,目前我只能获取当前中间件的文件名和行号。 有什么方法可以获取错误的实际来源吗?

func RegisterLogger(c config.Config) *zap.SugaredLogger {

    var logger *zap.Logger
    var err error
    if c.IsDebug {
        logger, err = zap.NewDevelopment()
    } else {
        logger, err = zap.NewProduction()
    }

    if err != nil {
        panic(err)
    }
    defer logger.Sync()

    return logger.Sugar()
}



func (s *ProviderServer) Pay(ctx context.Context, in *payment.PayRequest) (string, error) {
    resp, err := ctx.Value(in.Provider).(provider.IPayment).Exec(ctx, in)

    if err != nil {
            pc, file, line, ok := runtime.Caller(2)
            if ok {
                file = filepath.Base(file)
                nowTime := time.Now().Format("2006/01/02 15:04:05")
                funcName := runtime.FuncForPC(pc).Name()
                funcName = filepath.Ext(funcName)
                funcName = strings.TrimPrefix(funcName, ".")
                s.log.Info("Times:", i, " nowTime:", nowTime, " file:", file, " line:", line, " funcName:", funcName, " err:", err)
            }
        
//Log the error information, including which file the error comes from.

        return resp.Result, err
    } else {
        s.log.Info("resp:", resp)
    }

}

解决方法

在当前的实现中,您尝试记录发生错误的文件和行号。但是,您获得的信息是针对当前中间件的,而不是错误的实际来源。

要获取错误实际来源的文件和行信息,您可以使用 pkg/errors 包。该包提供了一种包装错误并保留文件和行信息的方法。以下是如何修改代码以实现此目的的示例:

import (
    "github.com/pkg/errors"
)

// ...

func (s *ProviderServer) Pay(ctx context.Context, in *payment.PayRequest) (string, error) {
    resp, err := ctx.Value(in.Provider).(provider.IPayment).Exec(ctx, in)

    if err != nil {
        // Wrap the error with file and line information
        err = errors.Wrap(err, "pay error")

        // Log the wrapped error
        s.log.Errorw("Error occurred", "error", err)

        return resp.Result, err
    } else {
        s.log.Infow("Request processed successfully", "response", resp)
        return resp.Result, nil
    }
}

通过使用 errors.wrap 函数包装错误,您可以将文件和行信息添加到错误中。然后,当使用 s.log.errorw 记录错误时,日志消息将包含完整的堆栈跟踪,包括错误起源的文件和行信息。

这样,您就可以使用 errors 包提供的信息来跟踪错误的实际来源。

卓越飞翔博客
上一篇: 有没有办法约束(通用)类型参数?
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏