golang检查mongodb数据库数据变化，发生减少时执行打印操作，打印出减少的数据

你可以使用 MongoDB 的 Change Streams 功能来监控数据库的变化。在 Go 语言中，你可以使用 mongo-go-driver 库来连接到 MongoDB 数据库，并使用 ChangeStreams() 方法来设置监控。

下面是一个示例代码：

package main

import (
	"context"
	"fmt"
	"time"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

func main() {
	// 创建 MongoDB 连接
	client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))
	if err != nil {
		fmt.Println(err)
		return
	}
	err = client.Connect(context.TODO())
	if err != nil {
		fmt.Println(err)
		return
	}

	// 获取要监控的集合
	collection := client.Database("mydb").Collection("mycollection")

	// 设置监控选项
	changeStreamOptions := options.ChangeStream().SetFullDocument(options.UpdateLookup)

	// 创建 Change Stream
	changeStream, err := collection.Watch(context.TODO(), mongo.Pipeline{}, changeStreamOptions)
	if err != nil {
		fmt.Println(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(err)
			return
		}
		fmt.Println(changeEvent)

		// 如果发现数据减少，打印出减少的数据
		if changeEvent["operationType"].(string) == "delete" {
			fmt.Println("Deleted document: ", changeEvent["documentKey"])
		}
	}

	if err := changeStream.Err(); err != nil {
		fmt.Println(err)
		return
	}
}

在这个示例中，我们使用了 ChangeStreams() 方