如何高效批量删除多MongoDB集合用户及Cloudinary资源？

现有一段接口代码，可单次从likes、messages、users三个MongoDB集合中删除单个用户，同时在满足条件时删除Cloudinary中对应用户的资源及文件夹。现在计划将接口入参改为userId数组（格式为[userId1, userId2, userId3....]）实现批量删除，想咨询两个问题：

1. 是否需要使用for循环，还是可以通过高效的MongoDB查询实现？
2. Cloudinary是否支持传入多个标签进行资源删除？

当前代码如下：

handler.delete(async (req, res) => {
  const {userId, profileCompletion} = req.body;
  const db = await getMongoDb();
  await db.collection('likes').deleteMany( 
    {
      users: { $in: [userId] },
    }
  )
  await db.collection('messages').deleteMany( 
    {
    $or: [ {"from": userId}, {"to": userId}]
    }
  )
  await db.collection('users').deleteOne( 
    {
      "_id": userId,
    }
  )
  if(profileCompletion) {
    await cloudinary.api
    .delete_resources_by_tag(userId)
    .then(result=>console.log(result));
    await cloudinary.api
    .delete_folder(`users/${userId}`)
    .then(result=>console.log(result));
    
  }
  
  res.json({"Deleted": "success"});
})

一、MongoDB批量删除：无需循环，原生查询更高效 #

完全不需要用for循环遍历每个userId执行删除操作，MongoDB原生查询语法直接支持批量匹配，效率远高于循环单删，修改方式如下：

1. likes集合：将原代码中$in里的单个userId替换为传入的userId数组，即可匹配所有包含数组内任意userId的文档并删除：

await db.collection('likes').deleteMany({
  users: { $in: userIds } // userIds为传入的userId数组
})

2. messages集合：把$or条件中的单个userId替换为$in匹配数组，同时命中from或to字段属于目标userId数组的文档：

await db.collection('messages').deleteMany({
  $or: [
    { "from": { $in: userIds } },
    { "to": { $in: userIds } }
  ]
})

3. users集合：将deleteOne改为deleteMany，用_id: { $in: userIds }批量删除对应用户文档：

await db.collection('users').deleteMany({
  "_id": { $in: userIds }
})

二、Cloudinary批量删除标签资源的限制 #

Cloudinary的delete_resources_by_tag接口不支持直接传入多个标签，一次调用只能删除单个标签对应的资源。如果要批量处理多个用户的标签资源，需要循环遍历userId数组逐个调用该接口。

另外注意：delete_folder接口要求文件夹为空才能删除，所以必须先删除文件夹内的所有资源（通过标签删除），再执行删除文件夹的操作。

修改后的完整代码示例 #

handler.delete(async (req, res) => {
  const { userIds, profileCompletion } = req.body; // 入参改为userIds数组
  const db = await getMongoDb();

  // 批量删除MongoDB中的数据
  await db.collection('likes').deleteMany({
    users: { $in: userIds }
  });
  await db.collection('messages').deleteMany({
    $or: [
      { "from": { $in: userIds } },
      { "to": { $in: userIds } }
    ]
  });
  await db.collection('users').deleteMany({
    "_id": { $in: userIds }
  });

  // 批量处理Cloudinary资源（需循环）
  if (profileCompletion) {
    for (const userId of userIds) {
      // 先删除该用户标签对应的所有资源
      await cloudinary.api.delete_resources_by_tag(userId);
      // 再删除用户文件夹，捕获非空/不存在错误避免中断批量操作
      try {
        await cloudinary.api.delete_folder(`users/${userId}`);
      } catch (err) {
        console.log(`删除文件夹users/${userId}失败:`, err.message);
      }
    }
  }

  res.json({ "Deleted": "success" });
})

额外优化提示 #

• 给MongoDB的likes.users、messages.from、messages.to、users._id字段建立索引，可进一步提升批量删除的查询效率。
• 若用户数量不多，Cloudinary的循环操作可改用Promise.all并行执行，注意控制调用频率避免触发限流：

if (profileCompletion) {
  const promises = userIds.map(async userId => {
    await cloudinary.api.delete_resources_by_tag(userId);
    try {
      await cloudinary.api.delete_folder(`users/${userId}`);
    } catch (err) {
      console.log(`删除文件夹users/${userId}失败:`, err.message);
    }
  });
  await Promise.all(promises);
}

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