解析 mongo-go-driver 中聚合管道中的扩展 JSON 日期的方法

有志者，事竟成！如果你在学习Golang，那么本文《解析 mongo-go-driver 中聚合管道中的扩展 JSON 日期的方法》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我有一个带有日期字段的集合：

{
    "_id" : objectid("5b92b359ddceef5b24502834"),
    "datetimegmt" : isodate("2018-08-22t09:29:25.000z"),
    yada, yada, yada
}

我试图使用 mongo-go-driver 的 parseextjsonarray 函数在 $match 聚合阶段按日期查找。 （我知道如何直接使用 *bson.array 执行此操作。我问是为了知道使用 parserextjsonarray 执行此操作的正确方法，或者我是否遇到了限制。）

我已简化此示例并确认它与上述文档不匹配。

pipeline, err := bson.parseextjsonarray(`[
    { "$match": { "datetimegmt.$date":"2018-08-22t09:29:25.000z" } }
]`)
cursor, err := receivedfromresponsequeue.aggregate(ctx, pipeline)

以下内容在 mongo shell 中不起作用。 （这并不奇怪，因为它会自动转换为 isodate() 格式）

db.getcollection('received_from_response_queue').aggregate([
    { "$match": { "datetimegmt.$date":"2018-08-22t09:29:25.000z" } }
])

但这在 mongo shell 中确实有效。

db.getcollection('received_from_response_queue').aggregate([
    { "$match": { "datetimegmt": isodate("2018-08-22t09:29:25.000z") } }
])

但这会在“pipeline”中返回一个空数组。 （因为 parseextjsonarray 不处理 javascript）

pipeline, err := bson.parseextjsonarray(`[
    { "$match": { "datetimegmt":isodate("2018-08-22t09:29:25.000z") } }
]`)

因为它随后使用一个空数组，所以它会重新调整集合中的所有文档。有趣的是，我们尝试匹配的文档中的日期格式不同。

{
    "_id" : { "$oid" : "5b92b359ddceef5b24502834" },
    "datetimegmt" : { "$date" : "2018-08-22t05:29:25-04:00" },
    yada yada yada
}

但这也不匹配。

pipeline, err := bson.parseextjsonarray(`[
    { "$match": { "datetimegmt.$date":"2018-08-22t05:29:25-04:00" } }
]`)
cursor, err := receivedfromresponsequeue.aggregate(ctx, pipeline)

这在 mongo shell 中不起作用。

db.getCollection('received_from_response_queue').aggregate([
    { "$match": { "dateTimeGMT.$date":"2018-08-22T05:29:25-04:00" } }
])

有什么见解吗？

解决方案

MongoDB Extended JSON 背后的想法是用纯 json 表示二进制 json (BSON) 类型。

一般语法是将对象表示为单个嵌入文档。例如，bson binary 对象表示为文档 {"$binary": "<binary data>"}。键字段中的 $ 前缀表示类型。 bson date 对象也是如此。

方法 bson.ParseExtJSONArray() 期望扩展 json 类型是文档，而不是 mongodb dot-notation 表达式。例如，而不是下面的：

{ "$match": { "datetimegmt.$date":"2018-08-22t09:29:25.000z" } }

该方法期望：

{ "$match": { "datetimegmt": {"$date":"2018-08-22t09:29:25.000z" } } }

您还可以提供 Unix Epoch 中的日期值，例如：

{ "$match": { "datetimegmt": {"$date": { "$numberlong": "1546300800"} } } }

使用 mongo-go-driver/bson，示例如下：

raw := `[ { "$match": {"datetimegmt": {"$date": {"$numberlong": "1530962624753" } } } } ]`
pipeline, err := bson.parseextjsonarray(raw)
cursor, err := collection.aggregate(context.background(), pipeline)

额外说明： 您可以在通过迭代将结果值传递给聚合之前调试 parseextjsonarray() 。例如：

toConvert := `[
   { "$lookup": {
        "from": "anotherCollection",
        "localField": "foreignKey",
        "foreignField": "_id",
        "as": "someField"
    }},
    { "$match": {"dateTimeGMT":{"$lt": {"$date": "2019-01-10T09:29:25.000Z" } } } }
]`
pipeline, err := bson.ParseExtJSONArray(toConvert)

it, err := bson.NewArrayIterator(pipeline)
for it.Next() {
    fmt.Println(it.Value().MutableDocument().ToExtJSON(true))
}

//Outputs : 
//   {"$lookup":{"from":"anotherCollection","localField":"foreignKey","foreignField":"_id","as":"someField"}}
//   {"$match":{"dateTimeGMT":{"$lt":{"$date":{"$numberLong":"1547112565000"}}}}}
//

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《解析 mongo-go-driver 中聚合管道中的扩展 JSON 日期的方法》文章吧，也可关注编程网公众号了解相关技术文章。