在使用streaming_bulk
helper时,我偶尔会遇到BulkIndexError
。是否有任何方法配置客户端以重试此类错误?使用帮助程序时处理错误的最佳方法是什么?
嗯,你可以设置你的流管道在某种程度上,以便重试错误(我相信,这将是一个BulkIndexError
)。
streaming_bulk
的响应是一个看起来像ok, item
的元组[见此]。现在,如果您在try中包装对streaming_bulk
的请求,并且在except中不清空操作列表,则可以将此try-except
块置于无限循环中,并在操作列表为空时中断。