Python操作MongoDB：将小时级聚合改为30分钟级遇报错

之前已实现按小时对数据聚合求平均值，现需调整为每30分钟聚合一次，修改查询后未成功，还触发了pymongo.errors.OperationFailure错误。以下是具体解决方法及错误排查步骤：

30分钟聚合的两种实现方式 #

方法一：使用$dateTrunc（MongoDB 5.0及以上版本） #

该方法语法简洁，直接通过内置函数按指定时间间隔截断日期：

db.collection.aggregate([
  {
    $group: {
      _id: {
        $dateTrunc: {
          date: "$timestamp", // 替换为你的时间字段名
          unit: "minute",
          binSize: 30
        }
      },
      avgValue: { $avg: "$value" } // 替换为要求平均值的字段名
    }
  },
  { $sort: { _id: 1 } }
])

方法二：兼容低版本的时间戳计算法 #

如果你的MongoDB版本低于5.0，可通过时间戳毫秒数计算实现30分钟分组：

db.collection.aggregate([
  {
    $group: {
      _id: {
        $multiply: [
          { $floor: { $divide: [ { $toLong: "$timestamp" }, 1800000 ] } }, // 1800000毫秒 = 30分钟
          1800000
        ]
      },
      avgValue: { $avg: "$value" }
    }
  },
  {
    $addFields: {
      intervalStart: { $toDate: "$_id" } // 将分组ID转换回日期格式，便于查看
    }
  },
  { $sort: { intervalStart: 1 } }
])

OperationFailure错误排查步骤 #

1. 检查语法与字段：确认聚合管道中字段名拼写正确、运算符参数合法，比如$timestamp字段是否存在且为日期/时间戳类型
2. 验证权限：确认执行查询的MongoDB用户拥有目标集合的read及aggregate权限
3. 核对版本兼容性：如果使用$dateTrunc，需确保MongoDB版本≥5.0，低版本需改用方法二
4. 直接在Shell测试：先在MongoDB Shell中执行聚合语句，排除pymongo客户端的适配问题
5. 查看错误详情：捕获pymongo.errors.OperationFailure的details属性，根据具体错误提示（如字段不存在、语法错误）精准修复

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