Go：如何获取ES数据

沈宥

发布于 2024-07-11 10:20:03

35500

代码可运行

文章被收录于专栏：从头开始学习测试开发从头开始学习测试开发

运行总次数：0

代码可运行

连接ES

必要参数 [Addresses]ES连接地址 [Username]登录账号 [Password]登录账号密码

addresses := []string{"http://es-logdata-cluster-n0.host.com:9200"}
	config := elasticsearch.Config{
		Addresses: addresses,
		Username:  "Username",
		Password:  "Password",
	}

	es, err := elasticsearch.NewClient(config)
	if err != nil {
		log.Error(err, "Error creating the es client")
	}

	res, err := es.Info()
	if err != nil {
		log.Error(err, "Error getting es response")
	}

获取数据

必要的参数： [index]es索引名称 [body]请求体搜索，即request body search，简单来说就是query语句，示例如下：

{
  "query": {
    "filtered": {
      "filter": {
1        { "term": { "brand": "gucci" }}
      }
    }
  },
  "aggs": {
    "colors": {
2      "terms": { "field": "color" },
    },
    "color_red": {
      "filter": {
3        "term": { "color": "red" }
      },
      "aggs": {
        "models": {
4          "terms": { "field": "model" }
        }
      }
    }
  },
5  "post_filter": {
    "term": { "color": "red" },
  }
}

[num]要获取查询结果的条数

buf := strings.NewReader(body)
	res, err = es.Search(
		es.Search.WithContext(context.Background()),
		es.Search.WithIndex(index),
		es.Search.WithIgnoreUnavailable(true),
		es.Search.WithBody(buf),
		es.Search.WithPretty(),
		es.Search.WithTrackTotalHits(true),
		es.Search.WithSize(num),
	)

	if err != nil {
		fmt.Println("err: ", err)
		log.Error(err, "Error getting response")
	}

	defer res.Body.Close()
	return  res.String()

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2024-05-15，如有侵权请联系 cloudcommunity@tencent.com 删除

登录