package main

import (
	"context"
	"fmt"

	"github.com/olivere/elastic/v7"
)

type Person struct {
	Name    string `json:"name"`
	Age     int    `json:"age"`
	Married bool   `json:"married"`
}

func main() {
	client, err := elastic.NewClient(elastic.SetURL("http://127.0.0.1:9200"), elastic.SetBasicAuth("elastic", "elastic"))
	if err != nil {
		// Handle error
		panic(err)
	}
	fmt.Println("connect to es success")
	person := Person{Name: "talen", Age: 39, Married: true}
	result, err := client.Index().
		Index("user-test").
		BodyJson(person).
		Do(context.Background())
	if err != nil {
		// Handle error
		panic(err)
	}
	fmt.Printf("user-test %s to index %s, type %s\n", result.Id, result.Index, result.Type)
}

Logo

瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手

更多推荐