[NiFi] Elasticsearch 와 연동하는 flow 작성

 

여기서 설명하는 flow 에선

 

GenerateFlowFile 에서 생성한 flowfile 의 attribute 를 json 으로 만들고,

 

그것을 elasticsearch 에 넣는다.

 

아래 flow 를 따라 만들면 된다.

 

 

< 전체 flow >

 

 

< AttributeToJson >

 

uuid 외에 filename, custom attribute 등 다른 attribute 값을 넣고싶다면,

Attributes List 와 Attributes Regular Expression 에 넣으면 됨.

물론 Regular Expression 을 통해 함수 등을 마음대로 넣어도 됨

 

 

 

< PutElasticsearchHttp >

이 스샷을 찍는 당시 local 에 elasticsearch 를 설치하여 연결시켰기 때문에 localhost 에 연결함.

 

아래처럼 index 와 type 도 예쁘게 적어준다.

 

 

이렇게 세팅하고 연결시 timeout 이 난다면, 서버와 통신이 안 되는 것

telnet 등을 통해 통신이 잘 되는지 먼저 체크하자