您可以使用 Watch() 方法在 Collection、Database 或 Client 上打开变更流。
例子
提示
参阅“使用示例”，了解如何运行此示例。
以下示例在restaurants collection 上打开 change stream 并打印插入的文档：
coll := client.Database("sample_restaurants").Collection("restaurants")
// Creates instructions to watch for insert operationspipeline := mongo.Pipeline{bson.D{{"$match", bson.D{{"operationType", "insert"}}}}}
// Creates a change stream that receives change eventscs, err := coll.Watch(context.TODO(), pipeline)if err != nil { panic(err)}defer cs.Close(context.TODO())
fmt.Println("Waiting For Change Events. Insert something in MongoDB!")
// Prints a message each time the change stream receives an eventfor cs.Next(context.TODO()) { var event bson.M if err := cs.Decode(&event); err != nil { panic(err) } output, err := json.MarshalIndent(event["fullDocument"], "", " ") if err != nil { panic(err) } fmt.Printf("%s\n", output)}if err := cs.Err(); err != nil { panic(err)}预期结果
运行完整示例后，在不同的 shell 中运行插入文档使用示例。运行插入操作后，应会看到以下输出：
// results truncated{ "_id": ..., "name": "8282", "cuisine": "Korean"}重要
完成后请务必关闭终端以关闭此使用示例。
更多信息
要了解有关打开变更流和处理潜在错误的更多信息，请参阅：