gorm sql监控上报

import (
  "gorm.io/gorm"
  "gorm.io/driver/sqlite"
  "gorm.io/plugin/prometheus"
)

db, err := gorm.Open(sqlite.Open("gorm.db"), &gorm.Config{})

db.Use(prometheus.New(prometheus.Config{
  DBName:          "db1", // use `DBName` as metrics label
  RefreshInterval: 15,    // Refresh metrics interval (default 15 seconds)
  PushAddr:        "prometheus pusher address", // push metrics if `PushAddr` configured
  StartServer:     true,  // start http server to expose metrics
  HTTPServerPort:  8080,  // configure http server port, default port 8080 (if you have configured multiple instances, only the first `HTTPServerPort` will be used to start server)
  MetricsCollector: []prometheus.MetricsCollector {
    &prometheus.MySQL{
      VariableNames: []string{"Threads_running"},
    },
  },  // user defined metrics
}))

type StatsLog struct {
	tally.Scope
	gormLogger *gormzap.Logger
}

func (log *StatsLog) Print(v ...interface{}) {
	log.stats(v)
	log.gormLogger.Print(v...)
}

func (log *StatsLog) stats(values []interface{}) {
	if len(values) > 1 {
		var level = values[0]
		source := getSource(values)

		if level == "sql" && log.Scope != nil {
			duration := getDuration(values)
			sql := values[3].(string)
			tags := map[string]string{
				"sql":       sql,
				"source":    source,
			}
			log.Scope.Tagged(tags).Histogram("metrics", HistogramBuckets).RecordDuration(duration)
		} 
	}
}