Utilisez Elasticsearch dans le langage Go pour obtenir une recherche efficace

Avec l'avènement de l'ère du big data, le stockage et la récupération de données sont devenus un problème important auquel nous sommes confrontés. Elasticsearch est un moteur de recherche et d'analyse distribué en temps réel open source. Il peut rechercher de grandes quantités de données grâce à une indexation inverse rapide et fournit une recherche efficace en texte intégral, une analyse globale, une surveillance en temps réel, une complétion automatique et une visualisation des données. pratique, il a un large éventail d’applications dans des scénarios d’application. Dans le même temps, en tant que langage de programmation rapide et typé statiquement, le langage Go est également largement utilisé dans le développement de services back-end. Dans cet article, nous présenterons comment utiliser Elasticsearch en langage Go pour implémenter des fonctions de recherche efficaces.

1. Installer les bibliothèques Elasticsearch et Go
Tout d'abord, nous devons installer Elasticsearch et les bibliothèques Go correspondantes pour implémenter la prise en charge de Go pour le client Elasticsearch. Pour l'installation d'Elasticsearch, vous pouvez vous rendre sur le site officiel d'Elasticsearch (https://www.elastic.co/downloads/elasticsearch) pour télécharger la version correspondante du package d'installation et l'installer selon le système d'exploitation et la méthode d'installation. .

Ensuite, nous devons ajouter la bibliothèque client Elasticsearch à l'environnement Go. Dans Go, il existe de nombreuses bibliothèques tierces qui prennent en charge notre développement de programmation à l'aide du client Elasticsearch. Parmi elles, les bibliothèques les plus courantes sont :

1. Elastic (adresse du document : https://godoc.org/gopkg.in/olivere/elastic.v5)
2. go-elasticsearch (adresse du document : https://github. com /elastic/go-elasticsearch)
3. golang-elasticsearch (Adresse du document : https://github.com/elastic/go-elasticsearch)

Ici, nous choisissons Elastic. Dans Go, vous pouvez utiliser la commande suivante pour installer la bibliothèque client Elasticsearch :

go get -u gopkg.in/olivere/elastic.v5

2. Connectez-vous à Elasticsearch
Pour vous connecter à Elasticsearch, vous devez spécifier l'adresse IP et le numéro de port du serveur Elasticsearch. Par défaut, le numéro de port d'Elasticsearch est 9200. Vous pouvez vous connecter via les méthodes suivantes :

client, err := elastic.NewClient(

elastic.SetURL("http://127.0.0.1:9200"),
elastic.SetSniff(false),

)
if err != nil {

// do something...

}

Créer un client Elasticsearch Durant le terminal, vous pouvez également effectuer certains réglages personnalisés, comme le code suivant :

client, err := elastic.NewClient(

elastic.SetURL("http://127.0.0.1:9200"),
elastic.SetSniff(false),
elastic.SetHealthcheck(true),
elastic.SetGzip(true),
elastic.SetErrorLog(log.New(os.Stderr, "ELASTIC ", log.LstdFlags)),
elastic.SetInfoLog(log.New(os.Stdout, "", log.LstdFlags)),
elastic.SetTraceLog(log.New(ioutil.Discard, "", 0)),

)

Parmi eux, pour les réglages pour nous connecter à Elasticsearch, nous avons effectué les configurations suivantes :

La méthode
1. SetURL() est utilisée pour spécifier l'IP et le numéro de port du serveur Elasticsearch ; la méthode
2. SetSniff() est utilisée pour interdire à Elastic de découvrir automatiquement le serveur Elasticsearch ; état des autres nœuds au moment de l'exécution pour obtenir l'état de santé du cluster et d'autres informations ; la méthode
3. SetHealthcheck() est utilisée Pour spécifier la fréquence de détection de l'état de santé, une notification sera envoyée si une anomalie est détectée ; est utilisé pour activer la fonction de compression Gzip du client Elasticsearch ;
4. La méthode SetErrorLog() est utilisée pour spécifier les informations du journal des erreurs ;
5. La méthode SetInfoLog() est utilisée pour spécifier les informations d'invite ; informations du journal de suivi.
3. Requête de base
7. Après la connexion à Elasticsearch, nous pouvons effectuer des requêtes de base sur les données. Voici un exemple de requête simple :

query := elastic.NewMatchQuery("name", "John")

result, err := client.Search().

Index("users").
Query(query).
Do(context.Background())

if err != nil {

// do something...

}

fmt.Printf("La requête a pris %d millisecondes

", result.TookInMillis)

Parmi eux, nous avons utilisé la méthode NewMatcQuery() dans le package élastique pour créer une requête correspondante exacte. Le champ de requête est le nom et la condition de la requête est. "John ". Lors de l'exécution de la requête, nous définissons l'index de la requête sur les utilisateurs et spécifions la méthode de requête. Ici, nous utilisons client.Search() pour effectuer l'opération de requête. Enfin, nous utilisons la méthode result.TookInMillis pour obtenir le temps consommé par la requête.

4. Requête avancée

En utilisation réelle, nous devons implémenter des fonctions de requête plus complexes, telles que la requête par plage, la requête floue, le tri, etc. Elasticsearch prend en charge ces fonctionnalités via Query DSL (Query Domain Specific Language). Voici quelques exemples de méthodes de requête courantes :

Requête en texte intégral

query := elastic.NewMatchQuery("content", "Elasticsearch")

Requête de correspondance multi-conditions

boolQuery := elastic.NewBoolQuery () .Must(

2. elastic.NewMatchQuery("content", "Elasticsearch"),
   elastic.NewRangeQuery("age").Gt("20"),

)

range query

rangeQuery := elastic.NewRangeQuery("age").Gt("20").Lt("30")

requête floue

fuzzyQuery : = elastic.NewFuzzyQuery("content", "Elasticsearch").

4. Fuzziness(2).
   PrefixLength(1)
   

sort

sort := elastic.NewFieldSort("age").Asc()
5. searchResult, err := client.Search() .

Index("users").
Query(boolQuery).
SortBy(sort).
Do(context.Background())

Bien sûr, dans la pratique, nous utiliserons des méthodes de requête plus complexes et plus flexibles pour obtenir les données dont nous avons besoin.

5. Pagination et agrégation

Lors de l'exécution d'une requête de données, nous devons souvent afficher les données sous forme de pagination et effectuer une requête d'agrégation. Elasticsearch fournit également des méthodes de requête qui prennent en charge ces opérations. Voici quelques exemples de requêtes courants :

Page query

searchResult, err := client.Search().

1. Index("users").
   Query(boolQuery).
   From(0).Size(10).
   Do(context.Background())
   

Parmi eux, la méthode From() est utilisée pour définir la position de départ de la requête et la taille () est utilisée. Utilisée pour définir le nombre d'éléments de données renvoyés.

2. 聚合查询

ageAggs := elastic.NewTermsAggregation().Field("age")
searchResult, err := client.Search().

Index("users").
Query(boolQuery).
Aggregation("age_group", ageAggs).
Do(context.Background())

其中，我们使用了 Elastic 中的 NewTermsAggregation() 方法和 Aggregation() 方法来创建聚合查询。在这个示例中，我们以 "age" 字段作为聚合查询的依据。

六、总结
在本文中，我们介绍了如何在 Go 语言中使用 Elasticsearch 构建一个高效的搜索系统。从连接 Elasticsearch 开始，我们讲解了基础查询、进阶查询、分页和聚合查询等多种查询方式，以及如何使用 Elasticsearch 去提高我们的搜索效率，并给出了部分示例代码。通过阅读本文，您应该可以对 Go 和 Elasticsearch 之间的集成有一个更加深入的理解，应用于实际项目开发中去构建高效的搜索系统。

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!