批量插入Cosmos DB需用Task.Delay规避429错误，耗时过长求优化

针对你当前的问题，以下几个优化方向可以同时解决429限流问题和耗时过长的问题：

1. 利用CosmosClient内置重试策略替代手动Delay #

Cosmos SDK本身已内置针对429错误的重试机制，默认策略可能不够适配你的场景，你可以自定义重试参数，让SDK自动处理限流，无需手动添加固定Delay，等待逻辑会根据Cosmos DB返回的Retry-After头智能调整，比固定等待更高效。

创建CosmosClient时配置重试选项：

var clientOptions = new CosmosClientOptions
{
    RetryOptions = new CosmosRetryOptions
    {
        MaxRetryAttemptsOnRateLimitedRequests = 10, // 按需调整最大重试次数
        MaxRetryWaitTimeOnRateLimitedRequests = TimeSpan.FromSeconds(30) // 按需调整最大重试等待时长
    }
};
using var client = new CosmosClient(_cosmosDbOptions.CosmosDbAccountEndpoint, _cosmosDbOptions.CosmosDbAccountKey, clientOptions);

2. 采用并行处理并控制并发数 #

不要逐个串行插入，而是通过控制并发数实现批量并行插入，既提升效率，又不会因并发过高触发大量429。可以用SemaphoreSlim限制并发量，数值根据容器的RU（请求单位）调整，一般每100RU可支持2-3个并发操作。

优化后的完整代码示例：

private async Task SaveProductToDbAsync(IList<ResponseItem> products, ILogger log, CancellationToken cancellationToken)
{
    var clientOptions = new CosmosClientOptions
    {
        RetryOptions = new CosmosRetryOptions
        {
            MaxRetryAttemptsOnRateLimitedRequests = 10,
            MaxRetryWaitTimeOnRateLimitedRequests = TimeSpan.FromSeconds(30)
        }
    };
    using var client = new CosmosClient(_cosmosDbOptions.CosmosDbAccountEndpoint, _cosmosDbOptions.CosmosDbAccountKey, clientOptions);
    var database = client.GetDatabase(_cosmosDbOptions.CosmosDbDatabaseName);
    var container = database.GetContainer(_cosmosDbOptions.CosmosDbContainerId);

    int successInsert = 0;
    int totalCount = products.Count;
    // 根据容器RU调整并发数，示例设置为15
    const int maxConcurrency = 15;
    using var semaphore = new SemaphoreSlim(maxConcurrency);

    var tasks = products.Select(async item =>
    {
        await semaphore.WaitAsync(cancellationToken);
        try
        {
            item.id = Utility.ToGuid(item.pk);
            try
            {
                await container.CreateItemAsync(item, new PartitionKey(item.id), cancellationToken: cancellationToken);
                successInsert++;
                log.LogDebug($"CosmosDB Created item in Database with id: {item.id}");
            }
            catch (CosmosException cosmosException)
            {
                log.LogError($"CosmosDB Could not Create item in Database with id: {item.id}, StatusCode: {cosmosException.StatusCode}, Error: {cosmosException.Message}");
            }
            catch (Exception ex)
            {
                log.LogError($"CosmosDB Could not Create item in Database with id: {item.id}, Error: {ex.Message}");
            }
        }
        finally
        {
            semaphore.Release();
        }
    });

    await Task.WhenAll(tasks);

    log.LogInformation($"Inserted {successInsert}/{totalCount} products");
}

3. 临时调整容器吞吐量（可选） #

如果批量操作是定期执行的一次性任务，可以临时提升容器的RU值，完成插入后再降回原有配置，这能大幅降低429触发概率，进一步缩短操作耗时。

效果说明 #

通过智能重试+可控并行的组合优化，2100条数据的插入时间可从3分钟压缩至几十秒内，同时彻底避免手动固定Delay的低效问题。

内容的提问来源于stack exchange，提问作者advapi