0

如何在 Open Distro for Elasticsearch 中使用 elasticsearch-dbapi，忽略 ssl 证书？

我正在使用 Open Distro for Elasticsearch 1.13.2、Python 3.7、elasticsearch 客户端 7.12.1、sqlalchemy：1.4.17、eland：7.10.1b1

这有效：

from elasticsearch import Elasticsearch
es = Elasticsearch (['https: // admin: admin @ localhost: 9200 /'], use_ssl = True, verify_certs = False, ssl_show_warn = False)
res = es.indices.get_alias ("*")
print (res)

这也有效：

import eland as ed
df = ed.DataFrame (es, es_index_pattern = "kibana_sample_data_flights")
df

但是以下方法不起作用，因为自签名证书会导致连接错误：

# Using sqlalchemy
from sqlalchemy.engine import create_engine
engine = create_engine (
    "odelasticsearch + https: // admin: admin @ localhost: 9200 /"
)
rows = engine.connect (). execute (
    "select Carrier, count (*) from kibana_sample_data_flights GROUP BY Carrier"
)
print ([row for row in rows])

部分错误消息：错误：[（'SSL 例程'，'tls_process_server_certificate'，'证书验证失败'）]

以下内容也不起作用：

# Using elasticsearch-dbapi
from es.elastic.api import connect
conn = connect (host = 'localhost')
curs = conn.cursor ()
curs.execute (
    "select * from kibana_sample_data_flights LIMIT 10"
)
print ([row for row in curs])

部分错误信息：ProtocolError: ('Connection aborted.', RemoteDisconnected ('Remote end closed connection without response'))

4

1 回答 1

0

现在这适用于 sqlalchemy

# sqlalchemy
from sqlalchemy.engine import create_engine
ssl_args = {"use_ssl": True, "verify_certs": False, "ssl_show_warn": False}
engine = create_engine (
     "odelasticsearch + https: // admin: admin @ localhost: 9200 /"
     , connect_args = ssl_args
)
rows = engine.connect (). execute (
     "select Carrier, count (*) from kibana_sample_data_flights GROUP BY Carrier"
)
print ([row for row in rows])

只需要使用 elasticsearch-dbapi 解决问题

于 2021-06-02T15:59:17.527 回答