在Go语言中，您可以使用MongoDB的Change Streams功能来监听集合中指定字段的变化。下面是一个示例代码，展示了如何实现这个功能：
package mainimport ("context""fmt""log""go.mongodb.org/mongo-driver/bson""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 {log.Fatal(err)}collection := client.Database("yourDatabase").Collection("yourCollection")pipeline := []bson.M{bson.M{"$match": bson.M{"operationType": "update"}},bson.M{"$project": bson.M{"fullDocument.name": 1, "fullDocument.age": 1}},}opts := options.ChangeStream().SetFullDocument(options.UpdateLookup)changeStream, err := collection.Watch(context.TODO(), pipeline, opts)if err != nil {log.Fatal(err)}defer changeStream.Close(context.Background())for changeStream.Next(context.Background()) {var changeEvent struct {Name string `bson:"name"`Age int `bson:"age"`ID struct {ObjectID string `bson:"_id"`} `bson:"_id"`Namespace string `bson:"ns"`Type string `bson:"type"`}if err := changeStream.Decode(&changeEvent); err != nil {log.Println(err)}fmt.Printf("Name: %s\n", changeEvent.Name)fmt.Printf("Age: %d\n", changeEvent.Age)}if err := changeStream.Err(); err != nil {log.Fatal(err)}}
在上述代码中，您需要将yourDatabase替换为实际的数据库名称，yourCollection替换为实际的集合名称。pipeline变量定义了一个数组，包含了两个阶段：$match用于筛选操作类型为update的文档，并且只保留name和age字段；$project用于返回指定字段。
最后，在循环中通过解码changeStream来获取相应的字段值，以便处理业务逻辑。
请注意，以上代码仅提供了监听和提取指定字段的示例，并不能保证能够直接运行。具体的实现还要根据您的环境和需求进行适当调整。
内容由零声教学AI助手提供，问题来源于学员提问
