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 파일을 확인하십시오.