Go での Elasticsearch の使用: 完全ガイド

Go での Elasticsearch の使用: 完全ガイド

Elasticsearch は、大量のデータの処理に使用できる人気のオープンソースの検索および分析エンジンです。全文検索、リアルタイム分析、データ可視化などの機能をサポートしており、さまざまなアプリケーションシナリオに適しています。同時に、Go 言語は高速かつ効率的なプログラミング言語であり、開発者の間でますます人気が高まっています。この記事では、Elasticsearchを使ってGo言語で検索・分析機能を実装する方法を紹介します。

1. Elasticsearch のインストールと設定

まず、Elasticsearch をインストールして設定する必要があります。 Linux 環境では、コマンド ラインを使用してインストールできます。インストールが完了したら、構成ファイル elasticsearch.yml を変更し、Elasticsearch のリスニング アドレスやデータ ストレージ パスなどのパラメーターを構成する必要があります。

2. Elasticsearch クライアント ライブラリの紹介

Go 言語にはさまざまな Elasticsearch クライアント ライブラリが用意されており、これらは単純な import ステートメントを通じて導入できます。例:

import "github.com/olivere/elastic"

ここで使用するのはオリベール/エラスティックライブラリ。

3. Elasticsearch への接続

Elasticsearch への接続は非常に簡単で、コード内で Elasticsearch インスタンスのアドレスを指定するだけです (例:

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

After)。接続が成功すると、Elasticsearch のさまざまな API を使用して、データのインデックス付け、クエリ、分析を行うことができます。

4. インデックス データ

Elasticsearch では、データはドキュメントの形式で保存され、各ドキュメントには取得および更新操作のために一意の ID が割り当てられます。 Bulk API を使用すると、複数のドキュメントに一度にインデックスを付けることができます。次に例を示します。

// 准备数据
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 {
    // 处理错误
}

この例では、ID、タイトル、作成者、言語などのフィールドを含む Book という名前の構造を定義します。次に、3 つの Book オブジェクトのスライスを構築し、Bulk API を使用して各ドキュメントに 1 つずつインデックスを付けます。このうち、Index パラメータと Type パラメータはそれぞれインデックス名とドキュメント タイプ名を指定し、Id パラメータはドキュメントの一意の ID を指定し、Doc パラメータは実際のドキュメント オブジェクトです。最後に、Bulk.Do() メソッドを呼び出して、インデックス付け操作を実行します。

5. データの検索

検索操作を実行するには、検索 API を使用する必要があります (例:

// 准备查询条件
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)

)。この例では、次のクエリ条件を構築します。 Title フィールドには「go programming」を入力し、Language フィールドには「english」を入力します。次に、検索 API を使用して、インデックス名、ドキュメント タイプ名、クエリ条件を指定して検索操作をリクエストします。実行が成功すると、返された searchResult オブジェクトには一致するすべてのドキュメントが含まれます。searchResult.Hits.Hits 要素をトラバースし、ドキュメント オブジェクトを 1 つずつ解析して書籍スライスに配置します。

6. データの分析

データを分析するには、たとえば、次のような集計 API を使用する必要があります:

// 构造Aggregation API请求
aggs := elastic.NewTermsAggregation().Field("author.keyword").Size(10)
searchResult, err := client.Search().Index("books").Type("doc").Aggregation("by_author", aggs).Do(context.Background())
if err != nil {
    // 处理错误
}

// 处理Aggregation API响应
aggResult, ok := searchResult.Aggregations.Terms("by_author")
if !ok {
    // 处理无法找到聚合结果的错误
}
for _, bucket := range aggResult.Buckets {
    fmt.Printf("%v: %v
", bucket.Key, bucket.DocCount)
}

この例では、 author を名前 (author.keyword) でグループ化し、各グループ内のドキュメントの数を数えます。次に、Aggregation API を使用して、インデックス名、文書型名、および集計条件を指定して集計操作を要求します。実行が成功すると、返された searchResult オブジェクトにはすべてのグループ化と統計結果が含まれます。searchResult.Aggregations.Terms メソッドを通じて by_author 集計条件にアクセスし、Buckets 要素をトラバースして各グループ化とドキュメントの数を 1 つずつ出力できます。

概要

この記事では、Elasticsearch を使用して Go 言語で検索および分析機能を実装する方法を紹介しました。まず Elasticsearch をインストールして構成し、olivere/elastic クライアント ライブラリを導入しました。次に、Elasticsearch への接続、データのインデックス付け、データの検索、データの分析の方法について説明しました。これらの例を通じて、Elasticsearch と Go 言語をすぐに使い始め、それらの高度な機能を詳しく学ぶことができます。

以上がGo での Elasticsearch の使用: 完全ガイドの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。