Bagaimana untuk membangunkan aplikasi untuk mendapatkan semula ES menggunakan Golang

Dengan perkembangan pesat aplikasi Internet, data besar-besaran telah menjadi kebiasaan, dan penyimpanan serta pertanyaan yang cekap bagi data ini telah menjadi sangat penting. Enjin Carian ialah enjin perolehan teragih yang cekap dan berskala untuk persekitaran penyimpanan data teragih berskala besar Ia adalah teknologi yang berorientasikan kepada bidang mendapatkan semula teks.

ElasticSearch (ES) ialah enjin carian yang dibangunkan berdasarkan perpustakaan Lucene Ia adalah enjin carian teks penuh yang diedarkan berdasarkan seni bina RESTful yang boleh menyokong carian masa nyata, analisis data dan fungsi lain. Disebabkan sifat sumber terbuka dan kemudahan penggunaannya, ElasticSearch semakin digemari oleh pembangun. Artikel ini akan memperkenalkan cara menggunakan Golang untuk membangunkan aplikasi untuk mendapatkan semula ES.

Pertama, kita perlu memasang klien ES dalam bahasa pengaturcaraan Go. Pelanggan ES menggunakan seni bina RESTful, jadi kami boleh menggunakan perpustakaan permintaan HTTP Go untuk berinteraksi dengan ES. Kemudian, kita boleh memanggil API ES RESTful untuk melaksanakan carian mudah dengan merujuk kepada contoh kod berikut:

package main

import (
    "encoding/json"
    "fmt"
    "net/http"
    "bytes"
)

type SearchResult struct {
    Hits struct {
        Total int `json:"total"`
        Hits []struct {
            Source interface{} `json:"_source"`
        } `json:"hits"`
    } `json:"hits"`
}

func main() {
    query := "hello"
    url := fmt.Sprintf("http://localhost:9200/_search?q=%s", query)
    resp, _ := http.Get(url)
    defer resp.Body.Close()
    var result SearchResult
    json.NewDecoder(resp.Body).Decode(&result)
    b, _ := json.Marshal(result.Hits.Hits)
    fmt.Println(string(b))
}

Pertama, kami mentakrifkan struktur bernama SearchResult untuk menyimpan hasil carian ES. Kemudian, kami menggunakan fungsi fmt.Sprintf untuk membina URL carian, menyerahkan permintaan kepada ES melalui fungsi http.Get dan menghuraikan hasilnya ke dalam struktur.

Akhir sekali, kami menyusun hasil bersiri ke format JSON dan mencetak ke konsol. Dengan cara ini, kita boleh menggunakan bahasa Go untuk mencari dokumen dalam ES dengan sangat mudah.

Walau bagaimanapun, kaedah ini hanya sesuai untuk aplikasi carian mudah Untuk operasi yang memerlukan fungsi yang lebih kaya seperti carian mengikut syarat atau pengagregatan, kami perlu menggunakan klien Golang yang disediakan secara rasmi oleh ES: go-elasticsearch.

Pertama, kita perlu memasang perpustakaan go-elasticsearch yang disediakan secara rasmi. Anda boleh menggunakan arahan berikut untuk memasang:

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

Seterusnya, kami melaksanakan pertanyaan ES melalui contoh kod berikut:

package main

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

type SearchResult struct {
    Hits struct {
        Total int `json:"total"`
        Hits []struct {
            Source interface{} `json:"_source"`
        } `json:"hits"`
    } `json:"hits"`
}

func main() {
    es, err := elasticsearch.NewDefaultClient()
    if err != nil {
        fmt.Println("Error creating Elasticsearch client:", err)
        return
    }

    query := "hello"

    var buf bytes.Buffer
    queryMap := map[string]interface{}{
        "query": map[string]interface{}{
            "match": map[string]interface{}{
                "message": query,
            },
        },
    }
    if err := json.NewEncoder(&buf).Encode(queryMap); err != nil {
        fmt.Println("Error encoding query:", err)
        return
    }

    req := esapi.SearchRequest{
        Index: []string{"my_index"},
        Body:  &buf,
        Pretty: true,
    }

    res, err := req.Do(context.Background(), es)
    if err != nil {
        fmt.Println("Error searching for documents:", err)
        return
    }
    defer res.Body.Close()

    var result SearchResult
    json.NewDecoder(res.Body).Decode(&result)
    b, _ := json.Marshal(result.Hits.Hits)
    fmt.Println(string(b))
}

Pertama, kami mencipta pelanggan Elasticsearch, dan kemudian tentukan kata kunci pertanyaan. Seterusnya, kami membina peta dalam format JSON yang mengandungi syarat pertanyaan dan mengekodnya ke buf melalui fungsi json.NewEncoder.

Akhir sekali, kami menggunakan API ES yang disediakan oleh perpustakaan go-elasticsearch untuk menghantar permintaan pertanyaan kepada ES dan membaca serta menghuraikan respons permintaan.

Menggunakan perpustakaan go-elasticsearch boleh melaksanakan fungsi carian ES yang kompleks dengan mudah dan menjadikan kod lebih elegan dan ringkas. Menggunakan Golang untuk carian ES sangat meningkatkan kelajuan carian sambil mengekalkan kecekapan kod.

Ringkasnya, Golang ialah bahasa pengaturcaraan yang ringkas dan cekap, dan sangat mudah untuk menggunakannya untuk melaksanakan carian ES. Saya harap artikel ini dapat membantu anda memahami penggunaan carian ES dan perpustakaan go-elasticsearch.

Atas ialah kandungan terperinci Bagaimana untuk membangunkan aplikasi untuk mendapatkan semula ES menggunakan Golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!