python链接elaticsearch报错Connection reset by peer，如何解决？

Question

python链接elaticsearch报错Connection reset by peer
信息如下：

elasticsearch.exceptions.ConnectionError: ConnectionError(('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer'))) caused by: ProtocolError(('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer')))

一下是代码信息：

query = {'query': {'match_all': {}}}
index = 'user_efficiency_detail_page_{}'.format(today.date())
try:
  all_doc = client.search(index=index, body=query)
  es_data = all_doc['hits']['hits']
    if not es_data:
      raise ValueError('无数据！')
    result = es_data[0]['_source']['result']
except Exception:
  result = self.users_efficiency_data_compute()
  create_es = {'result': result}
  client.index(index=index, doc_type='_doc', body=create_es)

报错之后部署在docker中的es就会直接宕机，不知道为什么。求解。万分感谢。

Answer 1

以下回答参考GPT并且由妙妙大帅整理：
个错误通常是由于与Elasticsearch服务器的连接中断引起的。一些可能的原因包括网络问题、服务器资源不足、Elasticsearch进程崩溃等等。

在您的代码中，当无法从Elasticsearch中检索到数据时，您正在调用users_efficiency_data_compute()方法，并尝试将计算出的结果存储回Elasticsearch。如果此时发生连接错误，会抛出异常，并将计算结果存储回Elasticsearch。这可能会导致无限循环，并在短时间内多次尝试将数据存储到Elasticsearch中，这可能会导致Elasticsearch服务器崩溃。

为了解决这个问题，您可以尝试以下方法：

检查Elasticsearch服务器的资源使用情况，特别是内存和CPU使用率，以确保它没有超过其限制。

尝试使用ping命令测试与Elasticsearch服务器的网络连接，以查看是否存在网络问题。

尝试在代码中添加适当的异常处理程序来捕获和处理连接错误，例如使用try-except语句并在发生异常时记录错误。

如果您仍然遇到问题，您可能需要检查Elasticsearch服务器的日志以获取更多信息，并根据需要调整服务器配置。

希望这些建议可以帮助您解决问题。