如何在MongoDB聚合框架中实现深层嵌套数据的结构转换

错误根因 #

你遇到的报错是因为无答案的问题经过$unwind后，answers字段为null，后续构造k/v结构时产生了null元素，直接传入$arrayToObject就会触发类型校验错误。

方案1：兼容原有写法的修正版 #

你可以在原有管道基础上补充空值过滤逻辑，完整管道如下：

阶段1：筛选指定商品未举报的问题

{
    '$match': {
      'product_id': 1, 
      'reported': 0
    }
}

阶段2：关联答案配图集合

{
  '$lookup': {
    'from': 'ansPhotos', 
    'localField': 'question_id', 
    'foreignField': 'question_id', 
    'as': 'answers'
  }
}

阶段3：拆分答案数组，保留无答案文档

{
  '$unwind': {
    'path': '$answers', 
    'preserveNullAndEmptyArrays': true
  }
}

阶段4：格式化单条答案结构，兼容空答案场景

{
  '$addFields': {
    'answerKV': {
      '$cond': {
        'if': { '$ne': [ '$answers', null ] },
        'then': {
          'k': { '$toString': '$answers.answer_id' },
          'v': {
            '$mergeObjects': [
              '$answers',
              { 'photos': { '$map': { 'input': '$answers.photos', 'in': '$$this.url' } } }
            ]
          }
        },
        'else': null
      }
    }
  }
}

阶段5：按问题维度聚合，保留问题原有字段

{
  '$group': {
    '_id': '$_id',
    'product_id': { '$first': '$product_id' },
    'question_id': { '$first': '$question_id' },
    'question_content': { '$first': '$question_content' },
    // 其余问题原有字段按需用$first补充保留
    'answerKVList': { '$push': '$answerKV' }
  }
}

阶段6：过滤空值后转换为目标键值对结构

{
  '$addFields': {
    'answers': {
      '$arrayToObject': {
        '$filter': {
          'input': '$answerKVList',
          'cond': { '$ne': [ '$$this', null ] }
        }
      }
    }
  }
}

阶段7：删除临时中间字段（可选）

{
  '$project': {
    'answerKVList': 0
  }
}

方案2：大数据量优化版（推荐） #

你有百万级数据的情况下，避免用$unwind+$group的组合会大幅提升性能，可以直接在$lookup阶段用子管道预处理答案结构，后续直接转换即可：

阶段1：筛选指定商品未举报的问题（和之前一致）

{
    '$match': {
      'product_id': 1, 
      'reported': 0
    }
}

阶段2：关联答案集合时直接预处理结构

{
  '$lookup': {
    'from': 'ansPhotos',
    'localField': 'question_id',
    'foreignField': 'question_id',
    'pipeline': [
      {
        '$addFields': {
          'photos': { '$map': { 'input': '$photos', 'in': '$$this.url' } }
        }
      }
    ],
    'as': 'answers'
  }
}

阶段3：直接转换为键值对结构，空数组自动转为空对象

{
  '$addFields': {
    'answers': {
      '$arrayToObject': {
        '$map': {
          'input': '$answers',
          'in': {
            'k': { '$toString': '$$this.answer_id' },
            'v': '$$this'
          }
        }
      }
    }
  }
}

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