빅데이터/Apache Nifi / / 2023. 12. 21. 09:46

Nifi Database 03. Relationships 설명

NiFI의 Relationships 설명입니다.

 

각 프로세서에는 데이터를 전송할 수 있는 정의된 "Relationships" 집합이 있습니다.

프로세서가 FlowFile 처리를 완료하면 해당 FlowFile을 다른 Relationships 중 하나로 전송합니다.

이는 처리 결과에 따라 사용자가 구성할 수 있습니다.

Relation 설정

 

대부분 프로세서들은 성공(success)과 실패(failure) 두 가지로 정의합니다.

 

Relation 성공(success) and 실패(failure)

 

프로세서간 일반적인 Relation 말고도 프로세스 그룹간 데이터를 전송하는 입력 포트와 출력포트도 있습니다.

 

입력 포트(Input Port) :  입력 포트는 데이터를 프로세스 그룹으로 전송하는 메커니즘을 제공합니다. 입력 포트를 캔버스에 끌어다 놓을 때 DFM은 포트에 이름을 지을 것을 요청받습니다. 프로세스 그룹 내의 모든 포트는 고유한 이름을 가져야 합니다.

출력 포트(Output Port) :  출력 포트는 프로세스 그룹 외부로 데이터를 전송하는 메커니즘을 제공합니다. 이하 입력 포트와 같습니다.

 

 

실제 구성사례는 아래 이미지처럼 구성 할 수있으며 예제 템플릿에서 로그관리를 위해 사용하였습니다.

 

 

이외에 아래와 같이 퍼널도 있는데 이번 설명에서는 생략하겠습니다.


 

퍼널(Funnel) :  퍼널은 여러 커넥션으로부터 나온 데이터를 하나의 커넥션으로 합치는 데 사용됩니다. 여러 커넥션의 데이터를 하나의 커넥션으로 퍼널링함으로써 해당 단일 커넥션의 모든 데이터를 우선순위를 정할 수 있게 되며, 각각의 커넥션을 독립적으로 우선순위를 정하는 것보다 효율적입니다.

  • 네이버 블로그 공유
  • 네이버 밴드 공유
  • 페이스북 공유