Mongoose中Story过期删除后，如何自动清理User关联ID数组？

问题背景 #

使用MongoDB的TTL索引自动删除Story文档时，关联的User文档中stories数组里的对应ID无法自动移除——因为TTL索引是MongoDB后台异步执行删除，不会触发Mongoose的pre('remove')或post('remove')中间件（这些中间件仅在通过Mongoose主动调用删除方法时生效）。

解决方案 #

方案1：利用MongoDB变更流监听删除事件

通过MongoDB的变更流（Change Streams）监听Story集合的删除操作，一旦检测到文档被删除，立即更新对应的User文档。

const Story = mongoose.model('Story', storySchema);
const User = mongoose.model('User', userSchema);

// 监听Story集合的删除事件
const storyChangeStream = Story.watch([
  { $match: { operationType: 'delete' } }
]);

storyChangeStream.on('change', async (change) => {
  const deletedStoryId = change.documentKey._id;
  // 批量移除所有用户数组中的该story ID
  await User.updateMany(
    { stories: deletedStoryId },
    { $pull: { stories: deletedStoryId } }
  );
});

// 可选：处理变更流断开重连
storyChangeStream.on('error', (err) => {
  console.error('变更流出错:', err);
  // 这里可以添加重连逻辑
});

方案2：自定义TTL删除逻辑（不用原生TTL索引）

放弃MongoDB原生TTL索引，改用定时任务主动清理过期文档，这样可以通过Mongoose的中间件同步更新用户数据。

const storySchema = new mongoose.Schema({
  createdAt: { type: Date, default: Date.now },
  title: String,
  creator: { type: mongoose.Types.ObjectId, ref: 'User' },
  tags: [String]
});

// 定义post删除中间件，删除Story后自动更新用户的stories数组
storySchema.post('remove', async function(doc) {
  await User.findByIdAndUpdate(
    doc.creator,
    { $pull: { stories: doc._id } }
  );
});

const Story = mongoose.model('Story', storySchema);

// 使用node-schedule定时清理过期文档（需先安装npm包：npm install node-schedule）
const schedule = require('node-schedule');
// 每5分钟执行一次清理任务（可根据需求调整频率）
schedule.scheduleJob('*/5 * * * *', async () => {
  const expireThreshold = new Date(Date.now() - 10000); // 10秒过期
  const expiredStories = await Story.find({ createdAt: { $lt: expireThreshold } });
  // 逐个删除触发中间件
  for (const story of expiredStories) {
    await story.remove();
  }
});

方案对比 #

• 变更流方案：依赖MongoDB原生功能，无需额外定时任务，实时性强；但要求MongoDB版本≥3.6，需处理连接异常重连。
• 自定义定时任务：逻辑灵活，可扩展更多删除前后操作；但存在清理延迟（取决于定时频率），需维护定时任务稳定性。

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