我目前正在使用laravel-elasticsearch我的ES查询的提供者。我在我的laravel队列(使用beanstalkd)处理的作业中使用它。我遇到的问题是，在长时间运行的作业中，最终我无法再将数据插入到elasticsearch中。工作只是挂起(没有抛出异常)我已经将它缩小到我进行ES调用的代码。我的连接是否有可能变得陈旧而不重新连接？我的另一个想法是它与使用Facade和它是一个单例有关。这是我正在做的，这不是我的确切代码。但是当它没有在长时间运行的作业中运行时，代码工作得很好。我只是想提供一些上下文。它插入得很好，在长时间运行的过程之后运行之前，代码运行没有问题。更新:

使用@Id注释我可以添加id字段到我的模型对象，当我执行查询时，生成的模型对象将包含elasticsearch_id的值在@Id带注释的字段。但是，我还没有弄清楚如何获取其他文档元数据，例如_version.我尝试添加version字段到我的模型并用@Version注释它注释但什么也没发生，该字段仍然存在null.{"_index":"twitter","_type":"tweet","_id":"1","_version":1,"found":true,"_source":{"user":"kimchy","postDate":"2009-11-15T14:12:12","messa

Settingssettings=Settings.settingsBuilder().put("cluster.name","logging_elasticsearch").build();TransportClientclient=TransportClient.builder().settings(settings).build().addTransportAddress(newInetSocketTransportAddress(InetAddress.getByAddress(newbyte[]{10,100,30,62}),9300));SearchResponseresp

我的ElasticSearch集群中有3个节点。例如。10.10.0.1、10.10.0.2、10.10.0.3现在我正在尝试使用Jest客户端API连接到集群并提供上述节点之一的IP(10.10.0.1)。现在，如果节点(10.10.0.1)已关闭，是否意味着我无法访问集群？如何处理这种我们有多个节点并尝试使用一个IP地址从代码连接到集群的问题？或者我应该去创建其他连接并提供另一个IP地址吗？我觉得这是一种非常粗略的做法，因为如果我们有100个节点，在那种情况下我们最终会尝试一个接一个地连接到100个节点。 最佳答案 我会看看在所

我想在保存查询以备后用之前验证查询。我看到ES有一个validateAPI但它看不到将它与Javaapi一起使用的方法。有没有办法使用javaapi验证ES查询？也许我可以在保存之前运行查询？ 最佳答案 所以在查看了Elasticsearch源代码之后，我想到了这个解决方案。publicActionFuturevalidateAsync(QueryBuilderquery,String[]indices){finalValidateQueryRequestrequest=newValidateQueryRequest();reque

我在java中有一个项目，我使用Elasticsearch2.3.3为数据编制索引。索引有两种类型。我的索引文档如下所示:{"took":10,"timed_out":false,"_shards":{"total":1,"successful":1,"failed":0},"hits":{"total":3,"max_score":1,"hits":[{"_index":"test_index","_type":"movies","_id":"uReb0g9KSLKS18sTATdr3A","_score":1,"_source":{"genre":"Thriller"}},{"_i

如何使用luke打开elasticsearch索引？我尝试了从3.5到4.8的luke，从1.1到1.2的elasticsearch，但似乎没有任何效果。似乎唯一适用的资源是http://rosssimpson.com/blog/2014/05/06/using-luke-with-elasticsearch/不幸的是，这没有用。 最佳答案 Luke现在支持elasticsearch1.5.0:https://github.com/DmitryKey/luke(从master构建或使用https://github.com/Dmitr

我在AWS云中有一个ElasticSearch实例，运行良好。但是我需要用S3来设置它来存储快照。首先，我需要通过将以下内容发布到端点(模拟json示例)来设置S3存储库:PUT_snapshot/my_s3_repository{"type":"s3","settings":{"bucket":"my_bucket_name","region":"us-west"}}但作为返回，我得到以下信息:“消息”:“快照注册需要settings.role_arn。”有什么想法吗？我曾尝试在IAM中摆弄角色，但没有成功。 最佳答案 将AWS论

我在Java中有一个简单的elasticsearch代码是这样的:publicclassTryElastic{publicstaticvoidmain(String[]args)throwsUnknownHostException{Mapjson=newHashMap();json.put("user","kimchy");json.put("postDate",newDate());json.put("message","tryingoutElasticsearch");try{Settingssettings=Settings.settingsBuilder().put("clus

我不明白高级REST客户端(它取代了传输客户端)和SpringDataElasticsearch之间的关系。有一些教程(https://www.baeldung.com/spring-data-elasticsearch-tutorial)展示了如何使用getSomethingById()等自动实现的方法进行JPA风格的查询。他们使用这个界面:publicinterfaceElasticsearchRepositoryextendsElasticsearchCrudRepository{但是ElasticsearchRepository似乎需要一个带有ElasticsearchTemp