Menggunakan Elasticsearch dalam Go: Panduan Lengkap

Menggunakan Elasticsearch dalam Go: Panduan Lengkap

Elasticsearch ialah enjin carian dan analisis sumber terbuka yang popular yang boleh digunakan untuk memproses sejumlah besar data. Ia menyokong carian teks penuh, analisis masa nyata, visualisasi data dan fungsi lain, dan sesuai untuk pelbagai senario aplikasi. Pada masa yang sama, bahasa Go ialah bahasa pengaturcaraan yang pantas dan cekap yang semakin popular di kalangan pembangun. Dalam artikel ini, kami akan memperkenalkan cara menggunakan Elasticsearch untuk melaksanakan fungsi carian dan analisis dalam bahasa Go.

1 Pasang dan konfigurasikan Elasticsearch

Mula-mula, kita perlu memasang dan mengkonfigurasi Elasticsearch. Dalam persekitaran Linux, anda boleh menggunakan baris arahan untuk memasang. Selepas pemasangan selesai, anda perlu mengubah suai fail konfigurasi elasticsearch.yml dan mengkonfigurasi parameter seperti alamat pendengaran dan laluan penyimpanan data Elasticsearch.

2. Pengenalan perpustakaan klien Elasticsearch

Bahasa Go menyediakan pelbagai perpustakaan klien Elasticsearch, yang boleh diperkenalkan melalui penyataan import mudah, contohnya:

import "github.com/olivere/elastic"

Di sini kami gunakan ialah perpustakaan olivere/anjal.

3 Sambung ke Elasticsearch

Menyambung ke Elasticsearch adalah sangat mudah Anda hanya perlu menyatakan alamat contoh Elasticsearch dalam kod, contohnya:

rreee

Selepas. sambungan berjaya, kami Anda boleh menggunakan pelbagai API Elasticsearch untuk mengindeks, bertanya dan menganalisis data.

4. Data indeks

Dalam Elasticsearch, data disimpan dalam bentuk dokumen, dan setiap dokumen mempunyai ID unik untuk operasi pengambilan dan kemas kini. Kami boleh menggunakan API Pukal untuk mengindeks berbilang dokumen serentak, contohnya:

client, err := elastic.NewClient(
    elastic.SetURL("http://localhost:9200"),
)
if err != nil {
    // 处理连接失败的错误
}

Dalam contoh ini, kami mentakrifkan struktur bernama Buku, yang mengandungi medan seperti ID, Tajuk, Pengarang dan Bahasa. Seterusnya, kami membina kepingan tiga objek Buku dan mengindeks setiap dokumen satu demi satu menggunakan API Pukal. Antaranya, parameter Indeks dan Jenis menentukan nama indeks dan nama jenis dokumen masing-masing, parameter Id menentukan ID unik dokumen dan parameter Dokumen ialah objek dokumen sebenar. Akhir sekali, kami memanggil kaedah pukal.Do() untuk melaksanakan operasi pengindeksan.

5. Data carian

Untuk melaksanakan operasi carian, anda perlu menggunakan API Carian, contohnya:

// 准备数据
type Book struct {
    ID       string `json:"id"`
    Title    string `json:"title"`
    Author   string `json:"author"`
    Language string `json:"language"`
}

books := []Book{
    {ID: "1", Title: "The Go Programming Language", Author: "Alan A. A. Donovan, Brian W. Kernighan", Language: "English"},
    {ID: "2", Title: "Go Web Programming", Author: "Sau Sheong Chang", Language: "English"},
    {ID: "3", Title: "Go in Action", Author: "William Kennedy, Brian Ketelsen, Erik St. Martin", Language: "English"},
}

// 使用Bulk API进行索引
bulk := client.Bulk()
for _, book := range books {
    req := elastic.NewBulkIndexRequest().Index("books").Type("doc").Id(book.ID).Doc(book)
    bulk.Add(req)
}
response, err := bulk.Do(context.Background())
if err != nil {
    // 处理错误
}

Dalam contoh ini, kami membina syarat pertanyaan yang memerlukan medan Tajuk mengandungi "go programming", medan Bahasa ialah "english". Seterusnya, kami meminta operasi carian menggunakan API Carian, menyatakan nama indeks, nama jenis dokumen dan kriteria pertanyaan. Selepas pelaksanaan berjaya, objek searchResult yang dikembalikan mengandungi semua dokumen yang sepadan Kita boleh melintasi elemen searchResult.Hits.Hits, menghuraikan objek dokumen satu demi satu dan meletakkannya ke dalam kepingan buku.

6. Menganalisis data

Untuk menganalisis data, kita perlu menggunakan API Pengagregatan, contohnya:

// 准备查询条件
query := elastic.NewBoolQuery().Must(
    elastic.NewMatchQuery("title", "go programming"),
    elastic.NewMatchQuery("language", "english"),
)

// 构造Search API请求
searchResult, err := client.Search().Index("books").Type("doc").Query(query).Do(context.Background())
if err != nil {
    // 处理错误
}

// 处理Search API响应
var books []Book
for _, hit := range searchResult.Hits.Hits {
    var book Book
    err := json.Unmarshal(*hit.Source, &book)
    if err != nil {
        // 处理解析错误
    }
    books = append(books, book)
}
fmt.Println(books)

Dalam contoh ini, kami membina keadaan pengagregatan yang memerlukan pengarang kepada Kumpulan mengikut nama (pengarang.kata kunci) dan kira bilangan dokumen dalam setiap kumpulan. Seterusnya, kami menggunakan API Pengagregatan untuk meminta operasi pengagregatan, menyatakan nama indeks, nama jenis dokumen dan syarat pengagregatan. Selepas pelaksanaan berjaya, objek searchResult yang dikembalikan mengandungi semua hasil pengumpulan dan statistik Kami boleh mengakses keadaan pengagregatan oleh_pengarang melalui kaedah searchResult.Aggregations.Terms, dan merentasi elemen Baldi untuk mengeluarkan nombor setiap kumpulan dan dokumen satu demi satu.

Ringkasan

Dalam artikel ini, kami memperkenalkan cara menggunakan Elasticsearch untuk melaksanakan fungsi carian dan analisis dalam bahasa Go. Kami mula-mula memasang dan mengkonfigurasi Elasticsearch dan memperkenalkan perpustakaan pelanggan olivere/elastik. Seterusnya, kami membincangkan cara menyambung ke Elasticsearch, data indeks, data carian dan menganalisis data. Melalui contoh ini, anda boleh mulakan dengan cepat menggunakan bahasa Elasticsearch dan Go, dan mempelajari fungsi lanjutannya secara mendalam.

Atas ialah kandungan terperinci Menggunakan Elasticsearch dalam Go: Panduan Lengkap. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!