在python中的elasticsearch中批量插入时出现连接错误答案

【问题标题】：Connection Error while bulk insert in elasticsearch in python在python中的elasticsearch中批量插入时出现连接错误
【发布时间】：2017-08-27 15:13:09
【问题描述】：

我已经编写了将 json 导入到 elasticsearch 的代码，但出现连接错误为 'Connection aborted.', error(104, 'Connection reset by peer'

代码是

from pyelasticsearch import ElasticSearch
import sys, json

ES_CLUSTER = 'http://localhost:9200/'
ES_INDEX = 'test'
ES_TYPE = 'doc'
es = ElasticSearch(ES_CLUSTER)

json_docs = []
with open(r'sample_data.json') as open_file:
        data = json.load(open_file)
        for js in data:
                json_docs.append(js)

es.bulk(ES_INDEX, ES_TYPE, json_docs)

错误是

Traceback (most recent call last):
  File "el_ex.py", line 18, in <module>
    es.bulk(ES_INDEX, ES_TYPE, json_docs) 
  File "/home/tradevigil123/.local/lib/python2.7/site-packages/pyelasticsearch/client.py", line 93, in decorate
    return func(*args, query_params=query_params, **kwargs)
  File "/home/tradevigil123/.local/lib/python2.7/site-packages/pyelasticsearch/client.py", line 448, in bulk
    query_params=query_params)
  File "/home/tradevigil123/.local/lib/python2.7/site-packages/pyelasticsearch/client.py", line 281, in send_request
    raise exc.info
urllib3.exceptions.ProtocolError: ('Connection aborted.', error(104, 'Connection reset by peer'))

谁能帮帮我？

【问题讨论】：

您找到解决方案了吗？

标签： python elasticsearch ubuntu-16.04 connectionexception bulk-import

【解决方案1】：

这个错误信息通常意味着对方已经关闭了连接。 Elasticsearch 不应该发生这种情况，除非出现垃圾收集或进程死亡等不良问题。你检查过 Elasticsearch 日志吗？之后你可以连接到 Elasticsearch 吗？您的批量请求有多大？您是否尝试过像 10MB 这样的批量大小？

【讨论】：