按最大创建日期时间从 mongo 投影整个文档

Question

我创建了这个查询来获取某个日期时间范围内的所有文档的最大创建日期时间。我正在查找每小时所有最新文档的列表。

pipe = [
  {
    "$addFields": {
      "start": {
        "$dateFromString": {
          "dateString": "$StartTime",
          "format": "%Y-%m-%dT%H:%M:%S%z"
        }
      },
      "created": {
        "$dateFromString": {
          "dateString": "$CreatedDateTime",
          "format": "%Y-%m-%dT%H:%M:%S%z"
        }
      }
    }
  },
  {
    "$match": {
      "start": {
        "$gte": start_time,
        "$lte": end_time
      }
    }
  },
  {
    "$sort": {
      "created": -1
    }
  },
  {
    "$group": {
      "_id": "$start",
      "doc": {
        "$first": "$$ROOT"
      }
    }
  },
  {
    "$replaceRoot": {
      "newRoot": "$doc"
    }
  }
]
cursor = COLLECTION.aggregate(pipeline=pipe)

但是，由于我使用的是 $addFields，所以我也在投射 start 和 created，这不是我在寻找的。我能否以排除这些字段并仅包含原始文档的方式复制此查询。我还想知道这是否不是我的解决方案的最佳查询，因此欢迎任何输入或建议。

这是一个示例文档：

{
  "StartTime" : "2020-05-01T00:00:00-05:00",
  "EndTime" : "2020-05-01T00:59:59-05:00",
  "Value" : 100,
  "CreatedDateTime" : "2020-05-01T00:00:00-05:00"
}

如果我要查询一小时，这就是查询返回的内容：

{
  "StartTime" : "2020-05-01T00:00:00-05:00",
  "EndTime" : "2020-05-01T00:59:59-05:00",
  "Value" : 100,
  "CreatedDateTime" : "2020-05-01T00:00:00-05:00",
  "start" : datetime.datetime(2020,05,01),
  "created" : datetime.datetime(2020,05,01)
}

如果我要查询多个小时，我正在寻找的结果是示例文档或示例文档列表。

Answer 1

聚合管道中不需要$addFields 阶段。只需将start_time 和end_time 转换为字符串。将start 替换为StartTime，将created 替换为CreatedDateTime。

所以，最后你的查询应该如下所示：

pipe = [{
  "$match": {
    "StartTime": {
      "$gte": start_time,
      "$lte": end_time
    }
  }
},
{
  "$sort": {
    "CreatedDateTime": -1
  }
},
{
  "$group": {
    "_id": "$StartTime",
    "doc": {
      "$first": "$$ROOT"
    }
  }
},
{
  "$replaceRoot": {
    "newRoot": "$doc"
  }
}]
cursor = COLLECTION.aggregate(pipeline=pipe)

就我而言，我初始化了start_time 和end_time，如下所示：

from datetime import datetime
start_time = datetime.strptime('01 May 2020 00:00:00-05:00', '%d %b %Y %H:%M:%S%z').strftime('%Y-%m-%dT%H:%M:%S%z') # Value: 2020-05-01T00:00:00-05:00
start_time = start_time[:-2]+':'+start_time[-2:]
end_time = datetime.strptime('01 May 2020 00:59:59-05:00', '%d %b %Y %H:%M:%S%z').strftime('%Y-%m-%dT%H:%M:%S%z') # Value: 2020-05-01T00:59:59-05:00
end_time = end_time[:-2]+':'+end_time[-2:]

你可以像上面那样做一些修改，然后运行查询。

简短说明： 字符串比较以字典顺序进行。所以，"01" 小于"02"，"03" 大于"01"，同样，"2020-05-01 00:00:00-05:00" 小于等于"2020-05-01T00:00:00-05:00"，"2020-05-01 00:59:59-05:00" 大于等于"2020-05-01T00:00:00-05:00"。

希望以上内容有所帮助。