FetchSFTP 2025.10.9.21 — SFTP 파일 가져오기 프로세서

FetchSFTP 2025.10.9.21 — SFTP 파일 가져오기 프로세서

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

출처: Snowflake 문서

본문

기능 — 일반 공개 (Generally Available)

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

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

Bundle

org.apache.nifi | nifi-standard-nar

Description

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

Tags

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

Input Requirement

REQUIRED

Supports Sensitive Dynamic Properties

false

Properties

Property Description
Algorithm Negotiation SSH 알고리즘 협상에 대한 구성 전략
Ciphers Allowed SFTP 연결에 허용되는 Cipher의 쉼표로 구분된 목록. 모두 허용하려면 설정하지 않은 채로 두세요. 사용 가능한 옵션: 3des-cbc, aes128-cbc, aes128-ctr, [email protected], aes192-cbc, aes192-ctr, aes256-cbc, aes256-ctr, [email protected], arcfour128, arcfour256, blowfish-cbc, [email protected], none
Completion Strategy 파일이 NiFi로 가져와진 후 서버의 원본 파일을 어떻게 처리할지 지정해요. Completion Strategy가 실패하면 경고가 기록되지만 데이터는 여전히 전송돼요
Connection Timeout 연결을 만드는 동안 시간 초과되기 전에 기다리는 시간
Create Directory 'Completion Strategy'가 'Move File'일 때 사용돼요. 원격 디렉터리가 존재하지 않으면 생성할지 여부를 지정해요
Data Timeout 로컬과 원격 시스템 사이에서 파일을 전송할 때, 두 시스템 사이에 데이터가 전송되지 않은 채 경과할 수 있는 시간을 지정해요
Disable Directory Listing 'Completion Strategy'가 'Move File'이고 'Create Directory'가 활성화됐을 때 'Move Destination Directory'를 만드는 방법을 제어해요. 'true'로 설정하면 누락된 디렉터리를 만들기 전에 디렉터리 목록 조회를 수행하지 않아요. 기본적으로 이 프로세서는 누락된 디렉터리를 만들기 전에 대상 디렉터리 존재 여부를 확인하기 위해 디렉터리 목록 명령을 실행해요. 하지만 다음과 같은 상황에서는 디렉터리 목록 조회를 비활성화해야 할 수도 있어요. 일부 권한 설정(예: chmod 100)에서는 디렉터리 목록 조회가 실패할 수 있어요. 또한 이 프로세서가 목록 조회를 수행한 뒤, 이 프로세서의 디렉터리 생성 요청이 완료되기 전에 다른 SFTP 클라이언트가 디렉터리를 만들면, 디렉터리가 이미 존재하므로 오류가 반환돼요
Host Key File 제공되면 그 파일이 Host Key로 사용돼요. 그렇지 않으면 'Strict Host Key Checking' 속성이 적용(true로 설정)될 때 ~/.ssh 디렉터리의 'known_hosts'와 'known_hosts2' 파일을 사용하고, 그 외에는 호스트 키 파일을 사용하지 않아요
Hostname 데이터를 가져올 호스트의 전체 자격을 갖춘 호스트 이름 또는 IP 주소
Key Algorithms Allowed SFTP 연결에 허용되는 Key Algorithm의 쉼표로 구분된 목록. 모두 허용하려면 설정하지 않은 채로 두세요. 사용 가능한 옵션: ecdsa-sha2-nistp256, [email protected], ecdsa-sha2-nistp384, [email protected], ecdsa-sha2-nistp521, [email protected], rsa-sha2-256, [email protected], rsa-sha2-512, [email protected], «redacted:sk-…»@openssh.com, «redacted:sk-…»@openssh.com, ssh-dss, [email protected], ssh-ed25519, [email protected], ssh-rsa, [email protected]
Key Exchange Algorithms Allowed SFTP 연결에 허용되는 Key Exchange Algorithm의 쉼표로 구분된 목록. 모두 허용하려면 설정하지 않은 채로 두세요. 사용 가능한 옵션: curve25519-sha256, [email protected], curve448-sha512, diffie-hellman-group-exchange-sha1, diffie-hellman-group-exchange-sha256, diffie-hellman-group1-sha1, diffie-hellman-group14-sha1, diffie-hellman-group14-sha256, diffie-hellman-group15-sha512, diffie-hellman-group16-sha512, diffie-hellman-group17-sha512, diffie-hellman-group18-sha512, ecdh-sha2-nistp256, ecdh-sha2-nistp384, ecdh-sha2-nistp521, mlkem1024nistp384-sha384, mlkem768nistp256-sha256, mlkem768x25519-sha256, sntrup761x25519-sha512, [email protected]
Log Level When File Not Found 프로세서가 트리거될 때 파일이 존재하지 않는 경우 사용할 로그 수준
Message Authentication Codes Allowed SFTP 연결에 허용되는 Message Authentication Code의 쉼표로 구분된 목록. 모두 허용하려면 설정하지 않은 채로 두세요. 사용 가능한 옵션: hmac-md5, hmac-md5-96, hmac-sha1, hmac-sha1-96, [email protected], hmac-sha2-256, [email protected], hmac-sha2-512, [email protected]
Move Destination Directory 파일이 NiFi로 수집된 후 원본 파일을 이동할 원격 서버의 디렉터리예요. Completion Strategy가 'Move File'로 설정되지 않으면 이 속성은 무시돼요. 'Create Directory'가 비활성화된 경우 지정된 디렉터리는 원격 시스템에 이미 존재해야 하며, 그렇지 않으면 이름 변경(rename)이 실패해요
Password 사용자 계정의 비밀번호
Port 데이터를 가져올 원격 호스트에서 연결할 포트
Private Key Passphrase 개인 키의 비밀번호
Private Key Path 개인 키 파일의 전체 자격을 갖춘 경로
Remote File 원격 시스템의 전체 자격을 갖춘 파일 이름
Send Keep Alive On Timeout 25초의 전체 시간 초과를 위해 5초마다 최대 5번 Keep Alive 메시지를 전송해요
Strict Host Key Checking 호스트 키를 엄격하게 적용할지 여부를 나타내요
Use Compression 파일을 전송할 때 ZLIB 압축을 사용할지 여부를 나타내요
Username 사용자 이름
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
sftp.remote.host 파일을 가져온 호스트 이름 또는 IP 주소
sftp.remote.port 원격 SFTP 서버와 통신하는 데 사용된 포트
sftp.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 SFTP Server
SFTP 서버의 디렉터리에 있는 모든 파일을 가져와요

See also

더 알아보기 (Learn more)