在Golang中监听MongoDB集合，并提取指定字段并在pipeline中设置$project，可以使用官方提供的go.mongodb.org/mongo-driver驱动来实现。
首先，需要创建一个监听器以监视MongoDB集合的变化。以下是一个示例代码：
package main
import (
"context"
"fmt"
"log"
"time"
"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("your_database").Collection("your_collection")
pipeline := []bson.M{
bson.M{
"$match": bson.M{
"operationType": "insert",
},
},
bson.M{
"$project": bson.M{
"name": 1,
"age": 1,
},
},
}
changeStream, err := collection.Watch(context.TODO(), pipeline, options.ChangeStream().SetFullDocument(options.UpdateLookup))
if err != nil {
log.Fatal(err)
}
for changeStream.Next(context.Background()) {
var result bson.D
if err := changeStream.Decode(&result); err != nil {
log.Fatal(err)
}
// 处理返回结果
fmt.Println(result)
}
if err := changeStream.Err(); err != nil {
log.Fatal(err)
}
}
上述代码连接到本地MongoDB数据库，并选择了特定的数据库和集合。然后定义了一个pipeline数组，其中包含了匹配操作类型为”insert”的\(match阶段，以及\)project阶段来指定提取的字段。在监听到变化时，将打印出相应的结果。
请注意替换代码中的”your_database”和”your_collection”为实际的数据库和集合名称。同时，确保已经导入了所需的驱动和依赖项。
希望以上信息对你有所帮助！
内容由零声教学AI助手提供，问题来源于学员提问
![make[5]: Entering directory `/home/onvif/gsoap_2.8.116/gsoap-2.8/gsoap/wsdl'
g++ -DWSDL2H_IMPORT_PATH=](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162234068218239.png)
![0 ? data :[{}]":scrol1l="{x:'max-content'}
:pagination="{
pageSize: pageSize,
showSizeChanger: true,
onShowSiz...](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162214216277121.png)
![make[5]: Entering directory `/home/onvif/gsoap_2.8.116/gsoap-2.8/gsoap/wsdl'
g++ -I/usr/lib64/include -DWITH_OPENSSL -DWITH_GZIP -DWSDL2H_IMPORT_PATH=](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162217459776743.png)
