Apache NiFi로 SQL을 던져보도록 하겠습니다.

Apache NiFi로 RDB에 SQL을 던져 결과 텍스트를 출력해 봅니다.
설치하다.
사이트 축소판 그림부터tar까지.gz나 zip 파일을 다운로드하고 압축을 풀다.
부팅
bin 디렉터리의 케이스를 실행합니다.
전형적인 예
$ nifi-0.4.1/bin/nifi.sh start
자세한 내용은 다른 사람이 쓴 이 페이지를 참고하시오.
데이터 스트리밍 툴 Apache NiFi란 무엇입니까?
JDBC 연결 설정
화면 왼쪽 상단에 있는 Controller Settings 아이콘에서 NiFi Flow Settings 대화상자를 열고 DBCPConneciton Pool을 추가합니다.
Controller Settings 아이콘

NiFi Flow Settings 대화 상자

DBCponnecitonPool 대화 상자

DBCPConnecitonPool 대화상자에서 JDBC의 4개의 점 그룹 (URL, 드라이브 클래스 이름, 사용자, 비밀번호 연결) 과jar 파일의 파일 경로를 설정하십시오.파일 경로의 시작 부분에 "file:/"가 필요합니다.
설정이 끝나면 오른쪽에 있는 번개 모양 아이콘을 클릭하여 Enabled 상태로 설정합니다.
SELECT 문을 JSON 형식으로 텍스트 파일로 내보냅니다.
계속해서 추가 Processor를 Connection으로 연결합니다.기본적인 사용법은 여기를 참고하세요.
아파치 니피로 기본 데이터 흐름 만들기?
Processor는 "ExecuteSQL""ConvertAvroToJSON""PutFile"3가지를 사용합니다.
ExecuteSQL 프로세서 추가

Database Connection Pooling Service...방금 만든 JDBC 연결

SQL select query...실행하려는 SQL의 SELECT 문구

ConvertAvroToJSON 프로세서 추가
기본값을 유지하도록 컨텐츠를 설정합니다.프로세서를 생략하고 PutFile에 ExecuteSQL을 직접 연결하면 Avro 형식의 바이너리 파일이 출력됩니다.
PutFile 프로세서 추가

Directory에서 파일의 출력 위치를 설정합니다.

Connection
Processor가 추가되면 Execute SQL에서 커넥션으로 Covert AvroToJSON, Covert AvroToJSON의 PutFile를 연결하십시오.
먼저 failuer와 success 두 곳에서 Fror relationships를 선택하십시오.
Processor 및 연결의 최종 이미지

실행
준비가 완료되면 세 Processor 모두 Start 상태가 됩니다.정상적으로 실행되면 JSON 파일은 PutFile 프로세서가 설정한 디렉토리로 출력됩니다.
TODO

이번에는 정적 SQL을 실행했지만 파라미터를 설정하고 싶습니다

확보한 데이터를 DB

로 저장