异常:Microsoft.Azure.Documents.RequestRateTooLargeException 从 DocumentDB 查询时
Exception: Microsoft.Azure.Documents.RequestRateTooLargeException while querying from DocumentDB
y 查询类似于
this.ProcessRequestSync(() => this.Client.CreateDocumentQuery<Model>(this.DocumentDBCollectionLink).Where(d => d.name.Equals(name) && d.code.Equals(code) && d.Type.Equals(this.documentType) && d.CreatedBy.Equals(myName).ToList<Model>());
public dynamic ProcessRequestSync(Func<dynamic> getRequest)
{
var delay = TimeSpan.Zero;
var minDelayTime = new TimeSpan(0, 0, 1);
for (;;)
{
try
{
Thread.Sleep(delay);
return getRequest();
}
catch (DocumentClientException documentClientException)
{
var statusCode = (int)documentClientException.StatusCode;
if (statusCode == 429 || statusCode == 503)
{
string errorMessage = string.Format("failed at DocumentDB with {0} status and {1} retry time", statusCode, documentClientException.RetryAfter);
this.Logger.Log(errorMessage );
// Back off if the request rate is too large or the service is temporarily unavailable
delay = TimeSpan.Compare(documentClientException.RetryAfter, minDelayTime) >= 0 ? documentClientException.RetryAfter: minDelayTime;
}
else
{
throw;
}
}
}
}
这是 requestRateTooLarge 异常引发时的重试逻辑方法。
我不确定它是否工作正常,
一次查询和插入大约 4000 条记录时出现异常:Microsoft.Azure.Documents.RequestRateTooLargeException,
我使用了相同的重试逻辑来插入,它工作正常。
我没有收到任何错误,也成功插入了所有记录,但无法获取查询数据。
您还需要一个用于 AggregateException 的 catch 块,并检查 AggregateException.InnerException 是否为 DocumentClientException 并对 StatusCode == 429 执行相同的检查。由于查询执行是异步的,您可能会受到限制包裹在 AggregateException 中的异常。
如果您可以 post 完整重现,我们或许能够明确地找出问题所在。
基于@aravind Ramachandra 和@Ryan CrawCour 的回答above/below,这就是我用来解决这个问题的方法。
public async Task SaveToDocDb(dynamic jsonDocToSave)
{
using (var client = new DocumentClient(endpoint, authKey))
{
var queryDone = false;
while (!queryDone)
{
try
{
await client.CreateDocumentAsync(docCollectionlink, jsonDocToSave);
queryDone = true;
}
catch (DocumentClientException documentClientException)
{
var statusCode = (int)documentClientException.StatusCode;
if (statusCode == 429 || statusCode == 503)
Thread.Sleep(documentClientException.RetryAfter);
else
throw;
}
catch (AggregateException aggregateException)
{
if(aggregateException.InnerException.GetType() == typeof(DocumentClientException)){
var docExcep = aggregateException.InnerException as DocumentClientException;
var statusCode = (int)docExcep.StatusCode;
if (statusCode == 429 || statusCode == 503)
Thread.Sleep(docExcep.RetryAfter);
else
throw;
}
else
throw;
}
}
}
}
y 查询类似于
this.ProcessRequestSync(() => this.Client.CreateDocumentQuery<Model>(this.DocumentDBCollectionLink).Where(d => d.name.Equals(name) && d.code.Equals(code) && d.Type.Equals(this.documentType) && d.CreatedBy.Equals(myName).ToList<Model>());
public dynamic ProcessRequestSync(Func<dynamic> getRequest)
{
var delay = TimeSpan.Zero;
var minDelayTime = new TimeSpan(0, 0, 1);
for (;;)
{
try
{
Thread.Sleep(delay);
return getRequest();
}
catch (DocumentClientException documentClientException)
{
var statusCode = (int)documentClientException.StatusCode;
if (statusCode == 429 || statusCode == 503)
{
string errorMessage = string.Format("failed at DocumentDB with {0} status and {1} retry time", statusCode, documentClientException.RetryAfter);
this.Logger.Log(errorMessage );
// Back off if the request rate is too large or the service is temporarily unavailable
delay = TimeSpan.Compare(documentClientException.RetryAfter, minDelayTime) >= 0 ? documentClientException.RetryAfter: minDelayTime;
}
else
{
throw;
}
}
}
}
这是 requestRateTooLarge 异常引发时的重试逻辑方法。
我不确定它是否工作正常,
一次查询和插入大约 4000 条记录时出现异常:Microsoft.Azure.Documents.RequestRateTooLargeException,
我使用了相同的重试逻辑来插入,它工作正常。 我没有收到任何错误,也成功插入了所有记录,但无法获取查询数据。
您还需要一个用于 AggregateException 的 catch 块,并检查 AggregateException.InnerException 是否为 DocumentClientException 并对 StatusCode == 429 执行相同的检查。由于查询执行是异步的,您可能会受到限制包裹在 AggregateException 中的异常。
如果您可以 post 完整重现,我们或许能够明确地找出问题所在。
基于@aravind Ramachandra 和@Ryan CrawCour 的回答above/below,这就是我用来解决这个问题的方法。
public async Task SaveToDocDb(dynamic jsonDocToSave)
{
using (var client = new DocumentClient(endpoint, authKey))
{
var queryDone = false;
while (!queryDone)
{
try
{
await client.CreateDocumentAsync(docCollectionlink, jsonDocToSave);
queryDone = true;
}
catch (DocumentClientException documentClientException)
{
var statusCode = (int)documentClientException.StatusCode;
if (statusCode == 429 || statusCode == 503)
Thread.Sleep(documentClientException.RetryAfter);
else
throw;
}
catch (AggregateException aggregateException)
{
if(aggregateException.InnerException.GetType() == typeof(DocumentClientException)){
var docExcep = aggregateException.InnerException as DocumentClientException;
var statusCode = (int)docExcep.StatusCode;
if (statusCode == 429 || statusCode == 503)
Thread.Sleep(docExcep.RetryAfter);
else
throw;
}
else
throw;
}
}
}
}