如何生成MongoDB oplog查询用的当前/30秒前Timestamp？

我来帮你搞定oplog查询里Timestamp的各种问题，直接上实用方案：

为什么直接new Timestamp()会报错？ #

在Node.js的MongoDB驱动里，Timestamp可不是全局对象，它是mongodb模块提供的专属BSON类型，必须先从模块里导入才能用，直接调用当然会报错啦。

正确的Timestamp生成步骤 #

首先确保你已经装好MongoDB驱动，然后按语法导入：

// CommonJS 写法
const { Timestamp } = require('mongodb');

// ES Modules 写法
import { Timestamp } from 'mongodb';

1. 生成当前时间的Timestamp #

最省心的方式是用Timestamp.fromDate()方法，直接传入当前日期对象就行：

// 当前时间对应的Timestamp
const currentTs = Timestamp.fromDate(new Date());

要是你想手动构造也可以（Timestamp构造函数的参数是[递增计数器, 秒级时间戳]，计数器设为0就行，我们只关心时间范围）：

const currentUnixSeconds = Math.floor(Date.now() / 1000);
const currentTs = new Timestamp(0, currentUnixSeconds);

2. 生成30秒前的Timestamp #

先算出30秒前的日期对象，再转成Timestamp：

// 先得到30秒前的Date实例
const thirtySecondsAgoDate = new Date(Date.now() - 30 * 1000);
// 转换为Timestamp
const thirtySecondsAgoTs = Timestamp.fromDate(thirtySecondsAgoDate);

手动构造的版本：

const thirtySecondsAgoUnixSeconds = Math.floor(Date.now() / 1000) - 30;
const thirtySecondsAgoTs = new Timestamp(0, thirtySecondsAgoUnixSeconds);

用正确的ts值查询oplog #

先拿到oplog集合（副本集里是local.oplog.rs），然后把生成的Timestamp对象直接放进查询条件里：

// 获取oplog集合
const oplogCollection = db.collection('oplog.rs');

// 查询30秒内产生的oplog条目
oplogCollection.find({ ts: { $gt: thirtySecondsAgoTs } })
  .toArray()
  .then(docs => {
    console.log('最近30秒的oplog内容:', docs);
  })
  .catch(err => {
    console.error('查询oplog出错:', err);
  });

⚠️ 注意：oplog的ts是BSON Timestamp类型，查询时必须传Timestamp对象，不能用字符串或数字，不然根本匹配不到数据哦。

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