我已经安装了一个麋鹿堆栈。我的elasticsearch磁盘已满,因此我更改了elasticsearch.yml的path.data参数,使其指向一个新磁盘。(新磁盘的权限已正确设置,ES已启动并运行,我看到数据已加载到ES (收集在新磁盘中),因此logstash能够收集并发送数据,当我查询ES以列出索引( get _cat/ index ?v)时,我可以看到所有索引都已列出,但kibana web界面没有显示任何可以选择作为默认索引的索引,因此我收到错误"No default index pattern“。您必须选择或创建一个才能继续。“,但当我使用旧磁盘时,它会自动列出我可以从中
假设我们有一个Elasticsearch查询,其中包含路由关键字apple、bear、peach。路由键apple和bear映射到分片1,peach映射到分片2,发送时会有两个单独的查询发送到分片1,还是会有一个合并查询发送到分片1,因为ES已经在内部做了优化? 假设发送到分片1的查询匹配doc1和doc2。主分片会收到来自分片1的doc1、doc2,还是会因为发送单独的查询而收到doc1、doc2、doc1、doc2?如果是后者,ES会过滤掉重复的文档吗? 我读了the ES docs about routing,但没有运气。
在Stormcrawler 1.14的已完成任务列表中,我看到列出了"Upgrade to Elasticsearch 7.0.x“和"ES 6.70 dependency elasticsearch”。这是否意味着1.14与这两个版本都兼容? 我之所以这样问,主要是因为我试图使用mvn archetype:generate生成一个1.13 stormcrawler,得到的消息是:Archetype repository not defined. Using the one from [com.digitalpebble.stormcrawler:storm-crawler-
在过去的一周里,我试图将Winlogbeat(在我的主机上)连接到我使用dockers在Ubuntu上设置的elasticsearch集群。
遵循教程。(在本教程中,他们不解释如何连接节拍)
我的问题是(Winlog节拍的) SSL配置,我只是因为某些原因不能正确地完成它。
这是运行安装命令(.\winlogbeat.exe setup -e)后在windows机器上遇到的错误-
2021-02-22T01:42:13.286+0200 ERROR instance/beat.go:971 Exiting: couldn't connect to any of
the
我们有这样的东西(我们为每集,节目和用户保存一个项目。并且所有项目都保存在同一个索引上:):
我们需要列出一个节目中的所有情节,但是我们需要过滤用户已经看过的节目。
在PostgreSQL中,我会运行这样的操作:
SELECT * FROM Episode WHERE show_id = 'showID' AND episode_id NOT IN (SELECT episode_id FROM watched WHERE user_id = 'userId')
但是,由于我们使用的是Elasticsearch,所以我们不确定什么是替代方案。
我们还假设监
我在一个节点上运行了一个elasticsearch服务。在我重新启动ES之后。一些碎片在几分钟内没有分配。
整个步骤如下:
我把很多数据加载到我的Elasticsearch中。
我杀了我的elasticsearch程序
重新启动后,elasticsearch将变为红色。一些碎片仍未分配。
我注意到的是。在我杀死elasticsearch之前,我检查了碎片,是这样的
[sflow@ES01 bin]$ curl 'localhost:9200/_cat/shards?v'
index shard prirep state do
我正在设置一个简单的Node.js REST服务,使用官方的Javascript客户端与Elasticsearch连接。我在本地运行这段代码,但是集群位于远程。当我浏览浏览器时,使用_head插件,我可以毫无问题地连接ES和查询。但是,通过Javascript客户端执行此操作会使所有请求超时。我设置了ElasticSearch对象,但是向它发送任何请求都不起作用。我不认为这是网络问题,因为我可以通过浏览器访问ES。这是我请求东西的方式,一个非常基本的get:
var elasticsearch = require("elasticsearch");
var es = new e
我试图使用Python向ElasticSearch发送多个查询。我将所有的查询集中在一个列表中,其中查询是dict的类型。我可以使用以下方法将它们分别发送给弹性:
def send_query(query):
es = Elasticsearch([uri])
res = es.search(index="index", body=query, size=100)
return res
您能建议如何同时发送列表中的所有查询吗?我试过这样做,但不管用:
es = Elasticsearch([uri])
res = es.msearch(index="index"
我有一个麋鹿码头群设置运行在4个不同的主机。我可以ping不同主机上的容器,但当我尝试运行curl命令时,它无法连接curl http://elastic:9200。Logstash和kibana应用程序无法连接到位于不同主机上的elasticsearch容器(3节点es集群)。我已经在所有主机上打开了docker swarm文档中提到的所有端口,但没有成功。在停止所有主机上的防火墙后,LS/Kibana能够连接到elasticsearch。
尝试重新连接到已死的ES实例,但收到错误: Unable to connect to Elasticsearch at
有没有人遇到过这个问题?谢谢。
*[2020-01-21 19:26:03.593] [ERROR] fileserver - [RequestID:2032]-Error after returned from scroller
{ Error: [es_rejected_execution_exception] rejected execution of org.elasticsearch.transport.
TransportService$6@1178a002
org.elasticsearch.transport.TransportService$6@1178a002 on EsThreadPoolExecu
我有一个带有JSON数据的Kafka主题。现在im试图使用新的"Java“()将这些JSON字符串发送到ES主题,但是im遇到解析器异常:
co.elastic.clients.elasticsearch._types.ElasticsearchException: [es/index] failed: [mapper_parsing_exception] failed to parse
at co.elastic.clients.transport.rest_client.RestClientTransport.getHighLevelResponse(RestClientTrans
下面是将数据发送到本地Elasticsearch的代码
r = [{'Name': 'Dr. Christopher DeSimone', 'Specialised and Location': 'Health'},
{'Name': 'Dr. Tajwar Aamir (Aamir)', 'Specialised and Location': 'Health'},
{'Name': 'Dr. Bernard M. Aaron',