탄력적 검색 HTTPConnectionPool(호스트='127.0.0.1', 포트=9200):최대 재시도 초과

Question

라이브 웹사이트와 Django 관리 명령을 통해 쿼리하는 Elastic Search 서버가 있습니다.관리 명령은 오전 3시(GMT)에 셀러리 비트를 사용하여 실행되어 외부 서비스의 데이터를 동기화합니다.때때로(매번은 아니지만) 이 명령이 실행되면 탄력적 검색이 중단되는 것처럼 보이고 오류 로그에 다음 오류가 표시됩니다.

    [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 파일에 다음 코드를 사용하여 Elastic Search에 연결하고 있습니다.

try:
    ES_CON
except NameError:
    ES_CON = None

if not ES_CON:
    ES_CON = ElasticSearch(ELASTICSEARCH_URI)

어떤 도움이라도 대단히 감사하겠습니다.

Answer 1

공식 Elasticsearch Python 클라이언트를 사용하는 것이 좋습니다. 탄력적 검색-py 안정적인 연결 처리 기능이 있고 스레드로부터 안전합니다.또한 더 빠릅니다(Elasticsearch 팀의 일원인 저자에 따르면).

그러면 당신은 당신의 es = Elasticsearch() 당신의 상단에 tasks.py, 또는 예를 들어 core.helpers 그리고 수입 es 거기에서.