FetchFTP 2025.10.9.21 — FTP 파일 가져오기 프로세서

FetchFTP 2025.10.9.21 — FTP 파일 가져오기 프로세서

FetchFTP 프로세서는 원격 FTP 서버에서 파일 내용을 가져와 들어오는 FlowFile의 내용을 원격 파일의 내용으로 덮어써요.

출처: Snowflake 문서

본문

기능 — 일반 공개 (Generally Available)

Openflow Snowflake 배포는 AWS, Azure, GCP의 상용 리전에서 모든 계정에 제공돼요.

Openflow BYOC 배포는 AWS의 상용 리전에서 모든 계정에 제공돼요.

Bundle

org.apache.nifi | nifi-standard-nar

Description

원격 FTP 서버에서 파일 내용을 가져와 들어오는 FlowFile의 내용을 원격 파일의 내용으로 덮어써요.

Tags

fetch, files, ftp, get, ingest, input, remote, retrieve, source

Input Requirement

REQUIRED

Supports Sensitive Dynamic Properties

false

Properties

Property Description
Completion Strategy 파일이 NiFi로 가져와진 후 서버의 원본 파일을 어떻게 처리할지 지정해요. Completion Strategy가 실패하면 경고가 기록되지만 데이터는 여전히 전송돼요
Connection Mode FTP 연결 모드
Connection Timeout 연결을 만드는 동안 시간 초과되기 전에 기다리는 시간
Create Directory 'Completion Strategy'가 'Move File'일 때 사용돼요. 원격 디렉터리가 존재하지 않으면 생성할지 여부를 지정해요
Data Timeout 로컬과 원격 시스템 사이에서 파일을 전송할 때, 두 시스템 사이에 데이터가 전송되지 않은 채 경과할 수 있는 시간을 지정해요
Hostname 데이터를 가져올 호스트의 전체 자격을 갖춘 호스트 이름 또는 IP 주소
Internal Buffer Size 버퍼링된 데이터 스트림에 대한 내부 버퍼 크기를 설정해요
Log Level When File Not Found 프로세서가 트리거될 때 파일이 존재하지 않는 경우 사용할 로그 수준
Move Destination Directory 파일이 NiFi로 수집된 후 원본 파일을 이동할 원격 서버의 디렉터리예요. Completion Strategy가 'Move File'로 설정되지 않으면 이 속성은 무시돼요. 'Create Directory'가 비활성화된 경우 지정된 디렉터리는 원격 시스템에 이미 존재해야 하며, 그렇지 않으면 이름 변경(rename)이 실패해요
Password 사용자 계정의 비밀번호
Port 데이터를 가져올 원격 호스트에서 연결할 포트
Remote File 원격 시스템의 전체 자격을 갖춘 파일 이름
Transfer Mode FTP 전송 모드
Use Compression 파일을 전송할 때 ZLIB 압축을 사용할지 여부를 나타내요
Username 사용자 이름
ftp-use-utf8 파일과 파일 이름을 처리할 때 클라이언트가 UTF-8 인코딩을 사용하도록 지시해요. true로 설정하면 서버도 UTF-8 인코딩을 지원해야 해요
proxy-configuration-service 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요

Relationships

Name Description
comms.failure 통신 실패로 원격 서버에서 가져올 수 없었던 FlowFile이 이 관계로 전달돼요
not.found 원격 서버로부터 'Not Found' 메시지를 받은 FlowFile이 이 관계로 전달돼요
permission.denied 권한 부족으로 원격 서버에서 가져올 수 없었던 FlowFile이 이 관계로 전달돼요
success 받은 모든 FlowFile이 success로 라우팅돼요

Writes attributes

Name Description
ftp.remote.host 파일을 가져온 호스트 이름 또는 IP 주소
ftp.remote.port 원격 FTP 서버와 통신하는 데 사용된 포트
ftp.remote.filename 가져온 원격 파일의 이름
filename 파일 이름이 원격 파일의 이름을 가리키도록 업데이트돼요
path Remote File에 디렉터리 이름이 포함돼 있으면 그 디렉터리 이름이 'path' 속성을 사용해 FlowFile에 추가돼요
fetch.failure.reason 어떤 failure 관계로 라우팅할 때 적용된 실패 관계의 이름

Use Cases Involving Other Components

Retrieve all files in a directory of an FTP Server
FTP 서버의 디렉터리에 있는 모든 파일을 가져와요

See also

더 알아보기 (Learn more)