2

ここでJavaに実装されているものに似たMongoDBC＃ドライバーを使用してoplogウォッチャーを作成しようとしています。

これまでのところ、私はなんとか書くことができました：

public static void Read()
{
    const string connectionString = "mongodb://127.0.0.1:27017,127.0.0.1:27018/?replicaSet=rs0";
    MongoClient mongoClient = new MongoClient(connectionString);

    MongoDatabase local = mongoClient.GetServer().GetDatabase("local");
    MongoCollection opLog = local.GetCollection("oplog.$main");
    BsonValue lastId = BsonMinKey.Value;
    while (true)
    {
        var query = Query.GT("_id", lastId);
        var cursor = opLog.FindAs<BsonDocument>(query)
                    .SetFlags(
                        QueryFlags.AwaitData |
                        QueryFlags.TailableCursor |
                        QueryFlags.NoCursorTimeout)
                    .SetSortOrder(SortBy.Ascending("$natural"));
        using (var enumerator = (MongoCursorEnumerator<BsonDocument>)cursor.GetEnumerator())
        {
            while (true)
            {
            // I get a "tailable cursor requested on non capped collection" Exception
                if (enumerator.MoveNext())
                {
                    var document = enumerator.Current;
                    lastId = document["_id"];
                }
                else
                {
                    if (enumerator.IsDead)
                    {
                        break;
                    }
                    if (!enumerator.IsServerAwaitCapable)
                    {
                        Thread.Sleep(TimeSpan.FromMilliseconds(100));
                    }
                }
            }
        }
    }
}

サーバー上でoplogを作成し、ここにある手順を使用してmongoコマンドラインから正常にクエリを実行しましたが、例外で上限が設定されていない理由がわかりません。

4

1 に答える 1

1

レプリカセットを使用してセットアップしている場合は、oplogがあります。

oplogをクエリするには、データベース'local'を使用します。

その後、変更します

local.GetCollection("oplog.$main");

に

local.GetCollection("oplog.rs");
于 2013-03-07T19:28:42.970 に答える