CosmosDb SDK v3在批量插入时会自动重试吗？

Question

我是CosmosDB的新手，我正在努力掌握R/U的设置限制。

位置

在ASP.NETCore 2.1应用程序中，我想一次插入 /-3000个文档。循环这些项目并一个接一个地添加它们需要几分钟的时间。所以批量可能是最好的方法。我遵循了一些资源，例如：

使用docs.microsoft.com上的.NET SDK将数据批量导入Azure Cosmos DB SQL API帐户

在. NET SDK中引入批量支持

在我的代码中，我使用了博客中的示例代码。

List<Task> concurrentTasks = new List<Task>();
foreach (var entity in entities)
{
    entity.Id = GenerateId(entity);

    concurrentTasks.Add(Container.CreateItemAsync(entity, new PartitionKey(entity.RoleId)));
}

await Task.WhenAll(concurrentTasks);

将一个文档从我的本地开发机器插入Azure大约需要6个R/U。

当我设置默认的每秒400 R/U时，我很快就会得到429个太多请求异常。当我切换到自动缩放时，它在大约20秒内完成，没有异常。

我的问题是：如果我想限制R/U，并且仍然使用这种concurrentTasks方法，SDK会进行重试处理吗？或者我是否需要编写自己的429重试。

Answer 1

V3中的批量确实在429上应用重试（您可以通过查看任何操作中的诊断属性来验证这一点）。

重试次数由＜code＞CosmosClientOptions控制。MaxRetryAttemptsOnRateLimitedRequests（默认为9）。您得到错误的事实意味着SDK已经重试了9次。您可以增加此值并保持SDK重试（这将需要更长时间）。

启用自动缩放很有帮助，这意味着您想要推入的数据负载对于所调配的吞吐量(您提到的400 RU)来说太高了。Autoscale将检测节流并增加所提供的吞吐量以适应负载。