在监听 MongoDB Change Stream 并设置 options.ChangeStream().SetResumeAfter 后，如果收到的数据结构中没有 fullDocument 字段，可能是因为该字段被省略了。解决这个问题的方法是通过修改监听选项和查询条件。
首先，确保在创建 Change Stream 时使用 options.ChangeStream().SetFullDocument(mongodb.FullDocumentDefault) 设置完整文档的策略为默认模式。这样可以确保在数据变动时返回完整文档。
示例代码如下：
package main
import (
"context"
"fmt"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
func main() {
client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://localhost:27017"))
if err != nil {
fmt.Println("Failed to connect to MongoDB:", err)
return
}
collection := client.Database("your-database").Collection("your-collection")
pipeline := []bson.M{{"$match": bson.M{"operationType": "insert"}}}
changeStreamOptions := options.ChangeStream().SetFullDocument(mongo.FullDocumentDefault)
changeStream, err := collection.Watch(context.TODO(), pipeline, changeStreamOptions)
if err != nil {
fmt.Println("Failed to open change stream:", err)
return
}
defer changeStream.Close(context.TODO())
for changeStream.Next(context.TODO()) {
var changeEvent bson.M
if err := changeStream.Decode(&changeEvent); err != nil {
fmt.Println("Error decoding change event:", err)
continue
}
fullDocument := changeEvent["fullDocument"]
// 处理收到的完整文档
fmt.Println("Received full document:", fullDocument)
}
if err := changeStream.Err(); err != nil {
fmt.Println("Error in change stream:", err)
return
}
}
这样，你应该能够在监听到 MongoDB Change Stream 时收到包含完整文档的数据。注意修改 your-database 和 your-collection 为你自己的数据库和集合名称。
如果还是没有收到完整文档，可能是由于其他原因导致，比如权限设置不正确或者 MongoDB 版本兼容性问题。此时建议查看 MongoDB 官方文档以了解更多详细信息，并确保使用的驱动程序版本与 MongoDB 版本相匹配。
内容由零声教学AI助手提供，问题来源于学员提问
&1 请帮我分析有什么问题，这是在操作shar..." />
