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



在使用streaming_bulk helper时,我偶尔会遇到BulkIndexError。是否有任何方法配置客户端以重试此类错误?使用帮助程序时处理错误的最佳方法是什么?

嗯,你可以设置你的流管道在某种程度上,以便重试错误(我相信,这将是一个BulkIndexError)。

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

相关内容

  • 没有找到相关文章

最新更新