使用pymongo更新Mongo文档中的平均值

Question

我想更新现有mongodb文档中的字段。但设定值应为旧值和新值的平均值。

我可以从mongodb文档中获取旧值并计算平均值，并将其设置到字段中，但这不是线程安全性，在计算平均值时，mongodb文件中的旧值可能会更改。

示例，文档:

{ ' _ id ':ObjectId(" 55d 49338 b 9796 c 337 c 894 df 3 ")，值:10 }

Python代码：

# new_value = 15, therefore average_value = 12.5
db.mycollection.update_one(
    {'_id': '55d49338b9796c337c894df3'},
    {...} <- What there?
)

以前：

{ '_id'： ObjectId（“55d49338b9796c337c894df3”）， 值： 12.5 }

Answer 1

您可以使用聚合框架进行更新。执行此操作所需的管道步骤是$addFields和$out。$addFields运算符允许您使用表达式的结果替换集合中的现有字段，这将涉及算术运算符$avg，以计算平均值。

$avg运算符，如果在$project（或$addFields）阶段使用，可以接受表达式列表，并且可以使用该列表推送现有字段中的值和新值以计算这两个字段的平均值。

作为最后阶段的 $out 运算符将在将聚合管道的结果文档写入集合时更新现有集合。

以下示例描述了伪装成聚合操作的上述更新操作：

new_value = 15
db.mycollection.aggregate([
    { "$addFields": {
        "value": { "$avg":  ["$value", new_value] }
    } },
    { "$out": "mycollection" }
])

或者在MongoDB 3.2中，使用＜code＞$project

new_value = 15
db.mycollection.aggregate([
    { "$project": {
        "value": { "$avg":  ["$value", new_value] }
    } },
    { "$out": "mycollection" }
])