美文网首页
json格式的请求日志

json格式的请求日志

作者: EasyNetCN | 来源:发表于2020-07-19 07:36 被阅读0次

    主要使用的包

    package main
    
    import (
        "fmt"
        "io"
        "os"
        "strings"
        "time"
    
        "github.com/kataras/iris/v12"
        "github.com/kataras/iris/v12/middleware/logger"
    )
    

    退出时是否删除日志文件

    const (
        LOG_DELETE_FILE_ON_EXIT = false
    )
    

    不记录的路径和文件后缀名

    var (
        EXCLUDE_PATHS = [...]string{
            HEALTH_CHECK_URL,
        }
        EXCLUDE_EXTENSIONS = [...]string{
            ".js",
            ".css",
            ".jpg",
            ".png",
            ".ico",
            ".svg",
        }
    )
    

    logger和文件

    func newRequestLogger(newWriter io.Writer) iris.Handler {
        c := logger.Config{}
    
        c.AddSkipper(func(ctx iris.Context) bool {
            path := ctx.Path()
    
            for _, p := range EXCLUDE_PATHS {
                if strings.HasPrefix(path, p) {
                    return true
                }
    
            }
    
            for _, ext := range EXCLUDE_EXTENSIONS {
                if strings.HasSuffix(path, ext) {
                    return true
                }
            }
            return false
        })
    
        c.LogFuncCtx = func(ctx iris.Context, latency time.Duration) {
            datetime := time.Now().Format(ctx.Application().ConfigurationReadOnly().GetTimeFormat())
            customHandlerMessage := ctx.Values().GetString("log_message")
    
            jsonStr := fmt.Sprintf(`{"@timestamp":"%s","level":"%s","latency": "%s","ip":"%s""status": %d,"method":"%s","path":"%s","message":"%s"}`,
                datetime, "INFO", latency.String(), ctx.RemoteAddr(), ctx.GetStatusCode(), ctx.Method(), ctx.Path(), customHandlerMessage)
    
            fmt.Fprintln(newWriter, jsonStr)
        }
    
        return logger.New(c)
    }
    
    func todayFilename() string {
        return fmt.Sprintf("%s.log", time.Now().Format(utility.DATE_PATTERN))
    }
    
    func newLogFile() *os.File {
        path := "./logs"
        filename := fmt.Sprintf("%s/%s", path, todayFilename())
    
        if _, err := os.Stat(path); os.IsNotExist(err) {
            os.Mkdir(path, 0777)
            os.Chmod(path, 0777)
        }
    
        f, err := os.OpenFile(filename, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
    
        if err != nil {
            panic(err)
        }
    
        return f
    }
    

    main中配置logger

    func main() {
        app := iris.Default()
    
        app.Use(iris.Gzip)
    
        logFile := newLogFile()
    
        defer func() {
            logFile.Close()
    
            if LOG_DELETE_FILE_ON_EXIT {
                os.Remove(logFile.Name())
            }
        }()
    
        r := newRequestLogger(logFile)
    
        app.Use(r)
    
        app.Listen(fmt.Sprintf(":%d", conf.Server.Port), iris.WithOptimizations, iris.WithTimeFormat(utility.DATE_TIME_PATTERN))
    }
    

    相关文章

      网友评论

          本文标题:json格式的请求日志

          本文链接:https://www.haomeiwen.com/subject/ytflkktx.html