использовать Ие агрегатный итератор данные в upsert без демаршалинга

Question

Прежде всего, я очень новые идти :)

Я пытаюсь сделать агрегат + upsert в Монго, используя идти и драйвер ЕГО.

Мой код выглядит примерно так:

pipe := c.Pipe([]bson.M{{"$match": bson.M{"name":"John"}}}) 
iter := pipe.Iter() 
resp := []bson.M{} 

for iter.Next(&resp) { 
    // 
    // read "value.sha1" from each response 
    // do a: 
    // otherCollection.Upsert(bson.M{"value.sha1": mySha1}, resp) 
    // 
} 

Ответ от совокупного сбора может иметь много в форматах, поэтому я не могу определение структуры для него.

Мне просто нужно получить одно из полей ответа, которое является sha1, и обновить другую коллекцию с полученным откликом на основе состояния sha1.

Может ли кто-нибудь указать мне в правильном направлении?

Answer 1

Возможно, я вас неправильно понял, но вы можете просто получить доступ к возвращенным документам как map. Что-то вроде этого:

pipe := c.Pipe([]bson.M{}) 
iter := pipe.Iter() 
resp := bson.M{} // not array as you are using iterator which returns single document 

for iter.Next(&resp) { 
    otherCollection.Upsert(bson.M{"value.sha1": result["value"].(bson.M)["sha1"]}, resp) 
}