Примеры кода для подключения к кластеру OpenSearch

Статья создана

Обновлена 13 февраля 2026 г.

Go
Python

Перед подключением подготовьте сертификат.

Для подключения нужно использовать имя пользователя 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.

Подключение:
```
go run connect.go
```

О том, как получить FQDN хоста, см. инструкцию.

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())

Подключение:
```
python3 connect.py
```

О том, как получить FQDN хоста, см. инструкцию.

Примеры кода для подключения к кластеру OpenSearch

GoGo

PythonPython

Была ли статья полезна?

Go

Python