运输错误：运输错误（503，'search_phase_execution_exception'）答案

【问题标题】：TransportError: TransportError(503, 'search_phase_execution_exception')运输错误：运输错误（503，'search_phase_execution_exception'）
【发布时间】：2019-04-25 08:34:44
【问题描述】：

我正在尝试使用 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]

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

【问题讨论】：

在错误日志中我可以看到documents = es.search(index='myindex',body={})，而在代码中它是documents = es.search(index='myindex',body={"query": {"match_all": {}}})。代码中实际上是哪一行？
抱歉，documents = es.search(index='myindex',body={"query": {"match_all": {}}}) 是实际代码。另一个是当我从 *Source（提供）运行代码时。
TransportError(503, 'search_phase_execution_exception') 应该有更多的日志信息。如果没有，那么您可以添加可以在 elasticsearch 日志中找到的完整日志。
当您在浏览器中访问http://localhost:9200/myindex/_search 时会得到什么响应？
{"error":{"root_cause":[],"type":"search_phase_execution_exception","reason":"all shards failed","phase":"query","grouped" :true,"failed_shards":[]},"status":503}

标签： python pandas dataframe elasticsearch

【解决方案1】：

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

【讨论】：