MongoDB：如何通过HTTP方法获取文档中数组的长度？

需求说明 #

给定批量插入的文档：

[
  { comments: [{foo:1}, {foo:1}, {foo:1}, {foo:1}] },
  { comments: [{foo:1}, {foo:1}] },
  { comments: [{foo:1}, {foo:1}, {foo:1}, {foo:1}, {foo:1}] },
  { title: 'foo' },
  { comments: [{foo:1}, {foo:1}, {foo:1}, {foo:1}, {foo:1}, {foo:1}] }
]

需要计算每个文档中comments数组的长度，若文档无comments字段则将count设为0，最终得到结果：

[{count: 4}, {count: 2}, {count: 5}, {title: 'foo', count: 0}, {count: 6}]

实现方案 #

核心是利用MongoDB的聚合管道处理每个文档，再通过HTTP请求调用MongoDB的API（以MongoDB Atlas Data API为例，自定义HTTP接口逻辑一致）。

聚合管道逻辑

使用$ifNull处理字段不存在的情况，结合$size计算数组长度，再通过$addFields新增count字段：

[
  {
    "$addFields": {
      "count": { "$size": { "$ifNull": ["$comments", []] } }
    }
  },
  {
    "$project": {
      "comments": 0 // 可选：不需要保留comments字段时添加，不影响原有的其他字段（如title）
    }
  }
]

• $ifNull：检测comments字段，不存在则返回空数组[]
• $size：计算数组长度，空数组长度为0，正好满足无comments时count=0的要求
• $addFields：为每个文档新增count字段
• $project：排除comments字段，保留其他原有字段（如第四个文档的title）

HTTP请求示例（curl）

curl --request POST \
  --url https://data.mongodb-api.com/app/<你的APP_ID>/endpoint/data/v1/action/aggregate \
  --header 'Content-Type: application/json' \
  --header 'api-key: <你的API密钥>' \
  --data '{
    "collection": "你的集合名",
    "database": "你的数据库名",
    "dataSource": "你的集群数据源名",
    "pipeline": [
      {
        "$addFields": {
          "count": { "$size": { "$ifNull": ["$comments", []] } }
        }
      },
      {
        "$project": {
          "comments": 0
        }
      }
    ]
  }'

自定义HTTP接口（如Express）

如果是自己搭建后端接口，只需在代码中调用MongoDB驱动的聚合方法，传入上述管道即可，示例逻辑：

// Express示例
const { MongoClient } = require('mongodb');
const express = require('express');
const app = express();
app.use(express.json());

app.post('/get-comment-count', async (req, res) => {
  const client = new MongoClient('<你的MongoDB连接字符串>');
  try {
    await client.connect();
    const db = client.db('你的数据库名');
    const collection = db.collection('你的集合名');
    const result = await collection.aggregate([
      {
        $addFields: {
          count: { $size: { $ifNull: ["$comments", []] } }
        }
      },
      {
        $project: { comments: 0 }
      }
    ]).toArray();
    res.json(result);
  } catch (err) {
    res.status(500).json({ error: err.message });
  } finally {
    await client.close();
  }
});

app.listen(3000, () => console.log('Server running on port 3000'));

内容的提问来源于stack exchange，提问作者its9527