节点 Ingest Elasticsearch

Parfois, nous devons indexer le document avant de le convertir. Par exemple, nous devons supprimer un champ du document ou renommer un champ, puis l'indexer. Cela est traité par le nœud Ingest.

Chaque nœud du cluster a la fonction d'extraction, mais peut également être personnalisé pour être traité uniquement par des nœuds spécifiques.

Étape

Le travail du nœud d'ingestion implique deux étapes-

• Créer un pipeline

• Créer un fichier

Créer un pipeline

Tout d'abord, créez un pipeline contenant des processeurs, puis exécutez ce pipeline, comme suit-

PUT _ingest/pipeline/int-converter
{
　　　"description" : "convertit le contenu du champ seq en entier"
　　　"processors" : [
　　　　　　{
　　　　　　　　　"convert" : {
　　　　　　　　　　　　"field" : "seq",
　　　　　　　　　　　　"type" : "integer"
　　　　　　　　　}
　　　　　　}
　　　]
}

在运行上面的代码时，我们得到以下结果-

{
　　　"acknowledged" : true
}

Créer un fichier

Ensuite, nous utilisons le convertisseur de tuyau pour créer un document.

PUT　/logs/_doc/1?pipeline=int-converter
{
　　　"seq":"21",
　　　"name":"w"3codebox",
　　　"Addrs":"Hyderabad"
}

Après avoir exécuté le code ci-dessus, nous obtenons la réponse suivante

{
　　　"_index"　:　"logs",
　　　"_type"　:　"_doc",
　　　"_id"　:　"1",
　　　"_version"　:　1,
　　　"result" : "created",
　　　"_shards" : {
　　　　　　"total" :　2,
　　　　　　"successful" :　1,
　　　　　　"failed" : 0
　　　},
　　　"_seq_no" : 0,
　　　"_primary_term"　:　1
}

Ensuite, nous utilisons la commande GET pour rechercher le document créé précédemment, comme suit-

GET　/logs/_doc/1

在运行上面的代码时，我们得到以下结果-

{
　　　"_index"　:　"logs",
　　　"_type"　:　"_doc",
　　　"_id"　:　"1",
　　　"_version"　:　1,
　　　"_seq_no" : 0,
　　　"_primary_term"　:　1,
　　　"found"　:　true",
　　　"_source"　:　{
　　　　　　"Addrs" : "Hyderabad",
　　　　　　"name" : "w"3codebox",
　　　　　　"seq" :　21
　　　}
}

Vous pouvez le voir ci-dessus21devient un entier.

Sans tuyau

Maintenant, nous pouvons créer des documents sans utiliser de tuyau.

PUT　/logs/_doc/2
{
　　　"seq":"11",
　　　"name":"Tutorix",
　　　"Addrs":"Secunderabad"
}
GET　/logs/_doc/2

在运行上面的代码时，我们得到以下结果-

{
　　　"_index"　:　"logs",
　　　"_type"　:　"_doc",
　　　"_id"　:　"2",
　　　"_version"　:　1,
　　　"_seq_no"　:　1,
　　　"_primary_term"　:　1,
　　　"found"　:　true",
　　　"_source"　:　{
　　　　　　"seq"　:　"11",
　　　　　　"name"　:　"Tutorix"
　　　　　　"Addrs"　:　"Secunderabad"
　　　}
}

您可以在上面看到11是一个不使用管道的字符串。