如何从 mongo-driver go 包访问多个 goroutine 中的同一游标-解网

问：

我正在使用多个 goroutines 从 MongoDB golang sdk 中的光标读取文档。但它没有返回所有文件。注意：它与单个 goroutine 一起正常工作。

我想从多个 goroutine 中读取来自同一集合游标的所有文档

示例代码：

cursor, err := coll.Find(context.TODO(), filter, opts)
if err != nil {
    fmt.Println("Finding all documents ERROR:", err)
    defer cursor.Close(ctx)

    // If the API call was a success
} else {

    // iterate over docs using Next()
    for cursor.Next(ctx) {
     ...............
  }

}

MongoDB Go 集合 SDK 游标

如果您有多个 goroutines 调用，那么当任何 goroutines 调用时，光标将在所有 goroutinges 中前进。你可能想做的是有一个用于读取的 goroutine，但随后你可以将结果传递给一个通道，然后你可以在一个单独的 goroutine 中处理每个文档。像这样：cursor.Nextcursor.Next

dataChannel := make(chan mongoResult)

func handleMongoResults() {
    for {
        res := <-dataChannel
        // do something
    }
}

go handleMongoResults()
go handleMongoResults()


for cursor.Next(ctx) {
    var result mongoResult
    if err := cursor.Decode(&result); err != nil {
        log.Fatal(err)
    }
    dataChannel <- result
}

然后显然，请确保在处理完结果后退出 goroutines。

如何从 mongo-driver go 包访问多个 goroutine 中的同一游标

How to access a same cursor in multiple goroutines from mongo-driver go package

评论

评论