Nifi Text
1. ExtractText Regex를 이용해 검색된 문자를 추출한다. [사용자 Attribute] + . + [Regex의 Capturing Group 순번] 형태의 Dynamic Attribute를 생성해서 찾아진 값에 매핑한다. 사용자 Attribute가 “regex”이...
최근 포스트
Nifi Log
1. LogAttribute FlowFile 정보를 NiFi 로그 파일($NIFI_HOME/logs/nifi-app.log)에 출력
Nifi Kafka
1. ConsumeKafka Kafka Topic을 Consume한다
Nifi Json
1. JsonTreeReader와 JsonPathReader의 차이 JsonTreeReader는 전체 JSON을 레코드로 읽거나 최상위 배열의 경우 배열의 각 요소를 (전체적으로) 레코드로 읽습니다. JsonPathReader를 사용하면 전체 흐름 파일 내의 특정 개체 / 레...
Nifi HDFS
1. PutHDFS flowFile을 HDFS로 저장한다
Nifi File
1. GenerateFlowFile 임의의 FlowFile을 한 개씩 1 Byte 문자로 생성하라는 의미이다.
Nifi Execute
1. ExecuteStreamCommand ** 외부 프로세서를 실행시키고 외부 프로세서가 받는 STDIN으로 FlowFile의 Contents를 넘겨주는 작업 Python script 실행. 특적 Directory의 파일을 하나씩 전달하는 것으로 보임.
Nifi DB
1. ConvertJsonToSQL Json을 SQL DML문으로 변환하다
Nifi Controller
1. DBCPConnectionPool Database 연결
Nifi Cluster
1. Sub Project