使用 alpakka-elasticsearch 客户端进行弹性搜索多查询
elastic search multi query with alpakka-elasticsearch client
我是 scala 新手,使用 alpakka-elasticsearch 客户端通过弹性搜索执行查询。
单个搜索查询在内部调用 _search url 弹性搜索的以下两种方式下工作正常:
val writeCustomIndex = ElasticsearchSource
.typed[Book](
indexName = "source",
typeName = "_doc",
query = """{"match_all": {}}"""
)
或
val readWithSearchParameters = ElasticsearchSource
.typed[TestDoc](
indexName,
Some(typeName),
searchParams = Map(
"query" -> """ {"match_all": {}} """,
"_source" -> """ ["id", "a", "c"] """
)
我正在寻找的是使用此客户端执行以下多查询(_msearch)。
url - http://localhost:9200/index1/_msearch?
request :
[
{"query" : {"match_all" : {}}, "from" : 0, "size" : 1},
{"index" : "index2"},
{"query" : {"match_all" : {}}, "from" : 0, "size" : 2}
]
弹性客户端来源:https://doc.akka.io/docs/alpakka/current/elasticsearch.html
按照建议尝试了一种方法,我合并了两个来源。
希望,这可能对某人有所帮助!
var elasticRecord: Future[Seq[ElasticRecord]] = ElasticsearchSource
.typed[ElasticRecord](
indexName1,
Some(typeName1),
query1,
settings = ElasticsearchSourceSettings()).map { message =>
message.source
}.merge(ElasticsearchSource
.typed[ElasticRecord](
indexName2,
Some(typeName2),
query1,
settings = ElasticsearchSourceSettings()).map { message =>
message.source
}).runWith(Sink.seq)
我是 scala 新手,使用 alpakka-elasticsearch 客户端通过弹性搜索执行查询。
单个搜索查询在内部调用 _search url 弹性搜索的以下两种方式下工作正常:
val writeCustomIndex = ElasticsearchSource
.typed[Book](
indexName = "source",
typeName = "_doc",
query = """{"match_all": {}}"""
)
或
val readWithSearchParameters = ElasticsearchSource
.typed[TestDoc](
indexName,
Some(typeName),
searchParams = Map(
"query" -> """ {"match_all": {}} """,
"_source" -> """ ["id", "a", "c"] """
)
我正在寻找的是使用此客户端执行以下多查询(_msearch)。
url - http://localhost:9200/index1/_msearch?
request :
[
{"query" : {"match_all" : {}}, "from" : 0, "size" : 1},
{"index" : "index2"},
{"query" : {"match_all" : {}}, "from" : 0, "size" : 2}
]
弹性客户端来源:https://doc.akka.io/docs/alpakka/current/elasticsearch.html
按照建议尝试了一种方法,我合并了两个来源。
希望,这可能对某人有所帮助!
var elasticRecord: Future[Seq[ElasticRecord]] = ElasticsearchSource
.typed[ElasticRecord](
indexName1,
Some(typeName1),
query1,
settings = ElasticsearchSourceSettings()).map { message =>
message.source
}.merge(ElasticsearchSource
.typed[ElasticRecord](
indexName2,
Some(typeName2),
query1,
settings = ElasticsearchSourceSettings()).map { message =>
message.source
}).runWith(Sink.seq)