4

如何使用javascript获取mongoDB中相邻记录之间的差异？例如，如果我在一个集合中有以下三个文档：

{
    "_id" : ObjectId("50ed90a55502684f440001ac"),
    "time" : ISODate("2013-02-13T15:45:41.148Z")
}

{
    "_id" : ObjectId("50ed90a55502684f440001ad"),
    "time" : ISODate("2013-02-13T15:45:42.148Z")
}

{
    "_id" : ObjectId("50ed90a55502684f440001ae"),
    "time" : ISODate("2013-02-13T15:45:45.148Z")
}

我想取相邻值之间“时间”字段的差异来获得：

{
    "_id" : ObjectId("50ed90a55502684f440001ac"),
    "time" : ISODate("2013-02-13T15:45:41.148Z"),
    "time_difference" : null
}

{
    "_id" : ObjectId("50ed90a55502684f440001ad"),
    "time" : ISODate("2013-02-13T15:45:42.148Z"),
    "time_difference" : 1
}

{
    "_id" : ObjectId("50ed90a55502684f440001ae"),
    "time" : ISODate("2013-02-13T15:45:45.148Z"),
    "time_difference" : 3
}

关于如何在 javascript/mongoDB 中有效地做到这一点的任何想法？谢谢。

4

4 回答 4

4

我不知道七年前问这个问题的时候是不是真的，但这完全可以在聚合框架内解决。假设集合名称为AdjacentDocument，则以下聚合将获得您要查找的结果：

db.AdjacentDocument.aggregate(
    {$sort: {time: 1}},
    {$group: {_id: 0, document: {$push: '$$ROOT'}}},
    {$project: {documentAndPrevTime: {$zip: {inputs: ['$document', {$concatArrays: [[null], '$document.time']}]}}}},
    {$unwind: {path: '$documentAndPrevTime'}},
    {$replaceWith: {$mergeObjects: [{$arrayElemAt: ['$documentAndPrevTime', 0]}, {prevTime: {$arrayElemAt: ['$documentAndPrevTime', 1]}}]}},
    {$set: {time_difference: {$trunc: [{$divide: [{$subtract: ['$time', '$prevTime']}, 1000]}]}}},
    {$unset: 'prevTime'}
);

聚合管道演练

首先，文档从最旧到最新排序。它们被分组到一个文档中，文档存储在有序数组字段中：

{$sort: {time: 1}},
{$group: {_id: 0, document: {$push: '$$ROOT'}}}

/*
{
    "_id" : 0,
    "document" : [
        {
            "_id" : ObjectId("50ed90a55502684f440001ac"),
            "time" : ISODate("2013-02-13T15:45:41.148Z")
        },
        {
            "_id" : ObjectId("50ed90a55502684f440001ad"),
            "time" : ISODate("2013-02-13T15:45:42.148Z")
        },
        {
            "_id" : ObjectId("50ed90a55502684f440001ae"),
            "time" : ISODate("2013-02-13T15:45:45.148Z")
        }
    ]
}
*/

接下来，将之前的时间压缩到文档数组中，创建一个数组[document, previousTime]：

{$project: {documentAndPrevTime: {$zip: {inputs: ['$document', {$concatArrays: [[null], '$document.time']}]}}}}

/*
{
    "_id" : 0,
    "documentAndPrevTime" : [
        [
            {
                "_id" : ObjectId("50ed90a55502684f440001ac"),
                "time" : ISODate("2013-02-13T15:45:41.148Z")
            },
            null
        ],
        [
            {
                "_id" : ObjectId("50ed90a55502684f440001ad"),
                "time" : ISODate("2013-02-13T15:45:42.148Z")
            },
            ISODate("2013-02-13T15:45:41.148Z")
        ],
        [
            {
                "_id" : ObjectId("50ed90a55502684f440001ae"),
                "time" : ISODate("2013-02-13T15:45:45.148Z")
            },
            ISODate("2013-02-13T15:45:42.148Z")
        ]
    ]
}
*/

接下来，展开文档和时间数组，为每个初始文档创建一个文档：

{$unwind: {path: '$documentAndPrevTime'}}

