传输错误：传输错误（503，'search_phase_execution_exception'）

Question

我正在尝试使用 Python 和 Elasticsearch 从索引中读取文档。我收到一个错误，我找不到解决方案。有谁知道我该如何解决这个问题？

我在网上查找了同样的问题，但找不到任何相关的文章/解决方案。

这是我的代码：

from elasticsearch import Elasticsearch
from pandasticsearch import Select

# Connection to ElasticSearch
es = Elasticsearch(['http://localhost:9200'],timeout=600)

# Retrieving all documents in index (no query given)
documents = es.search(index='myindex',body={"query": {"match_all": {}}})

# Convert the result to Pandas Dataframe
pandas_df = Select.from_dict(documents).to_pandas()

*来源：https://medium.com/@patni.sonal/elasticsearch-convert-your-index-data-into-pandas-dataframe-30c44ada2407

我得到的错误是：

GET http://localhost:9200/myindex/_search [status:503 request:0.062s]
GET http://localhost:9200/myindex/_search [status:503 request:0.027s]
GET http://localhost:9200/myindex/_search [status:503 request:0.030s]
GET http://localhost:9200/myindex/_search [status:503 request:0.017s]
Traceback (most recent call last):

File "<ipython-input-6-68e07be7c100>", line 1, in <module>
documents = es.search(index='myindex',body={"query": {"match_all": {}}})

File "C:\Users\XXXXXX\AppData\Local\Continuum\anaconda3\lib\site- 
packages\elasticsearch\client\utils.py", line 76, in _wrapped
return func(*args, params=params, **kwargs)

File "C:\Users\XXXXXX\AppData\Local\Continuum\anaconda3\lib\site- 
packages\elasticsearch\client\__init__.py", line 655, in search
doc_type, '_search'), params=params, body=body)

File "C:\Users\XXXXXX\AppData\Local\Continuum\anaconda3\lib\site- 
packages\elasticsearch\transport.py", line 318, in perform_request
status, headers_response, data = connection.perform_request(method, url, 
params, body, headers=headers, ignore=ignore, timeout=timeout)

File "C:\Users\XXXXXX\AppData\Local\Continuum\anaconda3\lib\site- 
packages\elasticsearch\connection\http_urllib3.py", line 185, in 
perform_request
self._raise_error(response.status, raw_data)

File "C:\Users\XXXXXX\AppData\Local\Continuum\anaconda3\lib\site- 
packages\elasticsearch\connection\base.py", line 125, in _raise_error
raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, 
error_message, additional_info)

TransportError: TransportError(503, 'search_phase_execution_exception')

这是elasticsearch日志：

[2019-04-25T11:19:35,843][DEBUG][o.e.a.s.TransportSearchAction] [Cx6mYd6] All shards failed for phase: [query]
[2019-04-25T11:19:35,845][WARN ][r.suppressed             ] [Cx6mYd6] path: /myindex/_search, params: {index=myindex}
org.elasticsearch.action.search.SearchPhaseExecutionException: all shards failed
    at org.elasticsearch.action.search.AbstractSearchAsyncAction.onPhaseFailure(AbstractSearchAsyncAction.java:293) ~[elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.action.search.AbstractSearchAsyncAction.executeNextPhase(AbstractSearchAsyncAction.java:133) ~[elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.action.search.AbstractSearchAsyncAction.onPhaseDone(AbstractSearchAsyncAction.java:254) ~[elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.action.search.InitialSearchPhase.onShardFailure(InitialSearchPhase.java:101) ~[elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.action.search.InitialSearchPhase.lambda$performPhaseOnShard$1(InitialSearchPhase.java:209) ~[elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.action.search.InitialSearchPhase$1.doRun(InitialSearchPhase.java:188) [elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:759) [elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37) [elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.common.util.concurrent.TimedRunnable.doRun(TimedRunnable.java:41) [elasticsearch-6.6.1.jar:6.6.1]
    at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:37) [elasticsearch-6.6.1.jar:6.6.1]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [?:1.8.0_181]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [?:1.8.0_181]
    at java.lang.Thread.run(Unknown Source) [?:1.8.0_181]

有谁知道如何解决这个问题？

Answer 1

我在启动服务后立即发送请求时遇到了此错误elasticsearch。几秒钟后，我重试并成功执行了请求。