nifi 예제

팁: 매월 첫 번째 에 시간 바인딩된 전류-nifi 상태 Elasticsearch 인덱스를 자동으로 롤오버-NiFi_Status_Elasticsearch_Index.xml 템플릿을 흐름에 드래그하고 프로세서에서 호스트 이름을 구성하고 모든 프로세서. 이 예제에서는 CSV 파일을 사용하여 Kafka에 게시합니다. 우리는 우리의 환경을 설정하기 위해 docker를 사용할 것입니다. 다음 내용을 docker-compose.yml에 복사하고 docker-compose -d를 실행합니다. 경우에 따라 사용자가 다른 FlowFile에서 스폰된 원래 FlowFile을 추적해야 할 수 있습니다. 예를 들어 FORK 또는 CLONE 이벤트가 발생하면 NiFi는 다른 FlowFiles를 생성한 상위 FlowFile을 추적하고 리니지에서 해당 부모 FlowFile을 찾을 수 있습니다. 계보 그래프에서 이벤트를 마우스 오른쪽 버튼으로 클릭하고 컨텍스트 메뉴에서 „부모 찾기“를 선택합니다. 이름: 프로세스 그룹의 사용자 정의 이름입니다. 이 이름은 프로세스 그룹이 캔버스에 추가될 때 설정됩니다. 나중에 프로세스 그룹을 마우스 오른쪽 단추로 클릭하고 „구성“ 메뉴 옵션을 클릭하여 이름을 변경할 수 있습니다. 이 예제에서 프로세스 그룹의 이름은 „프로세스 그룹 ABC“입니다. Out: 프로세서가 아웃바운드 연결로 전송한 데이터의 양입니다.

여기에는 프로세서가 자체적으로 제거하는 FlowFiles 또는 자동 종료된 연결로 라우팅되는 FlowFiles가 포함되지 않습니다. 위의 „In“ 메트릭과 마찬가지로 이 값은 아웃바운드 연결로 전송된 FlowFiles 수와 해당 FlowFiles 콘텐츠의 총 크기인 ()로 표시됩니다. 이 예제에서는 모든 관계가 자동으로 종료되도록 구성되므로 전송된 것으로 보고된 FlowFiles가 없습니다. NiFi가 NiFi 레지스트리에 연결되면 데이터 흐름은 프로세스 그룹 수준에서 버전 제어될 수 있습니다. NiFi 레지스트리 사용 및 구성에 대한 자세한 내용은 https://nifi.apache.org/docs/nifi-registry-docs/index.html 설명서를 참조하십시오. 표시된 예제에서는 버전이 있는 흐름이 이전 버전에서 최신 버전으로 업그레이드됩니다.