ReactiveAggregate与collection.update触发错误：Expected to find a document to change

这个错误和订阅失效的核心原因是ReactiveAggregate在重新计算聚合结果时，尝试更新客户端集合aggregatedProductRanking的文档，但找不到匹配的目标文档。

具体来说：

• 你的聚合管道最终返回的是一个没有固定_id的文档（因为你用了$project: { _id: 0 }），ReactiveAggregate默认会尝试用查询条件匹配客户端集合中的文档来更新，但缺少唯一标识的情况下，它无法定位到要更新的文档，就会抛出Expected to find a document to change错误。
• 错误发生后，ReactiveAggregate的更新流程中断，客户端的聚合集合没有得到最新数据，所以看起来订阅失效了，必须刷新才能看到变化。

我们需要给聚合结果添加一个固定的唯一标识，同时配置ReactiveAggregate使用upsert模式，确保无论是首次插入还是后续更新都能正常执行。

1. 修改服务端聚合管道和ReactiveAggregate配置 #

更新getProductRankingList函数，在聚合末尾添加固定_id，并开启upsert选项：

const getProductRankingList = (context) => ReactiveAggregate(context, Meteor.users, [
  { $match: { productFavorites: {$ne: [] }} },
  { $project: { _id: 0, productFavorites: { $concatArrays: "$productFavorites" } } },
  { $unwind: "$productFavorites" },
  { $facet: {
      rankingList: [ { $group: { _id: "$productFavorites", count: { $sum: 1 } } },{ $sort: { "count": -1 } } ],
      product_keys: [ { $group: { _id: 0, product_keys: { $addToSet: "$productFavorites" } } } ]
    } },
  { $unwind: "$product_keys" },
  { $project: { _id: 0, rankingList: 1, product_keys: "$product_keys.product_keys" } },
  // 添加固定的_id，让ReactiveAggregate能精准定位文档
  { $addFields: { _id: "globalProductRanking" } }
], { 
  clientCollection: "aggregatedProductRanking",
  // 开启upsert，不存在则插入，存在则更新
  upsert: true
})

2. 调整客户端获取聚合数据的逻辑 #

因为现在聚合结果只有一个固定_id的文档，客户端可以直接查询这个文档，比fetch()整个集合更可靠：

export default withTracker(() => {
  const handle = Meteor.subscribe("products.RankingList")
  return {
    // 直接查询固定_id的文档，避免数组处理的问题
    ranking: AggregatedProductRanking.findOne("globalProductRanking"),
    user: Meteor.user(),
    isLoading: !handle.ready() || !Meteor.user()
  }
})(ProductRankingList)

同时，更新客户端调用updateProductFavorites后的逻辑，适配新的ranking结构：

updateProductFavorites = (product_key, action) => {
  // 从当前ranking文档中获取product_keys
  const { ranking } = this.props
  const product_keys = ranking?.product_keys || []
  Meteor.call('Accounts.updateProductFavorites', product_key, action, (err, response) => {
    if (err) makeAlert(err.reason, 'danger', 3000)
    else this.getProductsByKeys(product_keys)
  })
}

3. 验证发布函数的上下文 #

确保你的发布函数正确传递了上下文，比如：

Meteor.publish("products.RankingList", function() {
  return getProductRankingList(this)
})

• 固定_id让ReactiveAggregate每次更新时都能精准找到客户端集合中的目标文档，不会出现“找不到文档”的情况。
• upsert: true配置确保首次计算聚合时会插入文档，后续更新时会修改已存在的文档，完美覆盖两种场景。
• 客户端直接查询固定_id的文档，避免了fetch()返回数组可能带来的空数组或多个文档的问题，数据更稳定。

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