Apache NiFi-흐름 생성
Apache NiFi는 개발자가 모든 유형의 프로토콜 또는 데이터 소스에 대한 데이터 흐름을 만들 수 있도록 많은 구성 요소를 제공합니다. 흐름을 만들기 위해 개발자는 메뉴 모음에서 캔버스로 구성 요소를 드래그하고 한 구성 요소에서 다른 구성 요소로 마우스를 클릭하고 드래그하여 연결합니다.
일반적으로 NiFi에는 소스 시스템에서 데이터를 가져 오는 getfile과 같은 흐름의 시작 부분에 리스너 구성 요소가 있습니다. 다른 쪽 끝에는 putfile과 같은 송신기 구성 요소가 있으며 그 사이에는 데이터를 처리하는 구성 요소가 있습니다.
예를 들어 한 디렉터리에서 빈 파일을 가져와 해당 파일에 텍스트를 추가하고 다른 디렉터리에 넣는 흐름을 만듭니다.
먼저 프로세서 아이콘을 NiFi 캔버스로 드래그하고 목록에서 GetFile 프로세서를 선택합니다.
다음과 같은 입력 디렉토리를 만듭니다. c:\inputdir.
프로세서를 마우스 오른쪽 버튼으로 클릭하고 구성을 선택하고 속성 탭에서 추가 Input Directory (c:\inputdir) 적용을 클릭하고 캔버스로 돌아갑니다.
프로세서 아이콘을 캔버스로 드래그하고 목록에서 ReplaceText 프로세서를 선택합니다.
프로세서를 마우스 오른쪽 버튼으로 클릭하고 구성을 선택합니다. 에서properties 탭, 다음과 같은 텍스트 추가 “Hello tutorialspoint.com” 대체 값의 텍스트 상자에서 적용을 클릭하십시오.
설정 탭으로 이동하여 오른쪽의 실패 확인란을 선택한 다음 캔버스로 돌아갑니다.
성공 관계에서 GetFIle 프로세서를 ReplaceText에 연결합니다.
프로세서 아이콘을 캔버스로 드래그하고 목록에서 PutFile 프로세서를 선택합니다.
다음과 같은 출력 디렉토리를 만듭니다. c:\outputdir.
프로세서를 마우스 오른쪽 버튼으로 클릭하고 구성을 선택합니다. 속성 탭에서Directory (c:\outputdir) 적용을 클릭하고 캔버스로 돌아갑니다.
설정 탭으로 이동하여 오른쪽의 실패 및 성공 확인란을 선택한 다음 캔버스로 돌아갑니다.
ReplaceText 프로세서를 성공 관계에 PutFile에 연결하십시오.
이제 흐름을 시작하고 입력 디렉터리에 빈 파일을 추가하면 출력 디렉터리로 이동하고 텍스트가 파일에 추가됩니다.
위의 단계에 따라 개발자는 프로세서 및 기타 NiFi 구성 요소를 선택하여 조직 또는 클라이언트에 적합한 흐름을 만들 수 있습니다.