[Apache Nifi]ListenHttp 프로세서 알아보기

ListenHttp란?

• Listen = 듣다, Http = 웹 프로토콜 → 즉, http가 호출 되는지 듣는 Processor이다.
• ListenHttp Processor를 활용하면, http에 보내준 xml, json데이터를 활용하여 다른 Processor들이나 로직을 실행 시킬 수 있다.

준비 사항 

• 먼저 열려져있는 ip주소가 있어야함(자기자신 주소(ip나 도메인)로 설정하면 됨)
• ListenHttp에서 사용할 Port가 있어야함

실행 순서 

1. ListenHttp 프로세서 만들기
2. ListenHttp 프로세서 properties(주소명칭, 포트번호)를 설정
3. 실행 내용 테스트 해보기

 

1. ListenHttp 프로세서 만들기

 

 

2. ListenHttp 프로세서 properties(주소명칭, 포트번호)를 설정

• 1번은 http://<ip or domain>/’Base Path’ ← 이렇게 설정 할 수 있도록 해주는 것이다. 아래와 같이 contentListener라고 설정이 되어있으면, http://<ip or domain>/contentListener라고 http가 호출이 되는 것을 인식한다는 것이다.
• 또한 port를 설정을 하면 http://<ip or domain>:’Listening Port’/’Base Path’ 로 설정이 된다. Listening Port를 9999로 설정을 했다면, http://<ip or domain>:9999/contentListener 로 http 호출 되는 것을 주의 하고 있다는 것

•  

• 최종적으로 아래와 같이 설정을 하였다. 아래와 같이 설정을 하면 Listening하고 있는 http주소는
• http://<ip or domain>:9999이다.

• 설정이 끝났으면 postman으로 한번 body와 같이 http를 날려보면 알 수 있다.

ListenHttp를 실행 시켜 주면 Task의 숫자가 3 ,6,10 이렇게 올라가면 정상적으로 Linstening을 하고 있는 것이다. processor를 실행 시켜주고 Postman으로 날려 보면

 

 

 

3. 실행 내용 테스트하기

Listen을 하는지 확인 할려면은 http로 호출을 해야하며 Body와 같이 날려 볼려면 Post를 사용해야한다는 것을 알아 두면 좋다.

Success에 queue가 들어온것을 볼 수 있고 content를 확인 해보면, 위에 postman에서 보낸 json데이터가 들어 온것을 확인 할 수 있다.

ListenHttp로 외부에서 접근을 해 개별적인 그룹이나 해당 개별 로직을 실행 하는데 사용하면 될 것 같다.