Примеры кода для подключения к кластеру OpenSearch
Статья создана
Обновлена 13 июля 2026 г.
Перед подключением подготовьте сертификат.
Для подключения нужно использовать имя пользователя admin и пароль, который был задан при создании кластера.
Примеры кода с заполненным FQDN хоста доступны в консоли управления по нажатию кнопки Подключиться на странице кластера.
Go
Перед подключением установите зависимости:
go mod init opensearch-example && \
go get github.com/opensearch-project/opensearch-go
Пример кода:
Подключение с SSL
connect.go
package main
import (
"crypto/tls"
"crypto/x509"
"crypto/x509"
"github.com/opensearch-project/opensearch-go"
"io/ioutil"
"log"
"net/http"
)
var hosts = []string{
"<FQDN_хоста_1_с_ролью_DATA>:9200",
...,
"<FQDN_хоста_N_с_ролью_DATA>:9200"
}
var CA = "/home/<домашняя_директория>/.opensearch/root.crt"
var password = "<пароль>"
func main() {
caCert, err := ioutil.ReadFile(CA)
if err != nil {
log.Fatal(err)
}
caCertPool := x509.NewCertPool()
caCertPool.AppendCertsFromPEM(caCert)
cfg := opensearch.Config{
Addresses: hosts,
Transport: &http.Transport{
TLSClientConfig: &tls.Config{
RootCAs: caCertPool,
},
},
Username: "admin",
Password: password,
}
es, err := opensearch.NewClient(cfg)
if err != nil {
log.Printf("Error creating the client: %s", err)
} else {
log.Println(es.Info())
}
}
В отличие от других способов подключения, в этом примере необходимо указывать полный путь к сертификату CA.pem для OpenSearch в переменной CA.
О том, как получить FQDN хоста, в инструкции.
Подключение:
go run connect.go
Python
Перед подключением установите зависимости:
sudo apt update && sudo apt install --yes python3 python3-pip && \
pip3 install opensearch-py
Пример кода:
Подключение с SSL
connect.py
from opensearchpy import OpenSearch
CA = '~/.opensearch/root.crt'
PASS = '<пароль>'
HOSTS = [
"<FQDN_хоста_1_с_ролью_DATA>",
...,
"<FQDN_хоста_N_с_ролью_DATA>"
]
conn = OpenSearch(
HOSTS,
http_auth=('admin', PASS),
use_ssl=True,
verify_certs=True,
ca_certs=CA)
print(conn.info())
О том, как получить FQDN хоста, в инструкции.
Подключение:
python3 connect.py