NiFi 표현식

NiFi 는 표현식이 있다. 이를 통하여 파일이름이나, 경로 등을 가져올 수 있고 이를 파싱, 대소 구분 등을 할 수 있다.

자세한 내용은 아래 아파치 문서를 통하여 확인 할 수 있다.

예제

FTP 로 데이터를 가져오는 경우를 예로 들어본다.

처음 원천에서 데이터를 가져올 때는 ListFTP 프로세서를 활용하여 데이터를 가져온다.

username, password, hostname, Port, Remote Path, Search Recursively 등을 기입 한 후 FetchFTP를 등록하여 연결하여 준다. 마찬가지로 속성을 적어 넣은 후 PutFile 을 통하여 데이터를 넣어준다.

이 때 PutFile의 Directory를 어떻게 입력해주느냐인데, 원천과 같은 디렉터리 구조를 가져오기 위해서는 아래와 같은 변수와 로컬 경로를 조합하여 입력해 준다.

LocalPath(ex. /tmp/img)/${path}