查询MongoDBoplog.rs-创新互联
oplog是Capped Collection,默认分配5%的空闲磁盘空间。
来看下oplog.rs的样子:
字段含义
ts:8字节的时间戳,由4字节unix timestamp + 4字节自增计数表示。
这个值很重要,在选举(如master宕机时)新primary时,会选择ts大的那个secondary作为新primary。
op:1字节的操作类型,例如i表示insert,d表示delete。
ns:操作所在的namespace。
o:操作所对应的document,即当前操作的内容(比如更新操作时要更新的的字段和值)
o2: 在执行更新操作时的条件,仅限于update时才有该属性。
其中op,可以是如下几种情形之一:
"i": insert
"u": update
"d": delete
"c": db cmd
"db":声明当前数据库 (其中ns 被设置成为=>数据库名称+ '.')
"n": no op,即空操作,其会定期执行以确保时效性。修改配置,会产生 "n" 操作。
查询示例
oplog.rs系统集合只用于复制,不能创建索引,查询语句会很慢。
> db.oplog.rs.find({},{"ts":1}).sort({$natural: -1}) { "ts" : Timestamp(1406185666, 1) } { "ts" : Timestamp(1406180043, 1) } { "ts" : Timestamp(1406180033, 1) } { "ts" : Timestamp(1406172831, 1) } { "ts" : Timestamp(1406171938, 1) } > db.oplog.rs.find({ "ts" : { "$gte" : Timestamp(1406185630, 1) } },{"ts":1})查询一小时内的oplog
> var SECS_PER_HOUR = 3600 > var now = Math.floor((new Date().getTime()) / 1000) // seconds since epoch right now > db.oplog.rs.find({ "ts" : { "$lt" : Timestamp(now, 1), "$gt" : Timestamp(now - SECS_PER_HOUR, 1) } }查询某一时间段内的oplog(当然注意时间是UTC存储)
> var since = Math.floor(ISODate("2014-08-12T09:00:00.000Z").getTime() / 1000) > var until = Math.floor(ISODate("2014-08-12T15:00:00.000Z").getTime() / 1000) > db.oplog.rs.find({ "ts" : { "$lt" : Timestamp(until, 1), "$gt" : Timestamp(since, 1) } })聚合统计各个集合的UPDATE操作量
> db.oplog.rs.aggregate([ { $match: { "op":"u" }}, { $group: { _id:"$ns",count:{$sum:1}}} ])oplog参考
Replica Set Oplog
https://docs.mongodb.com/manual/core/replica-set-oplog/
另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
分享文章:查询MongoDBoplog.rs-创新互联
分享链接:http://myzitong.com/article/dopggp.html