57.Go操作ES(官方提供github.com/elastic/go-elasticsearch库)
package main
import (
"context"
"fmt"
"log"
"os"
"github.com/elastic/go-elasticsearch/v8"
"github.com/elastic/go-elasticsearch/v8/esapi"
)
func main() {
es, err := elasticsearch.NewDefaultClient()
if err != nil {
log.Fatalf("Error creating the client: %s", err)
}
res, err := es.Info()
if err != nil {
log.Fatalf("Error getting response: %s", err)
}
defer res.Body.Close()
fmt.Println(res)
}
这段代码演示了如何使用go-elasticsearch
库创建Elasticsearch客户端,并获取Elasticsearch集群的信息。它首先尝试创建一个默认的Elasticsearch客户端,并在创建失败时记录错误和退出程序。然后,它调用es.Info()
函数来获取集群信息,并在获取信息失败时记录错误和退出程序。最后,它打印出响应结果。这是一个简单的例子,展示了如何开始在Go中使用Elasticsearch。
评论已关闭