MongoDB聚合查询如何移除嵌套响应中的null、空字符串与空数组

你可以根据实际使用的MongoDB版本，选择以下任意一种方案实现所有嵌套层级下null、空字符串、空数组字段的自动移除：

方案1：聚合管道内直接清洗（适用于MongoDB 4.4及以上版本） #

在你现有聚合管道的最后追加一个$replaceRoot阶段，通过$function执行服务端递归清洗逻辑，直接在数据库侧完成字段过滤，返回结果即为清洗后的干净数据，无需应用层额外处理。
追加的聚合阶段代码如下：

// 接在你原有input聚合管道数组的最后即可
{
  $replaceRoot: {
    newRoot: {
      $function: {
        body: function cleanEmpty(obj) {
          // 命中null、空字符串，标记为待移除
          if (obj === null || obj === '') return undefined;
          // 数组处理：递归清洗每个元素，过滤待移除项，空数组标记为待移除
          if (Array.isArray(obj)) {
            const cleanedArr = obj
              .map(item => cleanEmpty(item))
              .filter(item => item !== undefined);
            return cleanedArr.length === 0 ? undefined : cleanedArr;
          }
          // 对象处理：递归清洗每个字段，移除空值，空对象标记为待移除
          if (typeof obj === 'object' && obj !== null) {
            const cleanedObj = {};
            for (const key in obj) {
              const cleanedVal = cleanEmpty(obj[key]);
              if (cleanedVal !== undefined) cleanedObj[key] = cleanedVal;
            }
            return Object.keys(cleanedObj).length === 0 ? undefined : cleanedObj;
          }
          // 数字、布尔值、非空字符串等合法值直接保留
          return obj;
        },
        args: ["$$ROOT"],
        lang: "js"
      }
    }
  }
}

注意：该方案通过服务端执行JS逻辑完成清洗，性能略低于原生聚合操作符，但常规业务场景下单条文档处理耗时在毫秒级，无明显性能瓶颈。

方案2：应用层递归清洗（兼容所有MongoDB版本） #

如果你的MongoDB版本低于4.4，不支持$function操作符，可以在拿到聚合返回结果后，在Node.js侧用相同逻辑的递归函数完成数据清洗，代码示例如下：

const retVal = await DSModel.aggregate(input);

// 递归清洗函数
function cleanEmpty(obj) {
  if (obj === null || obj === '') return undefined;
  if (Array.isArray(obj)) {
    const cleanedArr = obj
      .map(item => cleanEmpty(item))
      .filter(item => item !== undefined);
    return cleanedArr.length === 0 ? undefined : cleanedArr;
  }
  if (typeof obj === 'object' && obj !== null) {
    const cleanedObj = {};
    for (const key in obj) {
      const cleanedVal = cleanEmpty(obj[key]);
      if (cleanedVal !== undefined) cleanedObj[key] = cleanedVal;
    }
    return Object.keys(cleanedObj).length === 0 ? undefined : cleanedObj;
  }
  return obj;
}

// 批量处理聚合返回结果
const cleanedResult = retVal
  .map(item => cleanEmpty(item))
  .filter(item => item !== undefined);

清洗规则说明 #

• 自动移除所有层级值为null、空字符串''的字段
• 自动移除空数组，以及数组元素中嵌套的空字段
• 自动移除清洗后无任何有效字段的空对象
• 不会误删0、false这类业务上合法的假值

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