MGO TTL 索引创建以选择性地删除文档

Question

我正在使用 Golang 和 MongoDB。我有一个集合，它需要保存一个可以持久或易变的文档。因此，如果它设置了过期日期（例如 expireAt），则该文档被视为易失性并被删除，否则它将保留在集合中，除非它被手动删除。

阅读this doc 我发现了一个可以按我的需要工作的索引。

基本上我需要在mgo中复制这种索引：

db.log_events.createIndex( { "expireAt": 1 }, { expireAfterSeconds: 0 } )

db.log_events.insert( {
  "expireAt": new Date('July 22, 2013 14:00:00'),
  "logEvent": 2,
  "logMessage": "Success!"
} )

我已阅读（我正在搜索此信息的来源）如果expireAt 不是有效日期，则不会触发删除。因此，我认为我需要做的就是在需要时将 expireDate 设置为有效日期，否则我会将其留给 Go time.Time 零值。

这是我的代码库

type Filter struct {
    Timestamp time.Time     `bson:"createdAt"`
    ExpireAt  time.Time     `bson:"expireAt"`
    Body      string        `bson:"body"`
}

// Create filter from data received via REST API.
var filter Filter
timestamp := time.Now()

if theUserAction == "share" { // This is action will set the document as volatile
    filter.ExpireAt = time.Now().Add(24 * time.Hour * 14)
}

filter.Timestamp = timestamp
filter.Body = "A BODY"

// Store filter in database
session, err := mdb.GetMgoSession() // This is a wrapping method that returns a valid mgo session
if err != nil {
    return NewErrorInternal("Error connecting to database", err)
}
defer session.Close()


// Get db with global data for legent
collection := session.DB(database).C(filtersCollection)

我的问题是：如果expireAt 键有效，我如何设置索引以便删除文档？ 阅读mgo documentation about Index Type 似乎没有办法复制前面提到的索引，因为库只提供ExpireAfter 字段..

另外，假设 mongodb 可以将零值解释为无效日期是否有效？

从文档中看，它是 January 1, year 1, 00:00:00.000000000 UTC，实际上似乎是一个有效的日期..

到目前为止我的想法是做这样的事情：

filtIdx := mgo.Index{
    Key:        []string{"expireAt"},
    Unique:     false,
    Background: true,
    Sparse:     false,
    ExpireAfter: 0,
}

Answer 1

如果 expireAt 键有效，我如何设置索引以便删除文档？

使用mgo.v2设置TTL索引的示例如下：

index := mgo.Index{
    Key:         []string{"expireAt"},
    ExpireAfter: time.Second * 120, 
}
err = coll.EnsureIndex(index)

上面的示例设置为 120 秒的过期时间。另见Expire Data from Collections by Setting TTL。

是否仍然可以使某些文件完全不过期？由于这是我期待的行为，因此我期待获得一个集合，其中一些文档确实过期而其他文档保持持久性

您可以为ExpireAt struct 字段指定omitempty 标志，如下所示：

type Filter struct {
    Timestamp time.Time `bson:"createdAt"`
    Body      string    `bson:"body"`
    ExpireAt  time.Time `bson:"expireAt,omitempty"`
}

本质上只包含未设置为零值的字段。查看更多信息mgo.v2 bson.Marshal

现在，例如，您可以插入两个文档，其中一个将过期而另一个将持续存在。代码示例：

var foo Filter
foo.Timestamp = timestamp
foo.Body = "Will be deleted per TTL index"
foo.ExpireAt = time.Now()
collection.Insert(foo)

var bar Filter
bar.Timestamp = timestamp
bar.Body = "Persists until expireAt value is set"
collection.Insert(bar)

稍后，您可以将expireAt 字段设置为Update()，例如：

newValue := bson.M{"$set": bson.M{"expireAt": time.Now()}}
err = collection.Update(queryFilter, newValue)

为expireAt 字段设置一个有效的时间值，将使其符合 TTL 索引。即不再持续存在。

根据您的用例，或者您也可以Remove() 文档，而不是更新和依赖 TTL 索引。