你可以使用mgo（MongoDB的Go语言驱动程序）来监听MongoDB集合并提取指定字段，然后在管道（pipeline）中使用$project操作符进行筛选。以下是一个示例代码：
package mainimport ("fmt""log""time""gopkg.in/mgo.v2""gopkg.in/mgo.v2/bson")type MyModel struct {ID bson.ObjectId `bson:"_id,omitempty"`Field string `bson:"field"`}func main() {session, err := mgo.Dial("mongodb://localhost:27017")if err != nil {log.Fatal(err)}defer session.Close()collection := session.DB("yourdb").C("yourcollection")pipeline := []bson.M{bson.M{"$match": bson.M{}}, // 这里可以设置更详细的查询条件bson.M{"$project": bson.M{"field": 1}},}changeStreamOpts := &mgo.ChangeStreamOptions{BatchSize: 0,Pipe: pipeline,}stream := collection.Watch([]bson.D{}, changeStreamOpts)go func() {for stream.Next(&MyModel{}) {doc := stream.Value.(*MyModel)fmt.Printf("Field value: %s\n", doc.Field)// 在这里处理你需要的逻辑}if err := stream.Err(); err != nil {log.Fatal(err)}}()time.Sleep(5 * time.Minute) // 监听5分钟后退出程序stream.Close()}
以上代码通过mgo连接到MongoDB数据库，并设置了一个管道（pipeline），其中包含$match和$project操作符。你可以在$match操作符中设置更具体的查询条件。然后，创建一个Change Stream来监听集合变化，并使用循环获取每个文档的指定字段值。
请注意，此示例代码仅供参考，请根据你的实际需求进行修改。
内容由零声教学AI助手提供，问题来源于学员提问
![[GIN-debug] [WARNING] Creating an Engine instance with the Logger and Recovery middleware already attached.](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162234452257235.png)
