写个golang可以监听mongodb删除事件，并取得删除数据的OwnerID、name 、QuotaSize

### 回答1：
好的，以下是示例代码：

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)
	}

	database := client.Database("test")
	collection := database.Collection("test_collection")

	changeStream, err := collection.Watch(context.TODO(), mongo.Pipeline{})
	if err != nil {
		log.Fatal(err)
	}
	defer changeStream.Close(context.TODO())

	for changeStream.Next(context.TODO()) {
		var deleteEvent bson.M
		if err := changeStream.Decode(&deleteEvent); err != nil {
			log.Fatal(err)
		}
		if operationType, ok := deleteEvent["operationType"]; ok {
			if operationType == "delete" {
				fullDocument := deleteEvent["fullDocument"].(bson.M)
				ownerID := fullDocument["OwnerID"]
				name := fullDocument["name"]
				quotaSize := fullDocument["QuotaSize"]
				fmt.Println("Deleted document with OwnerID:", ownerID, "name:", name, "QuotaSize:", quotaSize)
			}
		}
	}

	if err := changeStream.Err(); err != nil {
		log.Fatal(err)
	}
}

这段代码会连接到本地的 MongoDB 服务器，然后打开一个 "test" 数据库中 "test_collection" 集合的 change stream。每当在 "test_collection" 中发生删除操作时，它会打印出删除的文档的 OwnerID、name 和 QuotaSize 字段。

注意，这段代码仅在 MongoDB 4.0 及以上版本中可用。

### 回答2：
在Golang中监听MongoDB的删除事件并获取删除数据的OwnerID、name和QuotaSize可以通过使用MongoDB的Change Streams功能来实现。

首先，我们需要使用MongoDB的官方Go驱动程序（mongo-go-driver）来连接MongoDB数据库并创建一个Change Stream。下面是一个示例代码：

package main

import (
	"context"
	"fmt"
	"log"
	"time"

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

type DeletedData struct {
	OwnerID    string
	Name       string
	QuotaSize  int64
}

func main() {
	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://localhost:27017"))
	if err != nil {
		log.Fatal(err)
	}

	err = client.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}

	collection := client.Database("your-db-name").Collection("your-collection-name")

	// 监听删除事件
	changeStream, err := collection.Watch(context.TODO(), mongo.Pipeline{}, options.ChangeStream().SetFullDocument(core.Document).SetMaxAwaitTime(5*time.Second))
	if err != nil {
		log.Fatal(err)
	}

	for changeStream.Next(context.Background()) {
		var event struct {
			DocumentKey struct {
				ID string `bson:"_id"`
			} `bson:"documentKey"`
			OperationType string `bson:"operationType"`
			FullDocument  DeletedData
		}

		err := changeStream.Decode(&event)
		if err != nil {
			log.Fatal(err)
		}

		if event.OperationType == "delete" {
			fmt.Printf("Deleted data: OwnerID=%s, Name=%s, QuotaSize=%d\n", event.FullDocument.OwnerID, event.FullDocument.Name, event.FullDocument.QuotaSize)
		}
	}

	if err := changeStream.Err(); err != nil {
		log.Fatal(err)
	}

	if err := client.Disconnect(context.TODO()); err != nil {
		log.Fatal(err)
	}
}

在上面的代码中，我们首先连接到MongoDB数据库，并创建一个代表指定数据库和集合的`Collection`对象。然后，我们使用`Watch`方法来创建一个Change Stream，并使用`Decode`方法来解码Change Stream获取的事件数据。

当监听到删除事件（`operationType`为`delete`）时，我们可以从`FullDocument`字段中获取到被删除数据的`OwnerID`、`Name`和`QuotaSize`。

以上是一个简单的Golang示例，通过使用MongoDB的Change Streams功能来监听MongoDB的删除事件，并提取删除数据的OwnerID、Name和QuotaSize。请根据实际情况修改代码中的MongoDB连接URL、数据库名称以及集合名称。

### 回答3：
在Golang中监听MongoDB的删除事件，可以通过订阅MongoDB的操作日志，然后解析日志信息获得删除事件的相关数据。以下是一个基本实现示例：

1. 首先，引入所需的Golang库：

import (
	"context"
	"fmt"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
	"go.mongodb.org/mongo-driver/mongo/readpref"
	"log"
)

2. 设置MongoDB的连接配置和过滤条件：

func main() {
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")
	client, err := mongo.Connect(context.Background(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	err = client.Ping(context.Background(), readpref.Primary())
	if err != nil {
		log.Fatal(err)
	}

	pipeline := mongo.Pipeline{
		{{
			{"$match", bson.M{
				"operationType": "delete",
				"ns.coll":       "your_collection_name",
			}},
		}},
	}

	coll := client.Database("your_database_name").Collection("system.profile")
	changeStreamOptions := options.ChangeStream().SetFullDocument(options.UpdateLookup).SetMaxAwaitTime(time.Second * 10)
	changeStream, err := coll.Watch(context.Background(), pipeline, changeStreamOptions)
	if err != nil {
		log.Fatal(err)
	}
	defer changeStream.Close(context.Background())

	for changeStream.Next(context.Background()) {
		var changeDoc bson.M
		if err := changeStream.Decode(&changeDoc); err != nil {
			log.Fatal(err)
		}

		deleteDesc := changeDoc["description"].(string)
		fmt.Println("Delete Description:", deleteDesc)
		//解析其他想要的字段
	}
}

上述示例代码中：

- 通过`mongo.Connect`方法连接到MongoDB数据库。
- 通过`client.Ping`方法验证连接是否成功。
- 定义了一个流水线管道pipeline，用于筛选出`operationType`为"delete"且`ns.coll`为你的集合名称的操作。
- 通过`coll.Watch`方法监听满足过滤条件的删除事件，并设置了超时时间为10秒。
- 在`changeStream.Next`循环中，从监听到的删除事件中解析出描述信息deleteDesc，并打印或进行其他操作。

注意：以上示例代码仅用于参考，具体实现需要根据实际项目中使用的MongoDB驱动和版本进行调整。另外，建议对监听的删除事件进行更详细的解析，以获取OwnerID、name和QuotaSize等删除数据的字段信息。