El controlador de Mongo le dice qué registros tienen errores y cuáles no se procesaron en absoluto. Si todos los errores (generalmente uno) tienen el código 16500, entonces su problema es acelerar y volver a intentar los errores y los registros restantes son seguros. De lo contrario, sus errores se deben a otra cosa y debe hacer un análisis y decidir si continúa con los reintentos.
El controlador de Mongo no devuelve el encabezado HTTP donde Cosmos DB sugiere un retraso antes de volver a intentarlo, pero eso no es gran cosa. De todos modos, el retraso no garantiza el éxito, porque otras solicitudes que llegan a la misma base de datos pueden agotar las RU. Es mejor experimentar y determinar sus propias reglas de reintento. A continuación se muestra una solución recursiva simple que continúa reintentando hasta que todo está bien o se alcanza el límite de reintentos.
private async Task InsertManyWithRetry(IMongoCollection<BsonDocument> collection,
IEnumerable<BsonDocument> batch, int retries = 10, int delay = 300)
{
var batchArray = batch.ToArray();
try
{
await collection.InsertManyAsync(batchArray);
}
catch (MongoBulkWriteException<BsonDocument> e)
{
if (retries <= 0)
throw;
//Check if there were any errors other than throttling.
var realErrors = e.WriteErrors.Where(we => we.Code != 16500).ToArray();
//Re-throw original exception for now.
//TODO: We can make it more sophisticated by continuing with unprocessed records and collecting all errors from all retries.
if (realErrors.Any())
throw;
//Take all records that had errors.
var errors = e.WriteErrors.Select(we => batchArray[we.Index]);
//Take all unprocessed records.
var unprocessed = e.UnprocessedRequests
.Where(ur => ur.ModelType == WriteModelType.InsertOne)
.OfType<InsertOneModel<BsonDocument>>()
.Select(ur => ur.Document);
var retryBatchArray = errors.Union(unprocessed).ToArray();
_logger($"Retry {retryBatchArray.Length} records after {delay} ms");
await Task.Delay(delay);
await InsertManyWithRetry(collection, retryBatchArray, retries - 1, delay);
}
}