Nifi Processor 생성

- 해당 문서는 Getting Started with Apache Nifi 문서를 보고 실제로 Process를 실행해본 예제입니다. 

 

NiFi Processor 등록 및 연결

• NiFi는 Processor 등록부터 시작합니다. 데이터의 시작과 종료를 모두 Processor로 수행하므로 가장 많이 사용하는 기본 기능입니다.
• Processor 등록을 위해서는 Component Toolbar의 Processor 아이콘()을 선택하여, 드래그하여 캔버스의 원하는 위치에 놔두면(드롭) 아래와 같은 추가할 Processor를 검색할 수 있습니다.

Add Processor 화면

• 원하는 Processor를 필터에 입력하여 찾을 수 있으며, 옆에 Tag Cloud를 통해 Processor들을 분류할 수도 있습니다. (이 때 직접 생성한 Processor 그룹을 선택할 수 있도 있습니다.)
• 사용할 Processor를 테이블에서 선택하고, ADD 버튼을 눌러 등록할 수 있습니다. 

• Processor 설정은 해당 Processor를 더블클릭하면 됩니다. 저는 GetFile → PutFile 프로세스를 예시로 등록해보겠습니다.
• GetFile 설정을 보면 아래와 같습니다. 크게는 SETTINGS, SCHEDULING, PROPERTIES, COMMENTS 메뉴로 나눌 수 있습니다.

• 주로 사용되는 PROPERTIES 메뉴를 중심으로 설명해보겠습니다.
• GetFile PROPERTIES 는 다음과 같습니다.
• Property, Value로 나뉘어져 있으며, 속성옆에 ? 아이콘에 마우스를 갖다대면 해당 속성의 설명을 볼 수 있습니다.
• 참고로 굵은 글씨로 설정된 Property는 필수 값 입니다.

• PutFile PROPERTIES는 다음과 같습니다.

• 설정을 하려면, APPLY를 눌러 설정을 저장할 수 있습니다.
• process 폴더에 다음의 text 파일을 만들어보겠습니다.

• GetFile과 PutFile process를 실행시켜보겠습니다. (프로세스를 실행시 초록색 실행아이콘을 클릭하여 process를 실행시킬 수 있습니다.)

-

• 해당 Que가 쌓인것을 확인해보겠습니다. 오른쪽 마우스 → List queue 선택 후 → 왼쪽 상단의  i 아이콘을 클릭하면 다음의 FlowFile Attributes 를 확인할 수 있습니다.

• 나머지 PutFile 프로세스까지 실행시켜보겠습니다.

• process 디렉토리에 파일이 사라졌으며 result 디렉토리에 test.txt 파일이 생성된 것을 확인할 수 있습니다.

참고

• 보다 자세한 내용은 http://nifi.apache.org/docs/nifi-docs/html/getting-started.html 를 참고하시면 됩니다. (이 공식문서는 Nifi에서 기본적으로 설치, 기능 등에 대한 내용들이 상세히 적혀있습니다.)