2

我正在尝试使用 elastic4s 库注册过滤器查询。经过大量研究，我发现我需要使用类似的东西：

val myQuery = """ { "query" : { "match" : { "foo" : "bar" } } } """

esClient.execute( register id 12345 into "baz" query myQuery )

好像我正在这样做：

curl -XPUT 'localhost:9200/baz/.percolator/12345' -d '{
    "query" : {
        "match" : {
            "foo" : "bar"
        }
    }
}'

但是每当我尝试运行 esClient.execute 时，我最终都会遇到一些解析错误，但它通过 curl 可以正常工作：

[info]   org.elasticsearch.index.percolator.PercolatorException: failed to parse query [987654]
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry.parsePercolatorDocument(PercolatorQueriesRegistry.java:182)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry$RealTimePercolatorOperationListener.preIndex(PercolatorQueriesRegistry.java:301)
[info]   at org.elasticsearch.index.indexing.ShardIndexingService.preIndex(ShardIndexingService.java:146)
[info]   at org.elasticsearch.index.shard.IndexShard.index(IndexShard.java:565)
[info]   at org.elasticsearch.index.engine.Engine$Index.execute(Engine.java:836)
[info]   at org.elasticsearch.action.support.replication.TransportReplicationAction.executeIndexRequestOnPrimary(TransportReplicationAction.java:1073)
[info]   at org.elasticsearch.action.index.TransportIndexAction.shardOperationOnPrimary(TransportIndexAction.java:170)
[info]   at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryPhase.performOnPrimary(TransportReplicationAction.java:579)
[info]   at org.elasticsearch.action.support.replication.TransportReplicationAction$PrimaryPhase$1.doRun(TransportReplicationAction.java:452)
[info]   at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37)
[info]   ...
[info]   Cause: org.elasticsearch.index.query.QueryParsingException: Failed to parse query [{"query":{"match":{"foo":"bar"}}}]
[info]   at org.elasticsearch.index.query.QueryStringQueryParser.parse(QueryStringQueryParser.java:243)
[info]   at org.elasticsearch.index.query.QueryParseContext.parseInnerQuery(QueryParseContext.java:257)
[info]   at org.elasticsearch.index.query.IndexQueryParserService.parseInnerQuery(IndexQueryParserService.java:244)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry.parseQuery(PercolatorQueriesRegistry.java:208)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry.parsePercolatorDocument(PercolatorQueriesRegistry.java:179)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry$RealTimePercolatorOperationListener.preIndex(PercolatorQueriesRegistry.java:301)
[info]   at org.elasticsearch.index.indexing.ShardIndexingService.preIndex(ShardIndexingService.java:146)
[info]   at org.elasticsearch.index.shard.IndexShard.index(IndexShard.java:565)
[info]   at org.elasticsearch.index.engine.Engine$Index.execute(Engine.java:836)
[info]   at org.elasticsearch.action.support.replication.TransportReplicationAction.executeIndexRequestOnPrimary(TransportReplicationAction.java:1073)
[info]   ...
[info]   Cause: org.apache.lucene.queryparser.classic.ParseException: Cannot parse '{"query":{"match":{"foo":"bar"}}}': Encountered " "}" "} "" at line 1, column 30.
[info] Was expecting one of:
[info]     "TO" ...
[info]     <RANGE_QUOTED> ...
[info]     <RANGE_GOOP> ...
[info]   at org.apache.lucene.queryparser.classic.QueryParserBase.parse(QueryParserBase.java:123)
[info]   at org.apache.lucene.queryparser.classic.MapperQueryParser.parse(MapperQueryParser.java:848)
[info]   at org.elasticsearch.index.query.QueryStringQueryParser.parse(QueryStringQueryParser.java:227)
[info]   at org.elasticsearch.index.query.QueryParseContext.parseInnerQuery(QueryParseContext.java:257)
[info]   at org.elasticsearch.index.query.IndexQueryParserService.parseInnerQuery(IndexQueryParserService.java:244)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry.parseQuery(PercolatorQueriesRegistry.java:208)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry.parsePercolatorDocument(PercolatorQueriesRegistry.java:179)
[info]   at org.elasticsearch.index.percolator.PercolatorQueriesRegistry$RealTimePercolatorOperationListener.preIndex(PercolatorQueriesRegistry.java:301)
[info]   at org.elasticsearch.index.indexing.ShardIndexingService.preIndex(ShardIndexingService.java:146)
[info]   at org.elasticsearch.index.shard.IndexShard.index(IndexShard.java:565)
[info]   ...
[info]   Cause: org.apache.lucene.queryparser.classic.ParseException: Encountered " "}" "} "" at line 1, column 30.
[info] Was expecting one of:
[info]     "TO" ...
[info]     <RANGE_QUOTED> ...
[info]     <RANGE_GOOP> ...
[info]   at org.apache.lucene.queryparser.classic.QueryParser.generateParseException(QueryParser.java:698)
[info]   at org.apache.lucene.queryparser.classic.QueryParser.jj_consume_token(QueryParser.java:580)
[info]   at org.apache.lucene.queryparser.classic.QueryParser.Term(QueryParser.java:394)
[info]   at org.apache.lucene.queryparser.classic.QueryParser.Clause(QueryParser.java:247)
[info]   at org.apache.lucene.queryparser.classic.QueryParser.Query(QueryParser.java:171)
[info]   at org.apache.lucene.queryparser.classic.QueryParser.TopLevelQuery(QueryParser.java:160)
[info]   at org.apache.lucene.queryparser.classic.QueryParserBase.parse(QueryParserBase.java:118)
[info]   at org.apache.lucene.queryparser.classic.MapperQueryParser.parse(MapperQueryParser.java:848)
[info]   at org.elasticsearch.index.query.QueryStringQueryParser.parse(QueryStringQueryParser.java:227)
[info]   at org.elasticsearch.index.query.QueryParseContext.parseInnerQuery(QueryParseContext.java:257)
[info]   ...

所以我觉得我需要以不同的方式格式化查询，但它不在文档中，我似乎无法找到任何示例。我尝试了一些其他格式，例如：

val myQuery2 = """ "query" : { "match" : { "foo" : "bar" } } """
val myQuery3 = """ { "match" : { "foo" : "bar" } } """
val myQuery4 = """ "match" : { "foo" : "bar" } """

但是似乎没有什么可以工作，我唯一可以工作的就是这样：

val myQuery5 = "query"

但是有了这个，我无法指定我真正想要匹配的内容。有没有人有这方面的经验，或者有什么想法？

4

1 回答 1

1

该query方法接受一个字符串，但该字符串是一个查询字符串，而不是您尝试过的 json 片段。如果查询字符串格式不合适，则需要使用 elastic4s 查询 dsl 创建查询，例如

termQuery("field", "value")

或者

matchQuery("field", "value")

等等。查询类型很多，可以用布尔查询嵌套。

于 2016-01-03T12:24:10.347 回答