최근 포스트

Nifi Log

최대 1 분 소요

1. LogAttribute FlowFile 정보를 NiFi 로그 파일($NIFI_HOME/logs/nifi-app.log)에 출력

Nifi Kafka

최대 1 분 소요

1. ConsumeKafka Kafka Topic을 Consume한다

Nifi Json

1 분 소요

1. JsonTreeReader와 JsonPathReader의 차이 JsonTreeReader는 전체 JSON을 레코드로 읽거나 최상위 배열의 경우 배열의 각 요소를 (전체적으로) 레코드로 읽습니다. JsonPathReader를 사용하면 전체 흐름 파일 내의 특정 개체 / 레...

Nifi HDFS

최대 1 분 소요

1. PutHDFS flowFile을 HDFS로 저장한다

Nifi File

최대 1 분 소요

1. GenerateFlowFile 임의의 FlowFile을 한 개씩 1 Byte 문자로 생성하라는 의미이다.

Nifi Execute

1 분 소요

1. ExecuteStreamCommand ** 외부 프로세서를 실행시키고 외부 프로세서가 받는 STDIN으로 FlowFile의 Contents를 넘겨주는 작업 Python script 실행. 특적 Directory의 파일을 하나씩 전달하는 것으로 보임.

Nifi DB

최대 1 분 소요

1. ConvertJsonToSQL Json을 SQL DML문으로 변환하다

Nifi Controller

1 분 소요

1. DBCPConnectionPool Database 연결

Nifi Atributte

최대 1 분 소요

frowFile의 메타속성(Attribute) 을 다룬다.