اتصال به دیتابیس ElasticSearch در برنامه‌های go

go get github.com/elastic/go-elasticsearch/v8

ELASTICSEARCH_URI=http://fitz-roy.liara.cloud:33492/
ELASTICSEARCH_USERNAME=elastic
ELASTICSEARCH_PASSWORD=uWrfTv0eW5ESQPYDxpX8EQWI

package main

import (
	"context"
	"fmt"
	"log"
	"os"

	"github.com/elastic/go-elasticsearch/v8"
)

func main() {
	// Get Elasticsearch configuration from environment variables
	esURI := os.Getenv("ELASTICSEARCH_URI")
	esUsername := os.Getenv("ELASTICSEARCH_USERNAME")
	esPassword := os.Getenv("ELASTICSEARCH_PASSWORD")

	if esURI == "" || esUsername == "" || esPassword == "" {
		log.Fatal("Environment variables ELASTICSEARCH_URI, ELASTICSEARCH_USERNAME, and ELASTICSEARCH_PASSWORD must be set")
	}

	// Define the Elasticsearch connection configuration
	esConfig := elasticsearch.Config{
		Addresses: []string{
			esURI,
		},
		Username: esUsername,
		Password: esPassword,
	}

	// Create a new Elasticsearch client
	es, err := elasticsearch.NewClient(esConfig)
	if err != nil {
		log.Fatalf("Error creating the Elasticsearch client: %s", err)
	}

	// Test the connection
	res, err := es.Info()
	if err != nil {
		log.Fatalf("Error getting Elasticsearch info: %s", err)
	}
	defer res.Body.Close()

	// Print the response
	if res.IsError() {
		log.Fatalf("Elasticsearch returned an error: %s", res.String())
	}

	fmt.Println("Connected to Elasticsearch successfully!")
	fmt.Println(res.String())
}