MongoDB c#驱动程序RunCommandAsync

本文关键字：RunCommandAsync 驱动程序 MongoDB | 更新日期: 2023-09-27 18:19:52

我想从c#驱动程序运行db.printReplicationInfo()。

据我所知，我只能使用MongoDatabase.RunCommandAsync运行此处列出的命令。要做到这一点，我有这样的代码：

var command = new BsonDocumentCommand<BsonDocument>(new BsonDocument
{
    {"replSetGetStatus", 1}
});
var result = BsonSerializer.Deserialize<ReplicaSetStatus>(
             client.GetDatabase(ADMIN_DATABASE).RunCommandAsync(command).Result);

这使我可以运行该命令并将响应反序列化为我们创建的ReplicaSetStatus对象。（客户端是MongoClient的一个实例）。

我的问题是，我可以使用RunCommandAsync执行类似db.printReplicationInfo()的操作吗？命令会是什么样子？

如果没有，那么从c#运行这样的操作的最佳方式是什么？

看起来其他人也有类似的问题，但没有得到任何有用的答案。

谢谢！

MongoDB c#驱动程序RunCommandAsync

db.printReplicationInfo（）和db。GetReplicationInfo（）是MongoDb外壳函数，不能在外壳外使用。

您可以在mongo shell中看到自己的函数：

rs:PRIMARY> db.getReplicationInfo
function() {
    var localdb = this.getSiblingDB("local");
    var result = {};
    var oplog;
    var localCollections = localdb.getCollectionNames();
    if (localCollections.indexOf('oplog.rs') >= 0) {
        oplog = 'oplog.rs';
    } else {
        result.errmsg = "replication not detected";
        return result;
    }
    var ol = localdb.getCollection(oplog);
    var ol_stats = ol.stats();
    if (ol_stats && ol_stats.maxSize) {
        result.logSizeMB = ol_stats.maxSize / (1024 * 1024);
    } else {
        result.errmsg = "Could not get stats for local." + oplog + " collection. " +
            "collstats returned: " + tojson(ol_stats);
        return result;
    }
    result.usedMB = ol_stats.size / (1024 * 1024);
    result.usedMB = Math.ceil(result.usedMB * 100) / 100;
    var firstc = ol.find().sort({$natural: 1}).limit(1);
    var lastc = ol.find().sort({$natural: -1}).limit(1);
    if (!firstc.hasNext() || !lastc.hasNext()) {
        result.errmsg =
            "objects not found in local.oplog.$main -- is this a new and empty db instance?";
        result.oplogMainRowCount = ol.count();
        return result;
    }
    var first = firstc.next();
    var last = lastc.next();
    var tfirst = first.ts;
    var tlast = last.ts;
    if (tfirst && tlast) {
        tfirst = DB.tsToSeconds(tfirst);
        tlast = DB.tsToSeconds(tlast);
        result.timeDiff = tlast - tfirst;
        result.timeDiffHours = Math.round(result.timeDiff / 36) / 100;
        result.tFirst = (new Date(tfirst * 1000)).toString();
        result.tLast = (new Date(tlast * 1000)).toString();
        result.now = Date();
    } else {
        result.errmsg = "ts element not found in oplog objects";
    }
    return result;
}
rs:PRIMARY> db.printReplicationInfo
function() {
    var result = this.getReplicationInfo();
    if (result.errmsg) {
        var isMaster = this.isMaster();
        if (isMaster.arbiterOnly) {
            print("cannot provide replication status from an arbiter.");
            return;
        } else if (!isMaster.ismaster) {
            print("this is a slave, printing slave replication info.");
            this.printSlaveReplicationInfo();
            return;
        }
        print(tojson(result));
        return;
    }
    print("configured oplog size:   " + result.logSizeMB + "MB");
    print("log length start to end: " + result.timeDiff + "secs (" + result.timeDiffHours + "hrs)");
    print("oplog first event time:  " + result.tFirst);
    print("oplog last event time:   " + result.tLast);
    print("now:                     " + result.now);
}
相关文章：