elasticsearch - DeleteByQueryRequest 套接字超时异常 - java 高级别的客户端 api
问题描述
我是弹性搜索的初学者,我想删除大量与特定查询匹配的文档。我为此目的使用 DeleteByQueryRequest。我尝试了下面的代码。
String fileName="output2.log";
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http")));
DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest("_all");
deleteRequest.setQuery(QueryBuilders.termQuery("fileName.keyword",fileName));
deleteRequest.setTimeout(TimeValue.timeValueMinutes(10));
//deleteRequest.setRefresh(true);
BulkByScrollResponse bulkResponse = client.deleteByQuery(deleteRequest, RequestOptions.DEFAULT);
client.close();
System.out.println(bulkResponse.isTimedOut());
System.out.print("Deletion done");
当我运行此代码时,相应的文档会被删除,但此代码会引发以下异常。
java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-0 [ACTIVE]
可以做些什么来摆脱这个异常?提前致谢。
解决方案
经过一番研究,我发现 RestHighLevelClient 的默认套接字超时为 30000 毫秒。我使用下面的代码来延长套接字超时时间。
RestHighLevelClient client = new RestHighLevelClient((RestClient.builder(new
HttpHost(localhost,9200,"http"))).setRequestConfigCallback(requestConfigBuilder ->
requestConfigBuilder
.setConnectTimeout(10000)
.setSocketTimeout(60000)
.setConnectionRequestTimeout(0)
));
现在您可以在 setSocketTimout() 方法中增加时间限制。
推荐阅读
- hyperledger-fabric - 关于 Hyperledger Fabric Python SDK 的问题
- javascript - 如何向用户隐藏 javascript(反应本机)应用程序中的 S3 密钥?
- java - 使用 JdbcTempalte 时如何正确使用事务?
- javascript - rejected Promise in try-catch with/without await
- tensorflow - 尝试在 S3 存储桶中保存 TF 模型时出现 KeyError:'callable_inputs'
- windows - 获取内存映射文件的名称
- json - 使用flutter和php创建用户登录时解析json数据的类型错误
- python - 如何在 Pandas 中查询字符串
- logging - 如何从 Azure Blob 存储配置 Fluentbit / Fluentd 输入?什么输入类型?
- php - 如何在电报上分享网站上的图像?