Apache NiFi-맞춤형 프로세서
Apache NiFi는 오픈 소스 플랫폼이며 개발자에게 NiFi 라이브러리에 맞춤형 프로세서를 추가 할 수있는 옵션을 제공합니다. 다음 단계에 따라 사용자 지정 프로세서를 만듭니다.
아래 링크에서 Maven 최신 버전을 다운로드하십시오.
https://maven.apache.org/download.cgi
M2_HOME이라는 환경 변수를 추가하고 값을 maven의 설치 디렉터리로 설정합니다.
아래 링크에서 Eclipse IDE를 다운로드하십시오.
https://www.eclipse.org/downloads/download.php
명령 프롬프트를 열고 Maven Archetype 명령을 실행합니다.
> mvn archetype:generate
원형 프로젝트에서 nifi 유형을 검색하십시오.
org.apache.nifi : nifi-processor-bundle-archetype 프로젝트를 선택합니다.
그런 다음 버전 목록에서이 자습서의 최신 버전, 즉 1.7.1을 선택합니다.
groupId, artifactId, 버전, 패키지 및 artifactBaseName 등을 입력하십시오.
그런 다음 디렉토리가있는 메이븐 프로젝트가 생성됩니다.
nifi-<artifactBaseName>-processors
nifi-<artifactBaseName>-nar
nifi- <artifactBaseName> -processors 디렉토리에서 아래 명령을 실행하여 Eclipse에 프로젝트를 추가하십시오.
mvn install eclipse:eclipse
eclipse를 열고 파일 메뉴에서 가져 오기를 선택하십시오.
그런 다음“Existing Projects into workspace”를 선택하고 eclipse의 nifi- <artifactBaseName> -processors 디렉토리에서 프로젝트를 추가하십시오.
프로세서가 실행되도록 예약 될 때마다 실행되는 public void onTrigger (ProcessContext context, ProcessSession session) 함수에 코드를 추가합니다.
그런 다음 아래 언급 된 명령을 실행하여 코드를 NAR 파일로 패키징합니다.
mvn clean install
nifi-에서 NAR 파일이 생성됩니다.
-nar / target 디렉토리. NAR 파일을 Apache NiFi의 lib 폴더에 복사하고 NiFi를 다시 시작합니다.
NiFi를 성공적으로 다시 시작한 후 프로세서 목록에서 새 사용자 지정 프로세서를 확인하십시오.
오류가 있으면 ./logs/nifi.log 파일을 확인하십시오.