MongoDB聚合查询每日数据更新状态及批量检查集合数据插入情况

咱们逐个解决你的两个MongoDB问题：

首先，如果你有专门的updateTime或createTime字段，直接基于这个字段过滤会更准确；如果没有，MongoDB默认的_id（ObjectId类型）自带创建时间戳，可以通过$toDate转换后使用。

这里提供两种常用的聚合查询方案：

• 场景1：检查单个集合今日是否有更新/插入
  通过$match过滤最近24小时的文档，再用$count统计数量来判断：

db.yourCollection.aggregate([
  {
    $match: {
      $expr: {
        $gte: [
          $toDate("$ _id"), // 将ObjectId转为日期格式
          new Date(Date.now() - 24 * 60 * 60 * 1000) // 24小时前的时间节点
        ]
      }
    }
  },
  { $count: "recentDocumentCount" }
])

如果返回的recentDocumentCount大于0，说明该集合今日有数据更新或插入。如果你的集合有专门的更新时间字段（比如updatedAt），把$toDate("$ _id")替换成"$updatedAt"即可，这样能精准匹配更新动作。

• 场景2：按日期分组，统计每日更新情况
  如果需要查看一段时期内每天的更新记录，可以用$group按年月日分组：

db.yourCollection.aggregate([
  {
    $match: {
      // 可选：过滤最近7天的数据，缩小查询范围
      $expr: {
        $gte: [
          $toDate("$ _id"),
          new Date(Date.now() - 7 * 24 * 60 * 60 * 1000)
        ]
      }
    }
  },
  {
    $group: {
      _id: {
        year: { $year: $toDate("$ _id") },
        month: { $month: $toDate("$ _id") },
        day: { $dayOfMonth: $toDate("$ _id") }
      },
      dailyCount: { $sum: 1 }
    }
  },
  { $sort: { "_id.year": 1, "_id.month": 1, "_id.day": 1 } }
])

执行后会得到每天的新增/更新文档数，一目了然哪一天有数据变动。

你原来的代码只能单集合查询，要批量处理的话，可以在Mongo Shell里遍历所有集合来实现。另外尽量避免用$where——它会执行JavaScript，性能远不如原生查询，我们用$expr+$toDate来替代。

具体实现代码如下：

// 获取当前数据库的所有集合名称，排除系统集合（可选）
const collections = db.getCollectionNames().filter(name => !name.startsWith("system."));

// 遍历每个集合检查
collections.forEach(collectionName => {
  const currentCollection = db.getCollection(collectionName);
  
  // 统计最近24小时内的新文档数量
  const newDocCount = currentCollection.countDocuments({
    $expr: {
      $gte: [
        $toDate("$ _id"),
        new Date(Date.now() - 24 * 60 * 60 * 1000)
      ]
    }
  });
  
  // 输出检查结果
  print(`集合 ${collectionName} 最近24小时${newDocCount > 0 ? '有' : '没有'}新数据插入`);
});

小优化提示： #

• 用countDocuments替代find：我们只需要判断是否存在新数据，不需要返回具体文档，countDocuments更高效
• 若有createdAt字段：替换$toDate("$ _id")为"$createdAt"，结果会更精准（因为_id的时间戳是创建时间，无法反映后续的插入动作）

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