弹性搜索HTTPConnectionPool(host='127.0.0.1',端口= 9200):超出最大重试
-
21-12-2019 - |
题
我有一个弹性的搜索服务器,我正在从直播网站和Django Management命令查询。管理命令在凌晨3点格林威治标准时间使用Celery Beat运行,以同步来自外部服务的数据。有时(但不是每次)此命令运行弹性搜索似乎崩溃,我在错误日志中获得以下错误。
[09/Jan/2014 08:03:46] ERROR [django.request:212] Internal Server Error: /
Traceback (most recent call last):
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/django/core/handlers/base.py",
line 115, in get_response
response = callback(request, *callback_args, **callback_kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/django/views/generic/base.py",
line 68, in view
return self.dispatch(request, *args, **kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/django/views/generic/base.py",
line 86, in dispatch
return handler(request, *args, **kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/django/views/generic/base.py",
line 153, in get
context = self.get_context_data(**kwargs)
File
"/srv/www/site.co.uk/clothes_comparison/clothes_comparison/views.py",
line 56, in get_context_data
fields=['id', 'name', 'price', 'images', 'advertiser']
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/pyelasticsearch/client.py",
line 96, in decorate
return func(*args, query_params=query_params, **kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/pyelasticsearch/client.py",
line 512, in multi_get
'GET', ['_mget'], {'docs': docs}, query_params=query_params)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/pyelasticsearch/client.py",
line 238, in send_request
**({'data': request_body} if body else {}))
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/requests/sessions.py",
line 347, in get
return self.request('GET', url, **kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/requests/sessions.py",
line 335, in request
resp = self.send(prep, **send_kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/requests/sessions.py",
line 438, in send
r = adapter.send(request, **kwargs)
File
"/srv/www/site.co.uk/env/local/lib/python2.7/site-packages/requests/adapters.py",
line 327, in send
raise ConnectionError(e)
ConnectionError: HTTPConnectionPool(host='127.0.0.1', port=9200): Max
retries exceeded with url: /_mget (Caused by <class 'socket.error'>: [Errno 111]
Connection refused)
.
我正在使用pyelasticsearch在我的settings.py文件中使用以下代码连接到弹性搜索:
try:
ES_CON
except NameError:
ES_CON = None
if not ES_CON:
ES_CON = ElasticSearch(ELASTICSEARCH_URI)
.
任何帮助将非常感激。
解决方案
我会建议使用官方elasticsearch python客户端:弹星术 - 具有可靠连接处理的PY 是线程安全等。它也更快(根据作者,谁是Elasticsearch团队的一部分)。
然后,您可以在es = Elasticsearch()
的顶部或在例如,在例如,您可以使用您的tasks.py
。来自那里的core.helpers
和导入生成的世代odicetagcode。 不隶属于 StackOverflow