/*
{
    "_id" : 0,
    "documentAndPrevTime" : [
        {
            "_id" : ObjectId("50ed90a55502684f440001ac"),
            "time" : ISODate("2013-02-13T15:45:41.148Z")
        },
        null
    ]
}
{
    "_id" : 0,
    "documentAndPrevTime" : [
        {
            "_id" : ObjectId("50ed90a55502684f440001ad"),
            "time" : ISODate("2013-02-13T15:45:42.148Z")
        },
        ISODate("2013-02-13T15:45:41.148Z")
    ]
}
{
    "_id" : 0,
    "documentAndPrevTime" : [
        {
            "_id" : ObjectId("50ed90a55502684f440001ae"),
            "time" : ISODate("2013-02-13T15:45:45.148Z")
        },
        ISODate("2013-02-13T15:45:42.148Z")
    ]
}
*/

接下来，我们将文档替换为文档数组元素的值，并与上一个时间元素合并（如果它是初始索引，则使用 null）：

{$replaceWith: {$mergeObjects: [{$arrayElemAt: ['$documentAndPrevTime', 0]}, {prevTime: {$arrayElemAt: ['$documentAndPrevTime', 1]}}]}}

/*
{
    "_id" : ObjectId("50ed90a55502684f440001ac"),
    "time" : ISODate("2013-02-13T15:45:41.148Z"),
    "prevTime" : null
}
{
    "_id" : ObjectId("50ed90a55502684f440001ad"),
    "time" : ISODate("2013-02-13T15:45:42.148Z"),
    "prevTime" : ISODate("2013-02-13T15:45:41.148Z")
}
{
    "_id" : ObjectId("50ed90a55502684f440001ae"),
    "time" : ISODate("2013-02-13T15:45:45.148Z"),
    "prevTime" : ISODate("2013-02-13T15:45:42.148Z")
}
*/

time_difference最后，我们通过将 设置为两个时间字段的差异并删除临时字段来更新文档prevTime。由于两个日期之间的差异以毫秒为单位，并且您的示例使用秒，因此我们通过除以 1000 并截断来计算秒数。

{$set: {time_difference: {$trunc: [{$divide: [{$subtract: ['$time', '$prevTime']}, 1000]}]}}},
{$unset: 'prevTime'}

/*
{
    "_id" : ObjectId("50ed90a55502684f440001ac"),
    "time" : ISODate("2013-02-13T15:45:41.148Z"),
    "time_difference" : null
}
{
    "_id" : ObjectId("50ed90a55502684f440001ad"),
    "time" : ISODate("2013-02-13T15:45:42.148Z"),
    "time_difference" : 1
}
{
    "_id" : ObjectId("50ed90a55502684f440001ae"),
    "time" : ISODate("2013-02-13T15:45:45.148Z"),
    "time_difference" : 3
}
*/
于 2020-03-09T08:31:54.617 回答
2

您需要在此处确保的一件事是您对要用于装饰记录的查询进行了排序。如果不使用排序，它实际上将使用查找顺序，这不是$natural顺序。

查询之间的查找顺序可能不同，因此如果您在 2 分钟内运行两次查询，您可能会发现它们不会返回相同的顺序。但是，您的查询似乎会在逻辑上排序tiem_difference。

还应该注意，这是不可能通过正常查询实现的。我也看不到通过聚合框架执行此操作的简单方法。

因此，似乎下一个可行的方法是使用多个查询或客户端处理。使用上面@Marlon 定义的函数，客户端处理可能会更好。

于 2013-02-14T14:45:13.087 回答
1

有一件事，我想澄清你。与 MYSQL 不同，MongoDB 不保证该位置。我的意思是，MongoDB 会在不同的时间给你不同的排序。因此，在每次阅读时比较相邻文件可能会给出不同的结果。

如果您对此感到满意并且想要进行比较，请尝试使用 MongoDB 的 MapReduce http://docs.mongodb.org/manual/applications/map-reduce/

于 2013-02-14T14:32:23.010 回答
1

假设这 3 个对象在一个数组中通过，您可以执行以下操作：

var prevTime;
var currentTime;

for(var i = 0; i < records.length; i++)
{
    currentTime = new Date(records[i].time).getTime();
    records[i].time_difference = currentTime - prevTime;
    prevTime = currentTime;
}

当然，您需要交换位以使其使用来自 mongo 的记录。

如果您需要进行更复杂的日期计算，我强烈建议您查看datejs（如果需要，您可以获取节点包装器）。

于 2013-02-14T14:42:59.183 回答