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