ブログ

package main

import (
	"context"
	"crypto/tls"
	"encoding/json"
	"fmt"
	"net/http"
	"os"
	"strings"

	opensearch "github.com/opensearch-project/opensearch-go"
	opensearchapi "github.com/opensearch-project/opensearch-go/opensearchapi"
)

const IndexName = "opensearch_dashboards_sample_data_ecommerce"

type QueryStructure struct {
	Size  int `json:"size"`
	Query struct {
		Match struct {
			CustomerFullName string `json:"customer_full_name"`
		} `json:"match"`
	} `json:"query"`
}

func main() {
	// Initialize the client with SSL/TLS enabled.
	client, err := opensearch.NewClient(opensearch.Config{
		Transport: &http.Transport{
			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
		},
		Addresses: []string{"https://localhost:9200"},
		Username:  "admin", // For testing only. Don't store credentials in code.
		Password:  "admin",
	})
	if err != nil {
		fmt.Println("cannot initialize", err)
		os.Exit(1)
	}

	// クエリ構造体に設定
	query := QueryStructure{}
	query.Size = 10
	query.Query.Match.CustomerFullName = "Eddie"

	// Search for the document.
	queryStr, _ := json.Marshal(query)
	content := strings.NewReader(string(queryStr))

	search := opensearchapi.SearchRequest{
		Index: []string{IndexName},
		Body:  content,
	}

	searchResponse, err := search.Do(context.Background(), client)
	if err != nil {
		fmt.Println("failed to search document ", err)
		os.Exit(1)
	}
	fmt.Println("Searching for a document")
	fmt.Println(searchResponse)
	defer searchResponse.Body.Close()
}