Иногда выполнение FindAsync(), FindOneAndReplaceAsync(), UpdateOneAsync() занимает более 25 минут. ⇐ C#

[Anonymous]

Я использую драйвер .NET для запроса Mongo в своем .NET-приложении. Я использую шаблон репозитория. Иногда выполнение методов FindAsync(), FindOneAndReplaceAsync(), UpdateOneAsync() занимает более 25 минут.
Я запустил профилировщик в Mongodb для запросов длиной более 2000 мс, но ни одного из этих запросов, которые я вижу, там нет.
Я нашел это в New Relic. Это периодически возникающая проблема. Поделитесь приведенным ниже кодом, помогите мне разобраться.
Игнорируйте токен отмены, я не передаю его для решения этой проблемы.
Использование .NET с версией MongoDB.Driver="2.23.1"
// connectionstirng
"ConnectionString": "abc.in:21011/abc&directConnection=true&serverSelectionTimeoutMS=600000"

// Calling methods
var data = await _mongoDb.GetAsync(x => x.CoRelationId == cid, token);

await _mongoDb.AddUpdate(log);

public MongoLogRepo(IOptions MongoDbSettings)
{
var mongoClient = new MongoClient(MongoDbSettings.Value.ConnectionString);

var mongoDatabase = mongoClient.GetDatabase(MongoDbSettings.Value.DatabaseName);

_mongoRepo = mongoDatabase.GetCollection(
MongoDbSettings.Value.NhcxCollectionName);
_mongoRepoProfile = mongoDatabase.GetCollection(
MongoDbSettings.Value.ProfileCollectionName);
}

//public async Task GetAsync() =>
// await _mongoRepo.Find(_ => true).ToListAsync();

public async Task GetAsync(string id) =>
await _mongoRepo.Find(x => x._Id == id).ToListAsync();

public async Task GetAsync(Expression predicate, CancellationToken token)
{
try
{
return await _mongoRepo.Find(predicate).ToListAsync();
}
catch (OperationCanceledException)
{
Console.WriteLine("Operation cancelled");
}

return new List();
}

public async Task Update(string id, Dictionaryvalue)
{
try
{
Console.WriteLine($" {DateTime.Now} in Mongo update");
var updList = new List();

foreach (var kvp in value)
{
updList.Add(Builders.Update.Set(kvp.Key, kvp.Value));
}

var final = Builders.Update.Combine(updList);
var updateResult = await _mongoRepo.UpdateOneAsync(rec => rec._Id == id, final)
.ConfigureAwait(false);

return updateResult.IsAcknowledged &&
updateResult.ModifiedCount > 0;
}
catch (Exception ex)
{
Console.WriteLine(Newtonsoft.Json.JsonConvert.SerializeObject(ex));
throw new Exception ("Error while updating the Mongo "+ Newtonsoft.Json.JsonConvert.SerializeObject(ex));
}
}

public async Task AddUpdate(Nhcx_Mongo_Log record)
{
if (record != null && !string.IsNullOrEmpty(record.CoRelationId))
{
try
{
var updateRecord = await _mongoRepo.FindOneAndReplaceAsync(x => x.CoRelationId == record.CoRelationId, record);

if (updateRecord == null)
await _mongoRepo.InsertOneAsync(record);

return true;
}
catch (Exception ex)
{
throw new Exception("Mongo db transaction failed");
}
}

return false;
}

public Task? FetchProfileAsync(Expression predicate)
{
return _mongoRepoProfile.Find(predicate).ToListAsync();
}

public void AddProfiles(List profile)
{
_mongoRepoProfile.InsertMany(profile);
}


Подробнее здесь: https://stackoverflow.com/questions/791 ... ing-longer