내 mgo 쿼리를 실행하는 데 500-650ms가 걸리는 이유는 무엇입니까?

mgo - 쿼리 성능이 지속적으로 느린 것 같습니다(500-650ms)

문제:

Mongo 집계 쿼리에 약 사용에도 불구하고 반환하는 데 500~650밀리초가 걸립니다. mgo.

샘플 쿼리:

func (r userRepo) GetUserByID(id string) (User, error) {
    info, err := db.Info()
    if err != nil {
        log.Fatal(err)
    }

    session, err := mgo.Dial(info.ConnectionString())
    if err != nil {
        log.Fatal(err)
    }
    defer session.Close()

    var user User
    c := session.DB(info.Db()).C("users")
    o1 := bson.M{"$match": bson.M{"_id": id}}
    o2 := bson.M{"$project": bson.M{
        "first":           "$first",
        "last":            "$last",
        "email":           "$email",
        "fb_id":           "$fb_id",
        "groups":          "$groups",
        "fulfillments":    "$fulfillments",
        "denied_requests": "$denied_requests",
        "invites":         "$invites",
        "requests": bson.M{
            "$filter": bson.M{
                "input": "$requests",
                "as":    "item",
                "cond": bson.M{
                    "$eq": []interface{}{"$$item.active", true},
                },
            },
        },
    }}
    pipeline := []bson.M{o1, o2}
    err = c.Pipe(pipeline).One(&user)
    if err != nil {
        return user, err
    }
    return user, nil
}

질문: 쿼리 성능이 느린 이유가 분명한가요?

힌트: mgo.Dial() 메서드가 이전에 호출되고 있습니다.

답변:

예, 성능 저하의 원인은 mgo.Dial()에 대한 반복 호출 때문일 수 있습니다. 이 방법은 매번 MongoDB 서버에 대한 연결을 설정하며 수백 밀리초가 걸릴 수 있습니다. 이 문제를 해결하려면 전역 세션 변수를 생성하고 시작 시 연결을 한 번 설정한 후(예: 패키지 init() 함수에서) 모든 쿼리에 해당 세션(또는 그 복사본)을 사용하세요.

해결책:

var session *mgo.Session
var info *db.Inf // Use your type here

func init() {
    var err error
    if info, err = db.Info(); err != nil {
        log.Fatal(err)
    }
    if session, err = mgo.Dial(info.ConnectionString()); err != nil {
        log.Fatal(err)
    }
}

func (r userRepo) GetUserByID(id string) (User, error) {
    sess := session.Clone()
    defer sess.Close()

    var user User
    c := sess.DB(info.Db()).C("users")
    o1 := bson.M{"$match": bson.M{"_id": id}}
    o2 := bson.M{"$project": bson.M{
        "first":           "$first",
        "last":            "$last",
        "email":           "$email",
        "fb_id":           "$fb_id",
        "groups":          "$groups",
        "fulfillments":    "$fulfillments",
        "denied_requests": "$denied_requests",
        "invites":         "$invites",
        "requests": bson.M{
            "$filter": bson.M{
                "input": "$requests",
                "as":    "item",
                "cond": bson.M{
                    "$eq": []interface{}{"$$item.active", true},
                },
            },
        },
    }}
    pipeline := []bson.M{o1, o2}
    err = c.Pipe(pipeline).One(&user)
    if err != nil {
        return user, err
    }
    return user, nil
}

위 내용은 내 mgo 쿼리를 실행하는 데 500-650ms가 걸리는 이유는 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!