在ElasticSearch中使用Java API时，从JSON DSL构造QueryBuilder？
在ElasticSearch中使用Java API时，可以通过以下步骤从JSON DSL构造QueryBuilder：
- 导入必要的ElasticSearch Java客户端库，例如Maven依赖：
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.15.0</version>
</dependency>- 创建ElasticSearch客户端连接：
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http")));- 构建JSON DSL查询语句：
String jsonString = "{ \"query\": { \"match\": { \"field\": \"value\" } } }";- 使用QueryBuilder类从JSON DSL构造查询：
QueryBuilder queryBuilder = QueryBuilders.wrapperQuery(jsonString);- 执行查询操作：
SearchRequest searchRequest = new SearchRequest("index_name");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder().query(queryBuilder);
searchRequest.source(sourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);在上述代码中，我们首先创建了一个ElasticSearch的高级客户端连接，然后构建了一个包含查询条件的JSON DSL语句。接下来，我们使用QueryBuilder类的wrapperQuery方法将JSON DSL转换为QueryBuilder对象。最后，我们创建一个SearchRequest并设置查询条件，然后使用客户端执行查询操作。
ElasticSearch是一个开源的分布式搜索和分析引擎，它提供了强大的全文搜索、实时数据分析和可扩展性。它广泛应用于日志分析、电子商务、内容搜索等场景。
腾讯云提供了Elasticsearch Service（ES）产品，它是基于Elasticsearch构建的托管式云服务，提供了高可用、高性能的Elasticsearch集群。您可以通过腾讯云ES产品进行数据存储、搜索和分析等操作。了解更多关于腾讯云ES产品的信息，请访问：腾讯云Elasticsearch Service。
相关·内容
在Spring项目中，我使用ElasticSearch作为搜索服务，使用Transport与ES通信。
我想知道是否有一种方法可以从JSON构建QueryBuilder。例如，将这个bool查询DSL转换为QueryBuilder。
{
"query" : {
"bool" : {
"must" : { "match" : {"content" : "quick"},
"should": { "match
浏览 4提问于2014-09-16得票数 23
我有一个JSON格式的Elastic Search查询(下面提到)，我正在从数据库中读取该查询，我必须在Java spring程序中更新该查询。如何将JSON query对象转换为QueryBuilder对象，以便在执行之前可以对其进行操作以获得匹配结果？ {
"query": {
"bool": {
"must_not": [
{
"match": {
"after.values": {
"q
浏览 24提问于2021-04-12得票数 0
回答已采纳
我正在尝试迁移到elasticsearch-dsl，并将旧的类似dict/json的查询移植到elasticsearch-dsl语法中。
from_dict方法似乎可以完成这项工作，但我希望看到新的语法。
我没有看到任何可以打印它的from_dict属性。我希望从dict查询中获得(参见)如下所示的输出
Search(using=client, index="my-index") \
.filter("term", category="search") \
.query("match", title="python"
浏览 1提问于2017-10-30得票数 1
我使用elasticsearch-java客户端版本7.17，服务器为7.10。我想使用ElasticsearchClient，但似乎服务器版本不支持它。
因此，我决定使用RestClient和json对象。我将SearchRequest映射为使用以下代码进行请求：
StringWriter writer = new StringWriter();
JsonGenerator generator = JacksonJsonProvider.provider().createGenerator(writer);
searchRequest.serialize(generator, new Jac
浏览 8提问于2022-05-28得票数 0
我正在尝试通过java api查询elasticsearch，以获得以下elasticsearch查询
get my_index12/_search {
"query" : {
"bool": {
"must": [
{
"match": {
"code": {
浏览 3提问于2018-06-14得票数 0
1回答
我想在我的Elasticsearch Java客户机中重用一个QueryBuilder，并在每次使用它时简单地替换一个新的ID值。
QueryBuilder idQuery = QueryBuilders.boolQuery()
.must(QueryBuilders.matchQuery("id", "<ID PLACEHOLDER>"));
如何在每次运行查询时替换一个新的Id？也就是说，每次运行查询时，我都需要以编程方式更改<ID PLACEHOLDER>。
浏览 0提问于2015-12-10得票数 0
这是我对Elasticsearch的查询，
GET index101/_search
{
"query": {
"function_score": {
"boost_mode": "replace",
"query": {
"constant_score": {
"filter": {
"terms": {
"fields":
浏览 2提问于2022-07-28得票数 2
回答已采纳
我使用的是0.90.5版本的ElasticSearch。我试图限制使用QueryStringQuery解析的查询，并使用类似于这样的GeoShapeQuery：
public SearchResponse search(final String queryString, final Rectangle bbox){
final QueryBuilder queryA = QueryBuilders.queryString(queryString);
final QueryBuilder queryB = QueryBuilders.geoShapeQuery(GEO_FIELD
浏览 2提问于2013-11-19得票数 0
回答已采纳
我使用这段代码从elasticSearch获取数据：-
QueryBuilder qb;
if (query == null || query.trim().length() <= 0) {
qb = QueryBuilders.matchAllQuery();
} else {
qb = QueryBuilders.queryString(query.replaceAll(" ", " OR ").replaceAll(",", " A
浏览 3提问于2015-07-03得票数 1
回答已采纳
我在理解如何在java中创建json对象时遇到了一个问题。我必须通过java从elasticsearch获取某些数据，我也有一个功能强大的json，但我不知道如何使这种json具有可用的功能。
使用SearchResponse类及其函数可以做到这一点吗？QueryBuilder能帮上忙吗？
这与chrome中的Sense插件一起工作：
GET _search
{
"query": {
"constant_score": {
"filter": {
"and": {
浏览 1提问于2016-05-01得票数 0
使用Elasticsearch 1.7.0，我想对文档的文本字段进行查询。我需要所有的文件：
部分匹配(所有单词都需要有同义词和模糊)
匹配模糊(所有单词都需要存在+模糊+语音)
匹配相关(50%的单词需要找到)
我用3个Elasticsearch请求编写了一个Java程序，但是这些查询太长了，所以我尝试使用一个查询来实现这些功能：
{
"query":
{"bool": {
"should": [
{
"function_score": {
浏览 2提问于2015-10-08得票数 0
我试图定义一个DSL来构建特定于域的查询。DSL是使用FactoryBuilderSupport实现的，因此如下所示(缩写)：
class QueryBuilder extends FactoryBuilderSupport {
{
registerFactory('query', new QueryFactory())
registerFactory('match', new QueryMatchFactory())
registerFactory('obj', new ObjFactory())
}
浏览 0提问于2014-07-23得票数 2
回答已采纳
1回答
我已经实现了弹性搜索- Java来搜索数据的基础上的距离。
QueryBuilder geoQuery = QueryBuilders.geoDistanceQuery("article_location.location").point(lat , lon).distance(5 , DistanceUnit.KILOMETERS);
QueryBuilders.boolQuery().filter(geoQuery);
但是，我想从输入lat/lon获得每个结果的距离。有什么具体的办法吗？
我在弹性DSL中看到，我们可以通过script_fields来实现它，但是不知道如
浏览 1提问于2021-12-23得票数 0
回答已采纳
如何在elasticsearch中定义GeoPointField()。当我试图保存实例时，它会显示一个序列化错误。我使用的是库"django_elasticsearch_dsl代码：
from django_elasticsearch_dsl.fields import GeoPointField
geolocation = GeoPointField()
当我试图保存数据时
user = GutitUser.objects.get(phone_number=phone_number)
lat, lon = get_lat_long()
user.geolocation.lat
浏览 1提问于2018-05-31得票数 0
回答已采纳
我必须对字段进行编程配置，以便使用Hibernate搜索进行索引。
在下面的场景中，使用indexEmbedded()会导致“字段未找到错误”。
@Entity
public class AT {
@ManyToOne(fetch = FetchType.EAGER)
@JoinColumn(name = "ARRM_IDE", nullable = false)
private A arr;
private Date dateType;
(and other fields)
}
@Entity
public class A {
浏览 1提问于2016-06-10得票数 0
回答已采纳
社区:最近，当我在一个项目中使用Elasticsearch2.3.1工作时，我尝试使用.jar(弹性搜索.2.3.1.jar)文件中的java编译对ES进行一个简单的查询，然后添加到我的项目中，但是当我接下来编写代码时：
QueryBuilder qb = simpleQueryStringQuery("+kimchy -elasticsearch");
IDE没有修改"simpleQueryStringQuery("+kimchy -elasticsearch")“的指令，但在所有的例子中，在互联网和ES官方网站中，都以这种形式出现。做错什么了？提前
浏览 3提问于2016-06-02得票数 0
回答已采纳
1回答
在弹性搜索中搜索数组时使对象命中
、、、、
我试图从存储在elasticsearch中的JSON数组中获取一个对象。布局如下：
[
object{}
object{}
object{}
]
当我搜索并点击其中一个对象时，我需要做什么，以获得它匹配的特定对象。目前，使用我正在搜索的java API：
QueryBuilder qb = QueryBuilders.boolQuery()
.should(QueryBuilders.matchQuery("text", "pottery").boost(5)
.minimumShouldMatch("1"));
浏览 4提问于2015-09-09得票数 0
回答已采纳
我有三份文件，
{
"category":[{"id":"1"},{"id":"2"},{"id":"3"}]
}
{
"category":[{"id":"1"},{"id":"4"}]
}
{
"category":[]
}
我如何在mysql这样的(2,3)中找到有category.id的文档，以及我需要在java api querybuilder中使用哪种类型的DSL查询
浏览 0提问于2016-09-29得票数 1
我想要创建这个例子
GET /my_store/products/_search
{
"query" : {
"filtered" : {
"query" : {
"match_all" : {}
},
"filter" : {
"term" : {
"price" : 20
浏览 3提问于2015-11-18得票数 5
回答已采纳
之前我使用的是elasticsearch 2.2，现在我已经升级到elasticsearch 5.1，下面是获取传输客户端对象的代码，但遇到了一个问题。
Settings settings = Settings.builder().put("cluster.name",
elasticConfiguration.getProperty("cluster.name", "elasticsearch")).
put("client.transport.sniff", t
浏览 10提问于2017-03-15得票数 1
回答已采纳
我试图在python中使用elasticsearch dsl库，但我似乎得到了某种截断的结果/元数据，而不是文档/响应对象。已清理的查询如下：
from elasticsearch_dsl import Search, Q, F
from elasticsearch_dsl.query import MultiMatch
from elasticsearch import Elasticsearch
import requests
import json
client = Elasticsearch("")
s = Search().using(client).quer
浏览 2提问于2016-02-09得票数 1
我使用django库在elasticsearch中定义映射并索引elasticsearch-dsl模型对象。但是，对于初始索引，我希望对所有模型使用json数据。是否有一种方法可以直接从json或从DocType dict实例化Python子类对象
浏览 12提问于2017-07-25得票数 1
回答已采纳
是否有一种方法可以编程地使通过客户端(当然，假设分析器在双方都可用)由Elasticsearch服务器实例来索引给定的字段？
例如，使用映射(如：
{
"mappings": {
"article": {
"properties": {
"text": {
"type": "string",
"index": "ana
浏览 2提问于2016-05-11得票数 0
回答已采纳
我想使用elasticsearch进行一个新的项目，从我的研究中可以找到3种可行的解决方案：
不要使用包装器直接与elasticsearch通信
使用elasticsearch-py
使用elasticsearch-dsl-py
我喜欢解决方案1，因为它不需要依赖，我可以专注于学习本机语法/api，而不是2或3中的包装器。是否有令人信服的理由使用2或3而不是1？
更新
最后我使用了elasticsearch-py，因为它提供了各种好处，比如连接池和持久性。我发现elasticsearch-dsl-py太抽象和冗长
浏览 3提问于2015-11-05得票数 5
回答已采纳
我正处于从6升级到7的过程中。
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-elasticsearch</artifactId>
<version>4.4.2</version>
</dependency>
通过这次升级，我注意到搜索API被从elasticsearch存储库中删除。
我们在应用程
浏览 2提问于2022-09-21得票数 0
我正在跟踪以索引django-模型中的数据。我将我的documents.py文件定义为:->
from django_elasticsearch_dsl import Document , fields
from django_elasticsearch_dsl.registries import registry
from abc.models import *
from elasticsearch_dsl import connections, field, analyzer
connections.create_connection(hosts=['localhost
浏览 1提问于2019-08-25得票数 6
回答已采纳
我在db中有如下结构的元素：
{
"id": 324214,
"modDate": "2014-10-01",
"otherInfo": {
..
..
}
}
假设我有一个配对列表id，modDate
Map<String, String> idAndModDate
包含f.e (324214，“324214-10-01”)，(3254757，“201510-04”)..
现在，我想使用Java Api Elasticsearch QueryBu
浏览 1提问于2015-07-09得票数 0
我读了Elasticsearch文档，我知道Elasticsearch的API和查询DSL。我还可以找到关于如何从Elasticsearch获取查询结果的文档，但是如何在任何内部查询上有效地计算聚合呢？
浏览 3提问于2016-06-30得票数 2
如何使用多个包含语句进行OR查询(使用django-elasticsearch-dsl-drf)？文字查询:搜索标题包含"hello“或描述包含"world”的对象 我在文档中找不到它：https://django-elasticsearch-dsl-drf.readthedocs.io/en/0.3.12/advanced_usage_examples.html#usage-example
浏览 17提问于2020-10-26得票数 0
回答已采纳
我有一个elasticsearch范围查询，我想将其转换为：
Elasticsearch Python API
{"range":
{"@timestamp":
{"gte": 1570258800000,
"lte": 1571036400000,
"format": "epoch_millis"
}
}
}
Elasticsearch-DSL-Py查询？
from elasticsearch impo
浏览 31提问于2019-10-18得票数 1
回答已采纳
我在我的项目中使用了Elastic，这里出现了一个奇怪的服务器错误。由于某种原因，“接受”标头在这里不能工作，而Rest没有问题。我是否也应该设置任何选项，或者替代现有的选项？
这是我的代码(我正在使用Kotlin)：
fun search(
queryBuilder: QueryBuilder,
//index: String,
limit: Int? = null,
offset: Int? = null,
options: RequestOptions = RequestOptions
.DEFAULT
.toBui
浏览 4提问于2021-11-08得票数 1
搜索和搜索有什么区别？
>>> Search
<class 'elasticsearch_dsl.search.Search'>
>>> search
<module 'elasticsearch_dsl.search' from '/usr/local/lib/python2.7/dist-packages/elasticsearch_dsl/search.pyc'>
从Search()中我得到了elasticsearch_dsl.search.Search对象。从Elsasticse
浏览 31提问于2017-06-29得票数 0
回答已采纳
我正在编写一个API，当我输入某项内容时，它会自动提示，但是它正在工作，它不需要查询就返回结果，有时甚至是重复的值。
这是我的API视图：
from django_elasticsearch_dsl_drf.filter_backends import (
SuggesterFilterBackend
)
from django_elasticsearch_dsl_drf.viewsets import DocumentViewSet
from django_elasticsearch_dsl_drf.constants import (
SUGGESTER_COMPLET
浏览 3提问于2022-06-25得票数 0
我正在尝试使用django-elasticsearch-dsl包将ElasticSearch与我的Django项目集成在一起，我得到了这个错误：
>> $ curl -X GET http://localhost:9200
curl: (7) Failed to connect to localhost port 9200: Connection refused
我使用以下命令下载了django-elasticsearch-dsl：
pip install https://github.com/sabricot/django-elasticsearch-dsl/archive/6.
浏览 0提问于2019-06-13得票数 2
我试图更新现有的elasticsearch数据管道，并希望更全面地使用elasticsearch-dsl。在当前过程中，我们将文档创建为json对象，然后使用请求将对象放到相关的elasticsearch索引中。
现在我想使用elasticsearch方法，但是当我的对象或文档被构造为json时，我很难理解如何做到这一点。
目前的程序：
//import_script.py
index = 'objects'
doc = {"title": "A title", "Description": "Description&#
浏览 2提问于2020-02-12得票数 0
回答已采纳
我使用Java API查询ElasticSearch，得到了很多重复的值。我只想从查询中获得唯一值(distinct值)。我们如何从查询构建器中获取不同的值。
请找到我下面的java代码，它给出了重复的值。
QueryBuilder qb2=null;
List<Integer> link_id_array=new ArrayList<Integer>();
for(Replacement link_id:linkIDList) {
link_id_array.add(link_id.getLink_id());
}
qb2 = QueryBuilders.b
浏览 1提问于2018-07-02得票数 0
我有一堆merged_file文件(100)，它们被命名为JSON 1.json、json 2.json等等。
如何使用python(elasticsearch_dsl)将所有这些文件索引到elasticsearch中？
我正在使用这段代码，但它似乎不起作用：
from elasticsearch_dsl import Elasticsearch
import json
import os
import sys
es = Elasticsearch()
json_docs =[]
directory = sys.argv[1]
for filename in os.listdir(di
浏览 0提问于2017-05-15得票数 5
回答已采纳
我正在构建一个Java应用程序，它可以搜索来自Elasticsearch的数据(数据从kafka到logstash，然后是elasticsearch，格式为json格式)。当我使用QueryBuilders.queryStringQuery(reqId)时，我可以得到所有的结果，没有问题，但是当我使用QueryBuilders.termQuery("routingRequestID", reqId);时，即使ES数据中存在reqId，也会得到0次点击。
RestHighLevelClient client = new RestHighLevelClient(
浏览 15提问于2020-04-03得票数 0
回答已采纳
我想使用JAVA API构建弹性搜索查询。我想知道如何在elasticsearch java程序中使用Lucene分析器。我已经检查了QueryBuilders，并尝试直接使用分析器，如下所示。
QueryBuilder builder = QueryBuilders.matchQuery(searchString, fields).analyzer("porterstem");
但是，事实证明这是错误的。如果有人试过，你能给我一些信息吗？
浏览 4提问于2014-03-16得票数 0
1回答
我有个问题。在我的应用程序中，我使用ElasticSearch。我将JSON对象发布到我的ElasticSearch服务器上。该JSON对象包含DSL查询。所以，我需要做的是查询一些数据的特定索引。
这是一个查询：
{
"query":{
"indices":{
"indices":[
"index-1"
],
"query":{
"bool":{
浏览 5提问于2015-05-28得票数 2
回答已采纳
ElasticSearch给了我以下例外：
WARNING: request [POST http://localhost:9200/domain.dog/_search?size=10000&from=0] returned 1 warnings: [299 Elasticsearch-7.11.2-3e5a16cfec50876d20ea77b075070932c6464c7d "[types removal] Type queries are deprecated, prefer to filter on a field instead."]
org.hiber
浏览 0提问于2021-03-19得票数 0
我使用elasticsearch_dsl对elasticsearch进行查询和搜索。
我正在查询的字段之一是地址，它的结构如下所示：
address.first_line
address.second_line
address.city
adress.code
返回的文档将其保存在JSON结构中，因此地址保存在dict中，每个子字段都有一个字段。
我想把这个放进(熊猫)的数据里，这样每个子字段就有一栏的地址。
直接将地址放入dataframe给出了一列地址分块，并且迭代行来手动解压缩(json.normalize())每个地址dict需要很长的时间(4天，大约200,000行)。
从文档中，我
浏览 2提问于2020-01-06得票数 0
回答已采纳
我编写了以下类，用于在ElasticSearch中索引文档：
import java.net.InetAddress
import com.typesafe.config.ConfigFactory
import org.elasticsearch.client.transport.TransportClient
import org.elasticsearch.common.settings.Settings
import org.elasticsearch.common.transport.InetSocketTransportAddress
import play.api.libs.js
浏览 5提问于2016-07-12得票数 1
我正在尝试检索数据表单ES查询，我对如何将检索到的数据的每一击转换为Java对象感到困惑。到目前为止，我可以使用Gson实现JSON格式的每个命中，但我认为从hit转换到JSON，然后转换到Java对象是无用的。
我目前的代码是：
TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
浏览 3提问于2017-06-08得票数 2
回答已采纳
我正在尝试将我的elasticsearch客户端api版本从1.4.2更新到2.0.0。我使用的是java 1.8 .I，使用以下代码：
XContentBuilder builder = XContentFactory.jsonBuilder()
它曾经在1.4.2中起作用，但我在2.0.0中得到了这个异常：
Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.elasticsearch.common.xcontent.json.JsonXContentGenerator
at
浏览 11提问于2015-11-12得票数 2
回答已采纳
我已经构建了Elasticsearch查询(DSL)，如下所示。我想从Java应用程序集成它。当我读到Elastic提供的High和Low Level REST选项时。可以使用高级API构建复杂的查询吗？或者我应该使用低级API并通过Program构建DSL？
GET myindex/_search
{
"query": {
"bool": {
"must": [
{
"nested": {
"path"
浏览 2提问于2018-08-05得票数 0
我正在尝试创建一个小应用程序，它从Elasticsearch (在AWS托管的Elasticsearch服务上)索引的数据中显示一些简单的可视化。
因为，据我所知，AWS在ES服务上提供的访问控制的程度是基于允许特定的HTTP谓词(GET、POST等)来简化我的生活和ES管理员的，所以我授予这个应用程序“只读”权限，因此只能获取和领导。
但是，对于它的搜索API，ES公开了一个使用查询字符串参数的GET端点，以及一个使用基于JSON的“查询DSL”的POST端点。在我在网上和书中看到的所有例子中，这个DSL似乎都是首选的方法。
考虑到整个文档中查询DSL的优势，我想知道：
查询DSL是否公
浏览 4提问于2020-04-09得票数 1
回答已采纳
每当我试图保存一个包含嵌套字段的对象时，我都会得到一个类型错误。
TypeError: isinstance() arg 2 must be a type or tuple of types
我有以下文档类：
class CreationIndex(InnerDoc):
created_by = Keyword()
created_date = Date()
class UpdationIndex(InnerDoc):
updated_by = Keyword()
updated_date = Date()
class IndustryIndex(Doc
浏览 14提问于2018-04-06得票数 0
我有一个elasticsearch索引，其用户的字段类似于.."name“："kai”"age“："23”"location“：”印度德里“"tag"："search"，"nosql”等。
我想在用户的所有字段中查询多个字符串(例如，"nosql"，“德里”)。可以使用Java API吗？
以下是我正在使用的代码示例。(但这与问题无关)我只是想知道我现在正在使用的对象。
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery()
浏览 2提问于2014-12-02得票数 6
我在弹簧引导REST中进行弹性搜索。在使用ElasticSearch Java执行搜索查询时，我将获得以下异常。
org.elasticsearch.ElasticsearchStatusException: Elasticsearch exception [type=search_phase_execution_exception, reason=all shards failed]
以下是我的代码：
String query = path + "\"" + path + "\"";
SearchRequest
浏览 7提问于2022-05-24得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
