агрегации MongoDB в golang

Question

У меня есть коллекция MongoDB, как это:

{ 
    source: "...", 
    url: "...", 
    comments: [ 
     ..... 
    ] 
} 

Я хотел бы найти первые 5 документов, основанных на количестве комментариев. Я могу найти нужный результат, используя следующий запрос в командной строке:

db.gmsNews.aggregate([ 
    { 
    $match:{source:"..."} 
    }, 
    { 
    $unwind: "$comments" 
    }, 
    { 
    $group: { 
     _id: "$url", 
     size: { 
      $sum: 1 
     }, 
    } 
    }, 
    { 
    $sort : { size : -1 } 
    }, 
    { 
    $limit : 5 
    } 
]) 

Это дает мне следующий вывод:

{ "_id" : "...", "size" : 684 } 
{ "_id" : "...", "size" : 150 } 

Теперь я хотел бы перевести этот запрос в golang с помощью драйвера ЕГО , Я использую трубу для этого следующим образом:

o1 := bson.M{ 
     "$match" :bson.M {"source":"..."}, 
} 

o2 := bson.M{ 
    "$unwind": "$comments", 
} 

o3 := bson.M{ 
    "$group": bson.M{ 
     "_id": "$url", 
     "size": bson.M{ 
      "$sum": 1, 
     }, 
    }, 
} 

o4 := bson.M{ 
    "sort": bson.M{ 
     "size": -1, 
    }, 
} 

o5 := bson.M{ 
    "$limit": 5, 
} 

operations := []bson.M{o1, o2, o3, o4, o5} 

pipe := c.Pipe(operations) 

// Run the queries and capture the results 
results := []bson.M{} 
err1 := pipe.One(&results) 

if err1 != nil { 
    fmt.Printf("ERROR : %s\n", err1.Error()) 
    return 
} 

fmt.Printf("URL : %s, Size: %sn", results[0]["_id"], results[0]["size"]) 

К сожалению, это не работает, и я получаю следующий результат:

ERROR : Unsupported document type for unmarshalling: []bson.M 

Просто интересно, что я делаю неправильно и как разрешите это.

Любая помощь будет высоко оценена.

Заранее спасибо.

Ripul

Answer 1

Изменить

err1 := pipe.One(&results) 

в

err1 := pipe.All(&results)