Apache NiFi-프로세서 분류

이 장에서는 Apache NiFi의 프로세스 분류에 대해 설명합니다.

데이터 수집 프로세서

데이터 수집 범주의 프로세서는 데이터를 NiFi 데이터 흐름으로 수집하는 데 사용됩니다. 이들은 주로 Apache NiFi의 모든 데이터 흐름의 시작점입니다. 이러한 범주에 속하는 프로세서 중 일부는 GetFile, GetHTTP, GetFTP, GetKAFKA 등입니다.

라우팅 및 중개 프로세서

라우팅 및 중개 프로세서는 해당 플로우 파일의 속성 또는 컨텐츠의 정보에 따라 플로우 파일을 다른 프로세서 또는 데이터 플로우로 라우팅하는 데 사용됩니다. 이러한 프로세서는 NiFi 데이터 흐름을 제어하는 역할도합니다. 이 범주에 속하는 프로세서 중 일부는 RouteOnAttribute, RouteOnContent, ControlRate, RouteText 등입니다.

데이터베이스 액세스 프로세서

이 데이터베이스 액세스 범주의 프로세서는 데이터를 선택 또는 삽입하거나 데이터베이스에서 다른 SQL 문을 실행 및 준비 할 수 있습니다. 이러한 프로세서는 주로 Apache NiFi의 데이터 연결 풀 컨트롤러 설정을 사용합니다. 이 범주에 속하는 프로세서 중 일부는 ExecuteSQL, PutSQL, PutDatabaseRecord, ListDatabaseTables 등입니다.

속성 추출 프로세서

속성 추출 프로세서는 NiFi 데이터 흐름에서 처리되는 플로우 파일 속성을 추출, 분석, 변경하는 역할을합니다. 이 범주에 속하는 프로세서 중 일부는 UpdateAttribute, EvaluateJSONPath, ExtractText, AttributesToJSON 등입니다.

시스템 상호 작용 프로세서

시스템 상호 작용 프로세서는 모든 운영 체제에서 프로세스 또는 명령을 실행하는 데 사용됩니다. 이러한 프로세서는 또한 다양한 언어로 스크립트를 실행하여 다양한 시스템과 상호 작용합니다. 이 범주에 속하는 프로세서 중 일부는 ExecuteScript, ExecuteProcess, ExecuteGroovyScript, ExecuteStreamCommand 등입니다.

데이터 변환 프로세서

Data Transformation에 속한 프로세서는 플로우 파일의 내용을 변경할 수 있습니다. 사용자가 HTTP 프로세서를 호출하기 위해 flowfile을 HTTP 본문으로 보내야 할 때 일반적으로 사용되는 flowfile의 데이터를 완전히 대체하는 데 사용할 수 있습니다. 이 범주에 속하는 프로세서 중 일부는 ReplaceText, JoltTransformJSON 등입니다.

데이터 프로세서 보내기

전송 데이터 프로세서는 일반적으로 데이터 흐름의 최종 프로세서입니다. 이러한 프로세서는 데이터를 저장하거나 대상 서버로 보내는 역할을합니다. 데이터를 성공적으로 저장하거나 전송 한 후 이러한 프로세서는 성공 관계로 플로우 파일을 삭제합니다. 이 범주에 속하는 일부 프로세서는 PutEmail, PutKafka, PutSFTP, PutFile, PutFTP 등입니다.