根据聚合管道MongoDB Atlas触发器中的条件更新多个字段

发布于08月22日

当标志update设置为true时，我有以下流水线根据score计算排名(排序):

  const pipeline = [
    {$match: {"score": {$gt: 0}, "update": true}},
    {$setWindowFields: {sortBy: {"score": -1}, output: {"rank": {$denseRank: {}}}}},
    {$merge: {into: "ranking"}}
  ];
  
  await ranking_col.aggregate(pipeline).toArray();

我接下来要做的是在update标志设置为false时将rank设置为0:

ranking_col.updateMany({"update": false}, {$set: {"rank": parseInt(0, 10)}});

我的其中一个文档是这样的:

{
  "_id": "7dqe1kcA7R1YGjdwHsAkV83",
  "score": 294,
  "update": false,
  "rank": 0,
}

我希望避免额外的updateMany调用，并在管道内执行相同的调用.当时MongoDB的支持告诉我这样使用$addFields标志:

const pipeline = [
    {$match: {"score": {$gt: 0}, "update": true}},
    {$setWindowFields: {sortBy: {"score": -1}, output: {"rank": {$denseRank: {}}}}},
    {$addFields: {rank: {$cond: [{$eq: ['$update', false]},parseInt(0, 10),'$rank']}}},
    {$merge: {into: "ranking"}}
  ];

这在我的阿特拉斯触发器中不起作用. 你能纠正我的语法吗？或者告诉我一个好的方法？

db.ranking.aggregate([ { "$setWindowFields": { "partitionBy": "$update", "sortBy": {"score": -1}, "output": { "rank": {"$denseRank": {}} } } }, { "$set": { "rank": { "$cond": [ "$update", "$rank", 0 ] } } }, { "$match": { "$expr": { "$not": [{"$and": ["$update", {"$lte": ["$score", 0]}]}] } } }, {"$merge": "ranking"} ])

根据聚合管道MongoDB Atlas触发器中的条件更新多个字段

推荐答案

Mongodb相关问答推荐

如何将空值单独分组？

无法配置数据源：未指定url属性，无法为 MongoDb 配置嵌入数据源

Mongo 将一个数组链接到另一个数组

如何判断 mongodb 聚合，该文档具有键，该键是一个数组，其第二个元素是否存在？

在延迟函数中重用 context.WithTimeout

Mongoose 更新不同类型的记录

有没有办法在 Prisma for MongoDB 的模式中显式声明 int32？

在 MongoDB 中，如何使用对当前值进行操作的函数来更新嵌套文档的值？

Mongoose $inc 枚举验证失败

使用 mongodb 时是否需要规范化数据库？

如何将 json 字符串编组到 bson 文档以写入 MongoDB？

使用 homebrew 和 Xcode 8.1.1 安装 Mongodb 失败

MongoDB映射/减少多个集合？

在 Ubuntu 14.04 中安装 MongoDB 失败

如何在 mongo JavaScript shell 中中止查询

如何按季度分组日期？

MongoDB聚合排序不起作用

在 MongoDB 中插入或更新许多文档

Mongodb 查找除一两个条件之外的所有内容

mongodb & max connections最大连接数