golang 요청 es 인터페이스-Golang-php.cn

golang 요청 es 인터페이스

PHPz

풀어 주다： 2023-05-10 09:04:36

원래의

1383명이 탐색했습니다.

빅 데이터 시대가 도래하면서 사람들은 데이터 처리 및 저장에 점점 더 많은 관심을 기울이고 있습니다. 많은 애플리케이션 시나리오에서 데이터를 검색, 분석 및 쿼리해야 합니다. 이때 Elasticsearch(ES)는 많은 기업과 기관에서 사용하는 인기 있는 검색 엔진 및 분석 엔진이 되었습니다. ES를 사용할 때 Golang을 통해 ES와의 상호작용을 구현하는 방법은 무엇입니까? 이번 글에서는 Golang을 사용하여 ES 인터페이스를 요청하는 방법을 다음과 같은 측면에서 소개하겠습니다.

1. Go 언어와 ES 설치

먼저 Go 언어와 ES를 설치해야 합니다. 전자는 공식 홈페이지에서 다운로드하여 설치할 수 있고, 후자는 공식 홈페이지에서 다운로드하거나 컨테이너를 사용해 시작할 수 있다.

2. ES 클라이언트 라이브러리 설치

ES와 Golang을 더 쉽게 사용할 수 있도록 ES는 공식 클라이언트 라이브러리를 제공합니다. 다음 명령을 사용하여 ES의 Golang 클라이언트 라이브러리를 설치할 수 있습니다.

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

로그인 후 복사

참고: 설치 시 v8 브랜치 버전을 사용해야 합니다. 이 버전은 7.x 버전을 지원하기 때문입니다. ES의. v8 分支的版本，因为该版本支持 ES 的 7.x 版本。

3. 连接 ES

在使用 ES 前，需要连接到 ES 集群。ES 支持通过 HTTP 或 TCP 连接，HTTP 连接方式是最常用的方式。使用 Golang 连接到 ES 的示例代码如下：

package main

import (
    "context"
    "fmt"
    "github.com/elastic/go-elasticsearch/v8"
    "log"
)

func main() {
    cfg := elasticsearch.Config{
        Addresses: []string{
            "http://localhost:9200",
        },
    }

    es, err := elasticsearch.NewClient(cfg)
    if err != nil {
        log.Fatalf("创建ES客户端失败：%s
", err)
    }

    _, err = es.Info()
    if err != nil {
        log.Fatalf("无法连接到ES集群：%s
", err)
    }

    fmt.Println("ES连接成功！")
}

로그인 후 복사

以上代码创建了 ES 客户端连接对象，然后连接到 ES 集群，通过调用 Info 方法检查是否连接成功。如果连接成功，会在控制台输出 ES连接成功！。如果无法连接到 ES 集群，会在控制台输出相应的错误信息。

4. 使用 ES API

ES 提供了一系列的 API 来操作 ES 集群中的数据，包括索引操作、搜索、聚合等。在使用 API 时，需要注意相应的请求方法和请求路径、请求体等细节。

下面以搜索操作为例，示例代码如下：

package main

import (
    "context"
    "encoding/json"
    "fmt"
    "github.com/elastic/go-elasticsearch/v8"
    "log"
    "strings"
)

func main() {
    cfg := elasticsearch.Config{
        Addresses: []string{
            "http://localhost:9200",
        },
    }

    es, err := elasticsearch.NewClient(cfg)
    if err != nil {
        log.Fatalf("创建ES客户端失败：%s
", err)
    }

    res, err := es.Search(
        es.Search.WithIndex("test_index"),
        es.Search.WithBody(strings.NewReader(`{"query":{"match_all":{}}}`)),
        es.Search.WithPretty(),
    )

    if err != nil {
        log.Fatalf("搜索失败：%s
", err)
    }

    defer res.Body.Close()

    var r map[string]interface{}
    if err := json.NewDecoder(res.Body).Decode(&r); err != nil {
        log.Fatalf("无法解析响应体：%s
", err)
    }

    fmt.Println(r)
}

로그인 후 복사

以上代码创建了 ES 客户端连接对象，然后通过调用 Search

3. ES에 연결

ES를 사용하기 전에 ES 클러스터에 연결해야 합니다. ES는 HTTP 또는 TCP를 통한 연결을 지원하며, HTTP 연결이 가장 일반적으로 사용되는 방법입니다. Golang을 사용하여 ES에 연결하는 샘플 코드는 다음과 같습니다.

rrreee

위 코드는 ES 클라이언트 연결 개체를 생성한 후 ES 클러스터에 연결하고 Info를 호출하여 연결 성공 여부를 확인합니다. > 방법. 연결이 성공하면 ES 연결 성공이 콘솔에 출력됩니다! . ES 클러스터에 연결할 수 없는 경우 해당 오류 메시지가 콘솔에 출력됩니다.

4. ES API 사용🎜🎜ES는 인덱스 작업, 검색, 집계 등 ES 클러스터의 데이터를 작업할 수 있는 일련의 API를 제공합니다. API를 사용할 때 해당 요청 방법, 요청 경로, 요청 본문 및 기타 세부 사항에 주의해야 합니다. 🎜🎜다음은 검색 작업을 예로 들어보겠습니다. 샘플 코드는 다음과 같습니다. 🎜rrreee🎜위 코드는 ES 클라이언트 연결 개체를 생성한 후 Search 메서드를 호출하여 검색 작업을 수행합니다. . 인덱스 이름과 검색 쿼리문을 지정해야 합니다. 결과는 JSON 형식으로 반환되며, JSON 데이터를 파싱하여 관련 검색결과를 얻을 수 있습니다. 🎜🎜검색 작업 외에도 ES API를 사용할 때 필요에 따라 해당 문서를 참조하고 실제 시나리오에 따라 해당 처리 및 조정을 해야 합니다. 🎜🎜5. 요약🎜🎜이 글에서는 Golang을 사용하여 ES 인터페이스를 요청하는 방법을 소개합니다. ES 클러스터에 연결하고 ES API를 사용하면 ES와 쉽게 상호 작용할 수 있으며 실제 필요에 따라 해당 API 호출 방법을 조정하여 ES 클러스터에서 데이터 검색 및 집계와 같은 작업을 수행할 수 있습니다. 🎜

위 내용은 golang 요청 es 인터페이스의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!