詳解MongoDB?Go?Driver如何記錄日志

更新時(shí)間：2023年08月20日 14:54:56 作者：小白要生發(fā)

這篇文章主要為大家介紹了MongoDB?Go?Driver如何記錄日志詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

引言

如果你有這些問題：

golang 官方的 mongo driver 怎么執(zhí)行了沒有日志輸出啊
golang mongo driver 如何記錄sql，如何打印執(zhí)行的命令
想通過日志來檢查 golang mongo 調(diào)用API是否符合預(yù)期

那么這篇文章可以繼續(xù)看下去。

背景

在這之前我使用 MySQL 是比較多的，后來遇到有記錄用戶操作日志需求，隨著數(shù)據(jù)量越來越大，MySQL 有些扛不?。?，就換成了 Mongo，在使用Mongo過程中，發(fā)現(xiàn)沒法記錄日志，就是無法將打印代碼發(fā)起的sql，之前使用gorm打印execute sql是很方便的。

在網(wǎng)上查了好久也沒查到相關(guān)資料，就開始翻官方文檔，和源碼。

終于在不懈~ 打住，其實(shí)很簡(jiǎn)單，就在 ClientOptions 字段里：

// ClientOptions contains options to configure a Client instance. Each option can be set through setter functions. See
// documentation for each setter function for an explanation of the option.
type ClientOptions struct {
    AppName                  *string
    Auth                     *Credential
    AutoEncryptionOptions    *AutoEncryptionOptions
    ...
    MaxConnecting            *uint64
    PoolMonitor              *event.PoolMonitor
    Monitor                  *event.CommandMonitor // 執(zhí)行的命令監(jiān)視器(日志)
    ServerMonitor            *event.ServerMonitor
    ...
    err error
    uri string
    cs  *connstring.ConnString

github 代碼地址

ClientOptions.Monitor字段

使用方法如下：

package mongolearn
import (
    "context"
    "fmt"
    "log"
    "time"
    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/event"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)
var (
    mongoDsn = "mongodb://admin:123456@127.0.0.1:27017"
)
// TestConnUseDb sql monitor
func TestConnWithMonitor() {
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()
    // client option
    var clientOpt = options.Client().ApplyURI(mongoDsn)
    // log monitor
    var logMonitor = event.CommandMonitor{
        Started: func(ctx context.Context, startedEvent *event.CommandStartedEvent) {
            log.Printf("mongo reqId:%d start on db:%s cmd:%s sql:%+v", startedEvent.RequestID, startedEvent.DatabaseName,
                startedEvent.CommandName, startedEvent.Command)
        },
        Succeeded: func(ctx context.Context, succeededEvent *event.CommandSucceededEvent) {
            log.Printf("mongo reqId:%d exec cmd:%s success duration %d ns", succeededEvent.RequestID,
                succeededEvent.CommandName, succeededEvent.DurationNanos)
        },
        Failed: func(ctx context.Context, failedEvent *event.CommandFailedEvent) {
            log.Printf("mongo reqId:%d exec cmd:%s failed duration %d ns", failedEvent.RequestID,
                failedEvent.CommandName, failedEvent.DurationNanos)
        },
    }
    // cmd monitor set
    clientOpt.SetMonitor(&logMonitor)
    client, err := mongo.Connect(ctx, clientOpt)
    if nil != err {
        fmt.Printf("mongo connect err %v\n", err)
    } else {
        fmt.Printf("mongo connect success~\n")
        defer func() {
            if err = client.Disconnect(ctx); err != nil {
                panic(err)
            }
        }()
    }
    // update test
    if re, err := client.Database("test").Collection("test").UpdateOne(ctx, bson.M{"name": "cc"}, bson.M{"$set": bson.M{"age": 12}}); err != nil {
        log.Printf("%v", err)
    } else {
        log.Printf("mongo update one re %+v", re)
    }
}

輸出結(jié)果

mongo connect success~
2023/08/20 13:22:43 mongo reqId:6 start on db:test cmd:update sql:{"update": "test","ordered": true,"lsid": {"id": {"$binary":{"base64":"qfrrzSt7SkCN5ChY04/T5A==","subType":"04"}}},"$db": "test","updates": [{"q": {"name": "cc"},"u": {"$set": {"age": {"$numberInt":"12"}}}}]}
2023/08/20 13:22:43 mongo reqId:6 exec cmd:update success duration 44489114 ns
2023/08/20 13:22:43 mongo update one re &{MatchedCount:0 ModifiedCount:0 UpsertedCount:0 UpsertedID:<nil>}

# 下面是斷開 mongo 時(shí)觸發(fā)的命令
2023/08/20 13:22:43 mongo reqId:7 start on db:admin cmd:endSessions sql:{"endSessions": [{"id": {"$binary":{"base64":"qfrrzSt7SkCN5ChY04/T5A==","subType":"04"}}}],"$db": "admin"}
2023/08/20 13:22:43 mongo reqId:7 exec cmd:endSessions success duration 58037162 ns

通過以上日志可以看到，mongo 的 monitor 按照 Started, Succeeded 順序記錄，最后才會(huì)執(zhí)行函數(shù)外的日志。

以上就是詳解MongoDB Go Driver如何記錄日志的詳細(xì)內(nèi)容，更多關(guān)于MongoDB Go Driver記錄日志的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: