python - 在python的Elasticsearch中批量插入时出现连接错误

我已经编写了将json导入Elasticsearch的代码，但是出现了连接错误，即'连接已中止。'，错误(104，'由对等方重置连接'

该代码是

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'))

谁能帮我吗 ？

最佳答案

此错误消息通常表示另一端已关闭连接。 Elasticsearch不应发生这种情况，除了诸如垃圾回收或进程即将终止之类的严重问题之外。您是否查看过Elasticsearch日志？之后您可以连接到Elasticsearch吗？您的批量请求有多大？您是否尝试了10MB的批量大小？

关于python - 在python的Elasticsearch中批量插入时出现连接错误，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/45906428/