Как создать запрос API msearch с агрегацией для Elasticsearch

документация описывает способ создания простое тело запроса для запроса API msearch. Но если вы используете агрегации, это больше не работает ни с помощью curl, ни с любой версией библиотеки elasticsearch-py. Github, соответствующий билету. Пример запроса:

{ 
  "query": {
    "filtered": {
    "filter": { "term": {"applicationType":"myapptype"} },
    "query": {"match": {"search_key": "my_key_value"}}
    }
  },
  "aggs": {"client": {"terms": {"field": "client"}}},
  "size": 0
}

Код Python:

es = Elasticsearch()
es.msearch(body=[
   {"index": "index20150315"},
   {"query": {'filtered': {'filter': {'term': {'applicationType': 'myapptype'}}, 'query': {'match': {'search_key': 'my_key_value'}}}}, 'aggs': {'client': {'terms': {'field': 'client'}}}, 'size': 0}

])

Результат выглядит следующим образом:

{u'responses': [{u'error': u'SearchPhaseExecutionException[Failed to execute phase [query], all shards failed; shardFailures {[BRYrrx8dR4i-ukxlXbuNEw][index20150315][1]: RemoteTransportException[[i-1f30c5fb][inet[/10.101.2.234:9300]][search/phase/query]]; nested: SearchParseException[[index20150315][1]: query[filtered(search_key:my_key_value)->cache(applicationType:myapptype)],from[-1],size[-1]: Parse Failure [Failed to parse source [{"query": {"filtered": {"filter": {"term": {"applicationType": "myapptype"}}, "query": {"match": {"search_key": "my_key_value"}}}, "aggs": {"client": {"terms": {"field": "client"}}}, "size": 0}}]]]; nested: ElasticsearchParseException[Expected field name but got START_OBJECT "aggs"]; }{[BRYrrx8dR4i-ukxlXbuNEw][index20150315][2]: RemoteTransportException[[i-1f30c5fb][inet[/10.101.2.234:9300]][search/phase/query]]; nested: SearchParseException[[index20150315][2]: query[filtered(search_key:my_key_value)->cache(applicationType:myapptype)],from[-1],size[-1]: Parse Failure [Failed to parse source [{"query": {"filtered": {"filter": {"term": {"applicationType": "myapptype"}}, "query": {"match": {"search_key": "my_key_value"}}}, "aggs": {"client": {"terms": {"field": "client"}}}, "size": 0}}]]]; nested: ElasticsearchParseException[Expected field name but got START_OBJECT "aggs"]; }{[No9GT_PtQh6XoOvfz5uTmw][index20150315][0]: RemoteTransportException[[i-1d30c5f9][inet[/10.101.2.237:9300]][search/phase/query]]; nested: SearchParseException[[index20150315][0]: query[filtered(search_key:my_key_value)->cache(applicationType:myapptype)],from[-1],size[-1]: Parse Failure [Failed to parse source [{"query": {"filtered": {"filter": {"term": {"applicationType": "myapptype"}}, "query": {"match": {"search_key": "my_key_value"}}}, "aggs": {"client": {"terms": {"field": "client"}}}, "size": 0}}]]]; nested: ElasticsearchParseException[Expected field name but got START_OBJECT "aggs"]; }]'}]}

Кому-нибудь удалось заставить msearch API работать с запросами, содержащими агрегации?


elasticsearch elasticsearch-dsl
person rom85    schedule 19.03.2015    source источник

Ответы (1)


arrow_upward
1
arrow_downward

На самом деле все работает, это был неправильный запрос, который я использовал в тикете github (тот, который был опубликован выше, верен). Итак, команда будет следующей:

es = Elasticsearch()
es.msearch(body=[
   {"index": "index20150315"},
   {'query': {'filtered': {'filter': {'term': {'applicationType': 'myapptype'}}, 'query': {'match': {'search_key': 'my_key_value1'}}}}, 'aggs': {'client': {'terms': {'field': 'client'}}}, 'size': 0},
   {}, {'query': {'filtered': {'filter': {'term': {'applicationType': 'myapptype'}}, 'query': {'match': {'search_key': 'my_key_value2'}}}}, 'aggs': {'client': {'terms': {'field': 'client'}}}, 'size': 0}])

То же самое можно сделать и с curl. Кстати, elasticsearch-py документация говорит, что вам нужны новые строки в теле, но он работает нормально как обычный список [index1, query1, index2, query2].

person rom85    schedule 28.08.2015