elasticsearch-py - 使用批量流时如何使用 elasticsearch-py 重试索引？

Question

我偶尔BulkIndexError使用streaming_bulk助手时。有没有办法配置客户端重试此类错误？使用助手时处理错误的最佳方法是什么？

Answer 1

好吧，您可以以某种方式设置流式传输管道，以便重试错误（我相信，这将是一个BulkIndexError）。

来自的响应streaming_bulk是一个看起来像ok, item[see this ] 的元组。现在，如果您将请求包装streaming_bulk在 try 中，并且在您的 except 中，不要清空您的操作列表，您可以让这个try-except块处于无限循环中，并在您的操作列表为空时中断。