如何在不查询每个节点的情况下使用PySpark对Elasticsearch运行查询？
在不查询每个节点的情况下使用PySpark对Elasticsearch运行查询，可以通过使用Elasticsearch的分布式查询功能来实现。具体步骤如下：
- 首先，确保已经安装了PySpark和Elasticsearch的Python客户端库。可以使用pip命令进行安装。
- 导入所需的库和模块：
from pyspark.sql import SparkSession
from pyspark.sql.functions import *
from elasticsearch import Elasticsearch- 创建一个SparkSession对象：
spark = SparkSession.builder \
.appName("Elasticsearch Query") \
.getOrCreate()- 创建一个Elasticsearch客户端对象：
es = Elasticsearch(hosts=["<elasticsearch_host>"])其中，<elasticsearch_host>是Elasticsearch的主机地址。
- 使用Spark读取Elasticsearch中的数据：
df = spark.read.format("org.elasticsearch.spark.sql") \
.option("es.nodes", "<elasticsearch_host>") \
.option("es.resource", "<index>/<type>") \
.load()其中，<index>是Elasticsearch中的索引名称，<type>是索引中的类型名称。
- 运行查询操作：
result = df.filter("<query_condition>").select("<columns>")其中，<query_condition>是查询条件，可以使用Spark的DataFrame API进行灵活的查询操作，<columns>是需要返回的列。
- 将查询结果写入Elasticsearch：
result.write.format("org.elasticsearch.spark.sql") \
.option("es.nodes", "<elasticsearch_host>") \
.option("es.resource", "<index>/<type>") \
.mode("overwrite") \
.save()- 关闭SparkSession和Elasticsearch客户端连接：
spark.stop()
es.close()这样，就可以在不查询每个节点的情况下使用PySpark对Elasticsearch运行查询了。
推荐的腾讯云相关产品：腾讯云Elasticsearch Service（ES），它是基于开源Elasticsearch的托管式云服务，提供了高可用、高性能、易扩展的Elasticsearch集群，适用于日志分析、全文搜索、数据挖掘等场景。
产品介绍链接地址：腾讯云Elasticsearch Service（ES）
相关·内容
我读了Elasticsearch文档，我知道Elasticsearch的API和查询DSL。我还可以找到关于如何从Elasticsearch获取查询结果的文档，但是如何在任何内部查询上有效地计算聚合呢？
浏览 3提问于2016-06-30得票数 2
6回答
我正在设置一个简单的Node.js REST服务，使用官方的Javascript客户端与Elasticsearch连接。我在本地运行这段代码，但是集群位于远程。当我浏览浏览器时，使用_head插件，我可以毫无问题地连接ES和查询。但是，通过Javascript客户端执行此操作会使所有请求超时。我设置了ElasticSearch对象，但是向它发送任何请求都不起作用。我不认为这是网络问题，因为我可以通过浏览器访问ES。这是我请求东西的方式，一个非常基本的get：
var elasticsearch = require("elasticsearch");
var es = new e
浏览 0提问于2014-03-14得票数 21
我的最终目标是使用PySpark在Elasticsearch (ES)中高效地索引大量数据，然后对索引运行大量查询，并记录结果的统计信息。 Elasticsearch version 5.6.5
Spark version 2.4.0
Hadoop version 2.7
Elasticsearch-Hadoop python library version: 6.6.0 考虑以下代码： from pyspark import SparkContext
from pyspark import SparkConf
from pyspark.sql import SQLContext
# cr
浏览 20提问于2019-02-13得票数 0
我希望停止elasticsearch中的节点间通信，基本上是停止侦听端口9300。以上应该在不使用防火墙阻止任何端口的情况下实现。 我尝试关闭服务器引导程序中的netty通道，如果我这样做了，elasticsearch将无法启动。 当我运行elasticsearch实例时，它不应该侦听9300， 但是我得到了下面的错误，2019-03-25T10:46:16,344o.e.b.ElasticsearchUncaughtExceptionHandler在org.elasticsearch.bootstrap.Elasticsearch.execute(Elasticsearch.java:15
浏览 41提问于2019-03-25得票数 0
我需要设置多少个碎片和副本才能使用集群中的每个cpu核心(我想要100%加载，查询结果最快)？
我想使用Elasticsearch来进行聚合。我读到Elasticsearch使用多个cpu核，但是没有发现关于切分和复制的cpu核的确切细节。
我的观察是，一个碎片在查询时不会使用一个以上的核心/线程(考虑到一次只有一个查询)。对于副本，1-碎片索引的查询速度并不快，因为Elasticsearch似乎不使用其他节点来分配碎片上的负载。
我的问题(一次一个问题)：
一个碎片不使用一个以上的cpu核心？
碎片必须始终被完全扫描，复制不能用来在节点之间划分碎片内部的负载？
最佳性能的公式是和
浏览 3提问于2015-11-09得票数 9
回答已采纳
我们需要在AWS Elasticsearch上添加一个协调节点，但是很难找到方法。有可能吗？怎么做？
浏览 3提问于2021-03-03得票数 1
回答已采纳
我已经阅读过这个页面和其他相关链接，以便在hadoop上安装和配置elasticsearch。
但是，我没有什么问题。
我分别使用elasticsearch和spark/hadoop；具体而言，我使用的是cloudera和elasticsearch，它们运行在其他linux机器上。在hadoop中，我有一个边缘节点来提交火花作业，作业通过配置的执行器在其他6个节点上运行。
下面这个安装指南对我来说信息不多。
(1)当我在每个节点上安装elasticsearch-hadoop二进制文件时，Elasticsearch在HDFS上保留索引？(2)如果是，我需要将jar二进制文件放在哪里？
浏览 3提问于2016-03-09得票数 2
使用PySpark，我试图从elasticsearch中读取数据。通常，我会将查询设置为类似的内容(参见下面的查询)，并将索引设置为“my_ es.resource /doc”，这样我就可以将数据读取到spark中：
q ="""{
"query": {
"match_all": {}
}
}"""
但是，最近我在kibana上尝试了_xpack/sql，在其他SQL客户端上尝试了JDBC，它们在获取数据方面都工作得很好。但是，当我
浏览 0提问于2019-01-31得票数 3
1回答
环境详细信息：工作区: 6.2
应用服务器: server 8.5.5.0
OS: Windows 2008 r2
我试图在Worklight 6.2中实现操作分析的集群拓扑结构。以下是以下步骤
创建了两个自由服务器实例analytics1和analytics2。
在两个服务器的应用程序文件夹中复制analytics.war文件。
在server.xml服务器的analytis1中，我已经配置为主节点。
jndiEntry jndiName="analytics/nodetype“value="master”
jndiEntry jndiName="anal
浏览 5提问于2014-10-11得票数 1
回答已采纳
在服务器上运行的elasticsearch实例运行时，所有默认值都没有更改。
如何水平扩展到另一个网络上的另一个服务器？
你在哪里指定这个？
我在配置目录中只看到一个elasticsearch.yml文件，是否需要为每个集群/节点创建一个新的配置文件？配置文件似乎只用于一个实例。我如何告诉它将它用作主服务器和网络之外的辅助服务器作为辅助实例？
浏览 1提问于2014-10-01得票数 1
回答已采纳
我是Elasticsearch的新手，我想在一台机器上设置一个高度可用的Elasticsearch集群，以测试和学习如何使用Elasticsearch。我希望当主节点发生故障时，其他节点中的一个节点将接管并成为主节点。在我的机器上，我设置了一个由3个节点、一个主节点和两个数据节点组成的Elasticsearch集群，但是当我停止主节点时，没有其他节点接管并成为主节点，这是我对这三个节点的配置( elasticsearch的使用版本是7.9.2)：
# master node config.
cluster.name:demo-cluster
node.name: "es-node-1
浏览 4提问于2021-03-19得票数 0
当使用具有仲裁的复制时，Elasticsearch允许某些(少量)副本碎片写入失败。写入副本可能只会因为副本暂时不可用而失败(例如，由于临时网络分区)。当该碎片再次可用时(例如，网络是固定的)，会发生什么？
Elasticsearch是否自动检测到碎片过期(陈旧，与主碎片不一致)并在后台更新它？还是必须执行手动操作？当碎片因不可用而返回，但已过时时，Elasticsearch是否会自动避免查询该碎片(并检索陈旧的数据)，直到它被更新？或者必须提供特殊的查询参数，以确保不使用过时的碎片？
浏览 0提问于2018-02-16得票数 1
回答已采纳
Elasticsaerch的文档只涵盖了加载到Spark的完整索引。
from pyspark.sql import SQLContext
sqlContext = SQLContext(sc)
df = sqlContext.read.format("org.elasticsearch.spark.sql").load("index/type")
df.printSchema()
如何执行查询以从Elasticsearch索引返回数据，并使用pyspark将它们作为DataFrame加载到Spark？
浏览 0提问于2016-07-03得票数 11
我尝试使用以下命令启动每个节点，其中包括一台计算机和一个cluser (仅用于本地主机测试)：
sudo /usr/share/elasticsearch/bin/elasticsearch
-Des.node.data=false
-Des.node.master=true
-Des.node.name=NoData --default.path.conf=/etc/elasticsearch/
但是，我甚至不能启动一个节点，因为即使在启动第一个节点时，我仍然会得到这个错误：
> Exception in thread "main" java.lang.Run
浏览 4提问于2016-08-07得票数 1
回答已采纳
1回答
在将单节点群集改为多节点群集后，是否需要采取任何措施来利用群集？
例如，我们的应用服务器使用单个ip/port (单节点的ip/端口)搜索文档。
此外，logstash，kibana，single，它们都指向单个ip/端口。
我应该放置一个load balancer来利用多节点的优势吗？或者我可以免费得到一些东西？
我遵循以下停靠文件(仅将网络模式更改为主机，并部署在多个主机上)
es-log-00:
build:
context: .
dockerfile: ./compose/elasticsearch/Dockerfile
args:
浏览 2提问于2020-01-03得票数 1
回答已采纳
我们正在尝试从大约20,000台服务器收集性能指标，并使用下面的curl命令将数据发布到elasticsearch，以进一步分析数据
curl
-XPOST "$ELASTICSEARCH_URL/sariovm/sar/"
-H 'Content-Type: application/json'
-d '{ "@timestamp" : '\""$DATE3\""', "cpu" : '$cpu', "iowait"
浏览 0提问于2019-02-12得票数 0
我试图使用spark-sklearn库在星火库集群上执行网格搜索。出于这个原因，我在我的nohup ./spark_python_shell.sh > output.log & shell上运行bash以点燃Spark集群，并且运行我的python脚本(参见下面的spark-submit \ --master yarn 'rforest_grid_search.py')：
SPARK_HOME=/u/users/******/spark-2.3.0 \
Q_CORE_LOC=/u/users/******/****** \
ENV=loca
浏览 2提问于2018-10-25得票数 2
回答已采纳
我试图在我的查询中使用highlight，如这里提到的：。
此查询在search API中正确工作，但在实际执行昂贵的查询之前，我希望使用elasticsearch：提供的validation API验证它
但是这个错误消息失败了：
org.elasticsearch.common.ParsingException: request does not support [highlight]
那么，如何在不执行的情况下使用突出显示来验证查询呢？
我在ES讨论论坛上发现了一个类似的问题：，但它没有任何解决方案。
浏览 11提问于2022-11-25得票数 0
回答已采纳
如何检查索引是否存在并已准备好在ElasticSearch中使用？
目前，我们通过运行一个选择某些文档的查询来检查"indexA“是否存在。如果查询没有返回任何点击，我们假设"indexA“不存在，并创建索引(新安装)。问题是，当服务器重新启动时，我们的应用程序启动速度比ElasticSearch快，而且我们得到两个重复的"indexA“，因为在ElasticSearch启动时，在"indexA”中搜索加号失败。(我想索引还没有准备好)
有一种方法： --这是否保证返回"indexA“的"true”，即使ES正在启动，索引还没有准备好？
或者我应
浏览 1提问于2015-08-25得票数 5
回答已采纳
在Elasticsearch中使用热/温架构，在节点上使用索引模式或别名对多个索引进行搜索比使用简单的体系结构更有效吗？
我的意思是，热节点是查询中的一个限制因素，还是热节点提高了性能？
浏览 7提问于2020-06-03得票数 1
回答已采纳
2回答
我计划在我的所有查询中使用包含多个术语的Terms Query (取决于情况，最多为40-50k术语)。
这些术语将使用解释的查找从另一个索引中获取。Elasticsearch从内部获取它们，因此至少它们不会通过连接，但是查询本身看起来相当繁重。
我想知道查询性能是否正常。无论如何，我计划做一个压力测试，但不确定这是否会升级。有人有这类查询的经验，或者知道Elasticsearch如何在内部处理这些查询？
谢谢!
浏览 4提问于2017-03-13得票数 5
回答已采纳
我在我的一个Rails项目中使用Elasticsearch - Bonsai。所以，事情进展得非常顺利。但是，当我们向最终用户和用户发布这个应用程序的时候，我们注意到一个elasticsearch查询需要5-7秒的响应时间(对我们来说非常糟糕) --尽管我们已经安装了8-2xWebdynos。
因此，我们决定将Bonsai插件升级到Bonsai 10，并添加NewRelic外接程序(以跟踪单个查询响应所需的时间)。
以下是我们的环境设置：
Ruby: 2.2.4
Rails: 4.2.0
elasticsearch: 1.0.15
elasticsearch-model: 0.1.8
因此，我
浏览 5提问于2016-03-05得票数 3
我正在寻找一种存储密码查询的方法，当添加节点和关系时，当它与所述查询匹配时会被通知？现在可以这样做吗？类似于ElasticSearch渗滤器的东西会很棒。
浏览 1提问于2014-12-10得票数 8
回答已采纳
我已经启动了elasticsearch.bat，并使用Nest完成了第一个索引。
ElasticClient.Index查询
然后，我进行了第一个查询
var results = ElasticClient.Search<Product>(body =>
body.Query(query =>
query.QueryString(qs => qs.Query(key))));
这就是我所做的一切。后来，我使用elasticsearch.bat重新启动了elasticsearch控制台，现在它一直给我提供错误消息NoShardAvailableE
浏览 5提问于2015-08-14得票数 0
回答已采纳
我想从Java管理elasticsearch的启动和停止。有什么简单/好的方法可以做到这一点吗？
我们正在尝试在我们的产品中部署ElasticSearch，我们希望在我们自己的产品中维护客户机器上的ElasticSearch实例，而现在一切都依赖于从es.bat或其他系统启动的ElasticSearch实例。
顺便说一句，有没有人可以给我一个例子，说明如何围绕ElasticSearch的Jest API模拟测试一些代码，这样我就可以在不需要启动ElasticSearch实例的情况下对调用ElasticSearch的东西进行单元测试？
浏览 1提问于2013-07-06得票数 8
回答已采纳
我在应用程序中使用单个传输客户端实例查询elasticsearch以查找多个并行请求。
对于并行执行，我得到了以下异常。如何克服这个问题。
org.elasticsearch.common.util.concurrent.EsRejectedExecutionException: rejected execution (queue capacity 1000) on org.elasticsearch.search.action.SearchServiceTransportAction$23@5f804c60
at org.elasticsearch.common.util.concu
浏览 5提问于2015-01-06得票数 57
回答已采纳
我们希望在我们的项目中将elasticsearch版本从5.6升级到7.9。
我必须将我们的索引和文档迁移到新版本，但我不能使用重新索引，因此我需要将高级客户端连接到elasticsearch 7，并使用http request for elasticsearch 5。
对于迁移，我使用match_all查询获得部分文档，并从旧版本滚动，并在新的elasticsearch中使用批量请求对它们进行索引。
我们的旧版本elasticsearch有3个节点，我的问题是我必须分别向所有节点发送请求并处理文档，或者如果我将match_all查询搜索发送到一个节点，它将由elsaticsearch来处理(
浏览 6提问于2020-10-21得票数 0
回答已采纳
我每30分钟查询一次Elasticsearch，查找过去30分钟收集的一些事件。我期待着从6到8的结果。但是Elasticsearch不时地返回0，这是一个错误的查询结果。(我看到在基巴纳发生的事件，每30分钟没有偏离6-8信息的范围)。
查询正确运行了几个月，没有错误的结果，并在1周前开始返回不正确的结果。
我正在使用Elasticsearch版本的7.3.1。
到目前为止我所研究的
在启动时是否有任何弹性搜索升级/补丁?服务提供商告诉我没有。
在Elasticsearch的使用(摄入/查询)上有增加吗？--我认为与上个月的平均值没有任何偏差。
是群集的绿色状态？是的，集群处于绿色健康状态。
浏览 0提问于2020-12-24得票数 0
我有3个不同的Elasticsearch容器(我将在下一个命令run -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" docker.elastic.co/elasticsearch/elasticsearch:7.9.2中部署它们)
我想将它们作为3个集群使用，每个集群中有一个节点。之后，我将其中的两个定义为一个集群的远程集群(端口9200是“主”，9201 9202是远程的)。为了定义它，我使用：
cluster:
remote:
cluster_one:
s
浏览 5提问于2020-10-15得票数 2
回答已采纳
正如Elasticsearch的正式文档中提到的，使用file realm定义Elasticsearch中的所有角色并不是首选的方法：
"Please note however, that the roles.yml file is provided as a minimal administrative function and is not intended to cover and be used to define roles for all use cases."
原因何在？有谁能为所有角色和用户使用Elasticsearch file realm而不是使用它的na
浏览 3提问于2022-07-19得票数 1
在CLI中，我移动到hadoop目录(在EMR中)并下载了ojdbc.jar文件。我试着使用下面的shell命令连接Oracle DB：
pyspark \
--jars "/home/hadoop/ojdbc6.jar" \
--master yarn-client \
--num-executors 5 \
--driver-memory 14g \
--executor-memory 14g \
df = spark.read \
.format("jdbc") \
.option("url", &
浏览 1提问于2020-08-27得票数 1
回答已采纳
因此，我在一台服务器上运行了一个相当简单的Node.js应用程序，使用mongoDB作为主数据库，使用elasticsearch作为“复制集”，只在ES中索引与搜索相关的字段。我需要升级，因为旧版本与以下划线开头的字段冲突(例如。"_id")。
有没有一种方法可以在没有停机的情况下升级elasticsearch --而不掉回mongoDB呢？另外，在这个场景中备份elasticsearch的正确方法是什么？如果出现问题，恢复备份的步骤是什么？
TLDR:在这些版本之间备份和升级的正确方法是什么？
浏览 2提问于2015-10-20得票数 0
回答已采纳
我有两个two服务器，每个都有自己的Elasticsearch安装。这两个have服务器在其D:盘上都有一个共享文件夹。
我想使用相同的数据文件夹，这样我就有一组索引，并且每个elasticsearch安装都使用这些相同的索引，而不是每台服务器上有两组索引。
因此，我更改了两个elasticsearch.yml文件中的'path.data‘位置，使其指向相同的共享文件夹。
问题是，只有一台when服务器能够检索查询数据，另一台服务器在运行搜索查询时什么也不返回。
我是否缺少配置设置？
浏览 20提问于2017-08-23得票数 0
2回答
我们有多个数据库，我们可以查询和生成报告。由于我们必须创建复杂的查询和大量的连接等，如果我们使用Cassandra、Hadoop或Elasticsearch来加载数据(加载数据或增量更新的日常作业)并查询所有任务，这是不是一个好主意。
哪个是卡桑德拉、Hadoop、Elasticsearch或MongoDB的首选？
我们还希望为统一数据库上的报告和分析构建一个Web UI。
浏览 0提问于2013-04-30得票数 0
1回答
优化弹力搜索/ JVM
、、、、
我有一个机密网站。为此，我在同一个ubuntu14.04专用服务器上使用elasticsearch、postgres和rails，它有256 40的RAM和20个内核、40个线程。
我在elasticsearch上有10个索引，每个索引都有默认的碎片数(5)。根据不同的指数，他们有1000到40万的分类。大约每分钟5000次请求，2/3发出弹性搜索请求。
根据htop，jvm使用了大约500%的CPU --我尝试了不同的选项，我减少了每个索引的碎片数，我还试图按以下方式更改JAVA_OPTS
#JAVA_OPTS="$JAVA_OPTS -XX:+UseParNewGC"
#J
浏览 2提问于2015-01-28得票数 0
我有一个两个节点的ElasticSearch2.2.0集群，每个节点位于不同的物理框上。
现在我需要安装Delete的查询插件。我应该在每台机器上安装插件吗？
谢谢您的意见！
浏览 4提问于2016-03-02得票数 2
回答已采纳
如果我有3个数据节点，并执行一个带有许多聚合的查询，那么这个搜索是分布在所有集群数据节点上的吗？
或者Elasticsearch选择一个节点来查询和聚合数据？充当负载均衡器，而不是像“分布式映射/减少”那样
浏览 8提问于2018-08-02得票数 1
回答已采纳
1回答
这是我的连接文件
this IServiceCollection services, IConfiguration configuration)
{
var EsNode = configuration["elasticsearch:AcqDataUrl"];
var NCTNode = configuration["elasticsearch:NCTDataUrl"];
var nodes = new Uri[]
{
浏览 3提问于2020-09-17得票数 0
有人能告诉我elasticsearch客户机2.4.x是否向后兼容elasticsearch服务器2.3.1吗？
我无法在elasticsearch文档中找到这些信息。
浏览 1提问于2018-02-28得票数 0
回答已采纳
我通过使用python中的elasticsearch-hadoop连接器(导入吡火花)从Elasticsearch加载数据来创建一个Spark，如下所示：
es_cluster_read_conf = {
"es.nodes" : "XXX",
"es.port" : "XXX",
"es.resource" : "XXX"
}
es_cluster_rdd = sc.newAPIHadoopRDD(
inputFormatClass="org.el
浏览 0提问于2016-07-29得票数 1
回答已采纳
1回答
在Elasticsearch中，是否建议以专用的方式接收节点？我计划在k8s集群上运行Elasticsearch，并允许在具有其他java服务荚的工作节点上调度吞食荚。这是很好的生产装置吗？有多少内存，cpu应该保持多少摄取节点？
浏览 2提问于2020-05-29得票数 1
回答已采纳
1回答
我正在尝试对亚马逊产品数据执行基于内容的推荐，这些数据存储在我的名为‘亚马逊产品’的ElasticSearch索引中。
我通过在ES的python客户端中使用MLT query，但在尝试它时，我没有得到任何响应。
以下是我的代码：
os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages org.elasticsearch:elasticsearch-hadoop:7.7.1 pyspark-shell'
from elasticsearch import Elasticsearch
es = Elasticsearch(
浏览 7提问于2021-04-05得票数 0
我设置了一个elk堆栈来在本地使用日志文件；现在我正在尝试添加filebeat，它将输出到logstash进行过滤，然后再索引到elasticsearch中。下面是我的配置filebeat.yml：
prospectors:
# Each - is a prospector. Below are the prospector specific configurations
-
paths:
- /var/samplelogs/wwwlogs/framework*.log
input_type: log
document_type: framework
logstash:
浏览 4提问于2016-03-10得票数 0
1回答
感兴趣的elasticsearch和工作与txt文件，而不是json。elasticsearch能支持纯文本文件吗？如果有，有没有什么java API，我可以使用(我用postman对JSON文档进行了crud操作测试，运行良好)，谢谢你的帮助。
浏览 16提问于2019-05-21得票数 1
我是elasticsearch的新手，希望有人能帮我澄清几个概念
我正在设计一个具有以下要求的小型集群
当重新启动一台机器时，一切都应该正常工作(例如: OS更新)。
单次磁盘故障是可以的。
重索引不应影响查询性能。
我应该有多少主节点、数据节点、吞食节点？还是我需要两个集群？
索引工作负载是纯索引结构化文本文档，没有处理/规则.我需要一个吞食的节点吗？
另外，每个节点是否都有所有数据的完整副本？还是只有集群才有完整的副本？
浏览 0提问于2018-08-18得票数 2
回答已采纳
2回答
关于ElasticSearch碎片有两个最佳实践：
每个节点的最优碎片数为1。
碎片的大小最多应该是50 GB。
就我而言，它们有些争议。更具体地说，假设索引大小为2TB，并且有10个节点。我应该配置多少个碎片：
选项1: 10片，每个200 10
或
选项2: 40个碎片，每个50 40
查询延迟性能的更好选择是哪一种？
浏览 0提问于2018-06-29得票数 1
回答已采纳
我们正在AWS上运行elasticsearch，它目前支持elasticsearch 6.3作为最新版本。
我们有一个业务案例，需要更新索引中的所有文档，并每天删除一个嵌套对象。还有elasticsearch的，它将解决我们的目的。
但是在我们的java应用程序中，我们使用的是Java高级rest客户端。支持由query进行的更新。现在，如果我们将rest客户端升级到6.5，我们也需要在pom中升级elasticsearch版本。否则它们就不兼容了。
<dependency>
<groupId>org.elasticsearch.client&l
浏览 2提问于2018-11-30得票数 6
elasticsearch能很好地处理并发搜索/聚合吗？(例如，1000人同时发出相同/不同的查询)
请注意，我说的不是并发更新，而是search/agg。
像oracle/mysql这样的数据库都在讨论文档中的并发性。没有发现elasticsearch在谈论这个。这是否意味着并发性对elasticsearch的数据结构和体系结构没有问题？
我知道过滤器的缓存是使并发查询更容易的一件好事。还要别的吗？
浏览 12提问于2016-04-21得票数 0
回答已采纳
我有一个web应用程序，我正在尝试用Kubernetes进行部署。它工作正常，但是当我尝试添加资源限制时，ElasticSearch将不会部署。
elasticsearch-部署.：
apiVersion: v1
kind: Service
metadata:
name: elasticsearch-service
spec:
type: NodePort
selector:
app: elasticsearch
ports:
- port: 9200
targetPort: 9200
name: serving
- port: 9300
浏览 2提问于2022-03-23得票数 0
回答已采纳
1回答
我正在创建一个Elasticsearch集群，重点将放在search.The上，搜索的初始吞吐量预计为每秒6000次请求。目前，我有以下配置:-
主节点-7个节点(8 CPU，16 GB RAM)
数据节点-12个节点( 16 CPU，32 GB RAM)
协调器节点-4个节点( 16 CPU，32 GB RAM)
使用此设置，当我尝试使用Jmeter和sample查询进行负载测试时，可以达到每秒58 reuqest /秒。目标是avg响应时间不超过1.5秒。就查询而言，该查询包含多层查询，函数评分用于提供自定义评分。我有将近20个索引来执行搜索，每个索引中的数据并不是很大
浏览 0提问于2019-07-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
