Elasticsearch Ingest 노드

때로는 문서를 변환하기 전에 인덱싱이 필요할 때가 있습니다. 예를 들어, 문서에서 필드를 제거하거나 이름을 변경한 후 인덱싱을 하고 싶을 때 이를 Ingest 노드가 처리합니다.

클러스터의 각 노드는 추출 기능을 가지고 있지만, 특정 노드만 처리할 수 있도록 설정할 수도 있습니다.

단계

Ingest 노드의 작업은 두 단계로 이루어집니다-

• 파이프라인 생성

• 파일을 만들기

파이프라인 생성

처음으로 처리기가 포함된 파이프라인을 생성한 다음, 그 파이프라인을 실행하는 방법입니다.-

PUT　_ingest/pipeline/int-converter
{
　　　"description":　"converts　the　content　of　the　seq　field　to　an　integer",
　　　"processors"　:　[
　　　　　　{
　　　　　　　　　"convert"　:　{
　　　　　　　　　　　　"field"　:　"seq",
　　　　　　　　　　　　"type":　"integer"
　　　　　　　　　}
　　　　　　}
　　　]
}

위의 코드를 실행할 때, 다음과 같은 결과를 얻습니다-

{
　　　"acknowledged"　:　true
}

파일을 만들기

다음은, 파이프라인 변환기로 문서를 생성하는 방법입니다.

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

위의 코드를 실행하면 다음과 같은 응답을 받습니다:

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

다음은, 위에 생성한 문서를 GET 명령으로 검색하는 방법입니다.-

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
　　　}
}

위에서 볼 수 있습니다21정수로 변환됩니다.

파이프라인 없음

지금, 파이프라인 없이 문서를 생성할 수 있습니다.

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파이프를 사용하지 않는 문자열입니다.