[Apache Nifi] Mysql DB 연결하기

1. Mysql 연결 jdbc 다운로드

https://dev.mysql.com/downloads/connector/j/

홈페이지에서 환경에 맞는 jdbc를 다운로드 받아 압축파일 내에 있는 .jar 파일을 Nifi 실행 서버에 위치시킨다.

여러 노드로 클러스터링되어 있다면 모두 동일 위치에 넣어주어야 한다.

 

 

2. DBCPConnectionPool 생성

Nifi > 우클릭 > Configure > Controller Services에서 DBCPConnectionPool 추가 후 설정에서 아래의 항목을 채워주면 된다.

• Database Connection URL: jdbc:mysql://주소:port/db명
• Database Driver Class Name: com.mysql.jdbc.Driver
• Database Driver Class Name: jdbc 파일 위치
• Database User/ Password: 접속정보

추가 후 추가된 커넥션을 Enable 시켜주기 위해 번개모양 아이콘 클릭 후 Enable 시켜주어야 한다.

위: disable 상태의 서비스, 아래: enable 상태의 서비스

 

3. Processor에 적용

ExecuteSQL을 예로 들면, 아래와 같이 Database Connection Pooling Services에 위에서 설정한 커넥션풀이 리스트업된다.

원하는 서비스 선택 후 쿼리 실행 시 정상적으로 Avro Flowfile 생성되는 것을 확인할 수 있다.