Написать для аутентификации Elasticsearch в Python

У меня возникли проблемы с работой библиотеки Python Elasticsearch с предложением Compose for Elasticsearch от Bluemix. Когда я использую следующий код для кластера Elasticsearch, который я создал с помощью контейнеров IBM, он прекрасно подключается.

IBM Container Cluster с Elasticsearch с подключаемым модулем Shield для аутентификации пользователей

(venv) ❯ python
>>> import requests
>>> import elasticsearch
>>> from elasticsearch import Elasticsearch, RequestsHttpConnection
>>> es = Elasticsearch(
... host='clustertestv5.mybluemix.net',
... port=80,
... http_auth=('es_admin', 'REDACTED'),
... timeout=60)
>>> es.info()
{u'cluster_name': u'elasticsearch', u'tagline': u'You Know, for Search', u'version': {u'lucene_version': u'5.5.0', u'build_hash': u'218bdf10790eef486ff2c41a3df5cfa32dadcfde', u'number': u'2.3.3', u'build_timestamp': u'2016-05-17T15:40:04Z', u'build_snapshot': False}, u'name': u'Forgotten One'}

Когда я пытаюсь использовать тот же код, но аутентифицируюсь в кластере Elasticsearch, предоставленном Bluemix, происходит сбой с ответом ConnectionError.

(venv) ❯ python
>>> import requests
>>> import elasticsearch
>>> from elasticsearch import Elasticsearch, RequestsHttpConnection
>>> es1 = Elasticsearch(
... host='bluemix-sandbox-dal-9-portal.3.dblayer.com',
... port=15206,
... http_auth=('admin', 'REDACTED'),
... timeout=60)
>>> es1.info()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/Users/ryan/Desktop/deltaNiner/venv/lib/python2.7/site-packages/elasticsearch/client/utils.py", line 69, in _wrapped
    return func(*args, params=params, **kwargs)
  File "/Users/ryan/Desktop/deltaNiner/venv/lib/python2.7/site-packages/elasticsearch/client/__init__.py", line 220, in info
    return self.transport.perform_request('GET', '/', params=params)
  File "/Users/ryan/Desktop/deltaNiner/venv/lib/python2.7/site-packages/elasticsearch/transport.py", line 327, in perform_request
    status, headers, data = connection.perform_request(method, url, params, body, ignore=ignore, timeout=timeout)
  File "/Users/ryan/Desktop/deltaNiner/venv/lib/python2.7/site-packages/elasticsearch/connection/http_urllib3.py", line 105, in perform_request
    raise ConnectionError('N/A', str(e), e)
elasticsearch.exceptions.ConnectionError: ConnectionError(('Connection aborted.', BadStatusLine("''",))) caused by: ProtocolError(('Connection aborted.', BadStatusLine("''",)))
>>> quit()

Прямой поворот к кластеру Compose показывает, что имя пользователя и пароль верны, поэтому я знаю, что это не вызывает проблемы с подключением.

(venv) ❯ curl -k 'https://bluemix-sandbox-dal-9-portal.3.dblayer.com:15206/'
<html><body><h1>401 Unauthorized</h1>
You need a valid user and password to access this content.
</body></html>

(venv) ❯ curl -k -u admin:REDACTED 'https://bluemix-sandbox-dal-9-portal.3.dblayer.com:15206/'
{
  "name" : "elastic_search56_bluemix_sandbox_dal_9_data_2_dblayer_com",
  "cluster_name" : "bmix_dal_yp_xxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
  "version" : {
    "number" : "2.4.0",
    "build_hash" : "ce9f0c7394dee074091dd1bc4e9469251181fc55",
    "build_timestamp" : "2016-08-29T09:14:17Z",
    "build_snapshot" : false,
    "lucene_version" : "5.5.2"
  },
  "tagline" : "You Know, for Search"
}

Для справки вот библиотека Python Elasticsearch — https://elasticsearch-py.readthedocs.io/en/master/


person greyhoundforty    schedule 23.09.2016    source источник


Ответы (1)


в вашем коде Python, который создает соединение ES, вам не хватает параметра.

Добавить: use_ssl=True

В этот момент он будет жаловаться на отсутствие проверки сертификата, но продолжит. Чтобы завершить это, вы должны использовать сертификат, указанный в информации о соединении VCAP, вместе с опцией verify_ssl=True. Эта опция по умолчанию False. Примечание: поведение по умолчанию эквивалентно использованию вами параметра -k с curl.

person John Nason    schedule 26.09.2016
comment
К сожалению ошибка осталась. В ближайшее время посмотрю настройки VCAP - File "/Users/ryan/Library/Python/2.7/lib/python/site-packages/elasticsearch/connection/http_urllib3.py", line 105, in perform_request raise ConnectionError('N/A', str(e), e) elasticsearch.exceptions.ConnectionError: ConnectionError(('Connection aborted.', BadStatusLine("''",))) caused by: ProtocolError(('Connection aborted.', BadStatusLine("''",))) - person greyhoundforty; 26.09.2016
comment
Собственно, это и помогло. Следующая часть — где хранить сертификат, полученный из переменных среды VCAP? - person greyhoundforty; 26.09.2016