我有一个包含此类文档的 Mongodb 集合:

{
"_id" : ObjectId("53cb898bed4bd6c24ae07a9f"),
"account" : "C1"
"created_on" : ISODate("2014-10-01T01:23:00.000Z")
"value" : 253
}

和

{
"_id" : ObjectId("52cb898bed4bd6c24ae06a9e"),
"account" : "C2"
"created_on" : ISODate("2014-10-01T01:23:00.000Z")
"value" : 9381
}

C1 和 C2 每分钟有一个文档。

我想为另一个账户“C0”生成数据，该数据等于:(C2 - C1)*0.25 因此，目标是为集合中的每一分钟生成数据。

根据您的说法，是否可以在 mongo shell 中执行此操作？

非常感谢:)

最佳答案

解决这个问题的逻辑如下:

 a) group all the records by created_on date.
 b) get the value of both the documents in each group.
 c) calculate the difference the C2 and C1 documents for each group.
 d) In case one of the documents is missing difference 
    would be the value of the existing document.
 d) project a document with value as (difference*.25) in each group.
 e) insert the projected document to the collection.

我想提出两个解决方案，第一个是你的假设，

There is a document every minutes for C1 and C2.

所以 for every created_on时间，会有only two文件，C1和 C2 .

db.time.aggregate([ {
    $match : {
        "account" : {
            $in : [ "C1", "C2" ]
        }
    }
}, {
    $group : {
        "_id" : "$created_on",
        "first" : {
            $first : "$value"
        },
        "second" : {
            $last : "$value"
        },
        "count" : {
            $sum : 1
        }
    }
}, {
    $project : {
        "_id" : 0,
        "value" : {
            $multiply : [ {
                $cond : [ {
                    $lte : [ "$count", 1 ]
                }, "$first", {
                    $subtract : [ "$first", "$second" ]
                } ]
            }, 0.25 ]
        },
        "created_on" : "$_id",
        "account" : {
            $literal : "C0"
        }
    }
} ]).forEach(function(doc) {
    doc.value = Math.abs(doc.value);
    db.time.insert(doc);
});

第二种解决方案基于实时场景。对于特定的 created_on时间，可以有'n' C1 文件的数量和 'm'数量C2具有不同值的文档，但我们只需要 one 'C0'代表差异的文件，对于那个特定的 created_on时间。你需要一个额外的 $group管道操作符如下:

db.time.aggregate([ {
    $match : {
        "account" : {
            $in : [ "C1", "C2" ]
        }
    }
}, {
    $group : {
        "_id" : {
            "created_on" : "$created_on",
            "account" : "$account"
        },
        "created_on" : {
            $first : "$created_on"
        },
        "values" : {
            $sum : "$value"
        }
    }
}, {
    $group : {
        "_id" : "$created_on",
        "first" : {
            $first : "$values"
        },
        "second" : {
            $last : "$values"
        },
        "count" : {
            $sum : 1
        }
    }
}, {
    $project : {
        "_id" : 0,
        "value" : {
            $multiply : [ {
                $cond : [ {
                    $lte : [ "$count", 1 ]
                }, "$first", {
                    $subtract : [ "$first", "$second" ]
                } ]
            }, 0.25 ]
        },
        "created_on" : "$_id",
        "account" : {
            $literal : "C0"
        }
    }
} ]).forEach(function(doc) {
    doc.value = Math.abs(doc.value);
    db.time.insert(doc);
});

关于Mongodb 时间序列操作和生成，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26071820/