Azure搜索RetryPolicy

Question

我们正在使用蔚蓝搜索，需要实现重试策略以及存储失败文档的Ids，如所述。

有没有关于如何在Azure搜索中实现RetryPolicy策略的文档/示例？

谢谢

Answer 1

这就是我所用的：

 private async Task<DocumentIndexResult> IndexWithExponentialBackoffAsync(IndexBatch<IndexModel> indexBatch)
 {
      return await Policy
           .Handle<IndexBatchException>()
           .WaitAndRetryAsync(5, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), (ex, span) =>
           {
                indexBatch = ((IndexBatchException)ex).FindFailedActionsToRetry(indexBatch, x => x.Id);
           })
           .ExecuteAsync(async () => await _searchClient.IndexAsync(indexBatch));
 }

它使用波利图书馆来处理指数退避。在本例中，我使用了一个模型IndexModel，它有一个名为Id的id字段。如果您想记录或存储失败尝试的in，可以在WaitAndRetryAsync函数中这样做，如

((IndexBatchException)ex)ex.IndexingResults.Where(r => !r.Succeeded).Select(r => r.Key).<Do something here>

Answer 2

目前还没有显示如何在IndexBatchException上正确重试的示例。但是，有一种方法可以用来使实现变得更容易：IndexBatchException.FindFailedActionsToRetry。此方法从IndexBatchException中提取失败文档的ID，将它们与给定批处理中的操作关联起来，并返回一个新批处理，其中只包含需要重新尝试的失败操作。

关于重试逻辑的其余部分，您可能会发现ClientRuntime库中的这段代码很有用。您需要根据负载的特性调整参数。重要的是，在重新尝试帮助您的服务恢复之前，您应该使用指数退避，因为否则可能会限制您的请求。