ListSFTP 2025.10.2.19¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
SFTP 서버에 있는 파일 목록을 수행합니다. 원격 서버에서 발견되는 각 파일에 대해 파일 이름 특성이 원격 서버의 파일 이름으로 설정된FlowFile이 새로 생성됩니다. 그런 다음 FetchSFTP 와 함께 사용하여 해당 파일을 가져올 수 있습니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
알고리즘 협상 |
SSH 알고리즘 협상을 위한 구성 전략 |
암호화 허용됨 |
A comma-separated list of Ciphers allowed for SFTP connections. Leave unset to allow all. Available options are: 3des-cbc, aes128-cbc, aes128-ctr, aes128-gcm@openssh.com, aes192-cbc, aes192-ctr, aes256-cbc, aes256-ctr, aes256-gcm@openssh.com, arcfour128, arcfour256, blowfish-cbc, chacha20-poly1305@openssh.com, none |
Connection Timeout |
연결을 생성하는 동안 시간이 초과되기 전에 대기할 시간(초) |
데이터 시간 제한 |
로컬 시스템과 원격 시스템 간에 파일을 전송할 때 시스템 간에 데이터가 전송되지 않고 경과할 수 있는 시간을 지정하는 값입니다 |
파일 필터 정규식 |
파일 이름을 필터링하기 위한 Java 정규식을 제공하며, 필터를 제공하면 해당 정규식과 이름이 일치하는 파일만 가져옵니다 |
호스트 키 파일 |
제공된 파일이 호스트 키로 사용되며, 그렇지 않은 경우 ‘Strict Host Key Checking’ 속성이 적용되면(true로 설정) ~/.ssh 디렉터리의 ‘known_hosts’ 및 ‘known_hosts2’ 파일을 사용하고, 그렇지 않으면 호스트 키 파일이 사용되지 않습니다 |
호스트 이름 |
원격 시스템의 정규화된 호스트 이름 또는 IP 주소입니다 |
점선 파일 무시하기 |
true이면 이름이 점(“.”)으로 시작하는 파일이 무시됩니다 |
허용되는 키 알고리즘 |
A comma-separated list of Key Algorithms allowed for SFTP connections. Leave unset to allow all. Available options are: ecdsa-sha2-nistp256, ecdsa-sha2-nistp256-cert-v01@openssh.com, ecdsa-sha2-nistp384, ecdsa-sha2-nistp384-cert-v01@openssh.com, ecdsa-sha2-nistp521, ecdsa-sha2-nistp521-cert-v01@openssh.com, rsa-sha2-256, rsa-sha2-256-cert-v01@openssh.com, rsa-sha2-512, rsa-sha2-512-cert-v01@openssh.com, sk-ecdsa-sha2-nistp256@openssh.com, sk-ssh-ed25519@openssh.com, ssh-dss, ssh-dss-cert-v01@openssh.com, ssh-ed25519, ssh-ed25519-cert-v01@openssh.com, ssh-rsa, ssh-rsa-cert-v01@openssh.com |
허용되는 키 교환 알고리즘 |
A comma-separated list of Key Exchange Algorithms allowed for SFTP connections. Leave unset to allow all. Available options are: curve25519-sha256, curve25519-sha256@libssh.org, 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, sntrup761x25519-sha512@openssh.com |
최대 파일 수명 |
파일을 가져올 수 있는 최대 기간으로, 이 기간보다 오래된 파일(마지막 수정 날짜 기준)은 무시됩니다 |
최대 파일 크기 |
파일을 가져올 수 있는 최대 크기입니다 |
허용되는 메시지 인증 코드 수 |
A comma-separated list of Message Authentication Codes allowed for SFTP connections. Leave unset to allow all. Available options are: hmac-md5, hmac-md5-96, hmac-sha1, hmac-sha1-96, hmac-sha1-etm@openssh.com, hmac-sha2-256, hmac-sha2-256-etm@openssh.com, hmac-sha2-512, hmac-sha2-512-etm@openssh.com |
최소 파일 보관 기간 |
파일을 가져오기 위해 필요한 최소 수명; 이보다 오래된 파일(마지막 수정 날짜 기준)은 무시됩니다 |
최소 파일 크기 |
파일을 가져오기 위해 필요한 최소 크기입니다 |
비밀번호 |
사용자 계정의 비밀번호 |
경로 필터 정규식 |
재귀적으로 검색이 true이면 경로가 지정된 정규식과 일치하는 하위 디렉터리만 검색됩니다 |
Port |
원격 시스템이 파일 전송을 위해 수신 대기 중인 포트입니다 |
개인 키 암호 구문 |
개인 키의 비밀번호 |
개인 키 경로 |
개인 키 파일의 정규화된 경로입니다 |
원격 경로 |
파일을 가져오거나 푸시할 원격 시스템의 경로입니다 |
재귀적으로 검색하기 |
true이면 임의로 중첩된 하위 디렉터리에서 파일을 가져오고, 그렇지 않으면 하위 디렉터리를 트래버스하지 않습니다 |
시간 제한에 맞춰 킵 얼라이브 보내기 |
전체 시간 제한 25초 동안 5초마다 최대 5회까지 연결 유지 메시지를 보낼 수 있습니다. |
엄격한 호스트 키 확인 |
호스트 키에 엄격한 적용을 적용할지 여부를 나타냅니다 |
압축 사용 |
파일을 전송할 때 ZLIB 압축을 사용할지 여부를 나타냅니다 |
사용자 이름 |
사용자 이름 |
et-initial-listing-target |
Specify how initial listing should be handled. Used by ‘Tracking Entities’strategy. |
et-state-cache |
Listed entities are stored in the specified cache storage so that this processor can resume listing across NiFi restart or in case of primary node change. ‘Tracking Entities’strategy require tracking information of all listed entities within the last ‘Tracking Time Window’. To support large number of entities, the strategy uses DistributedMapCache instead of managed state. Cache key format is ‘ListedEntities::{processorId}(::{nodeId})’. If it tracks per node listed entities, then the optional ‘::{nodeId}’ part is added to manage state separately. E.g. cluster wide cache key =’ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b’, per node cache key =’ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b::nifi-node3’ The stored cache content is Gzipped JSON string. The cache key will be deleted when target listing configuration is changed. Used by ‘Tracking Entities’strategy. |
et-time-window |
Specify how long this processor should track already-listed entities. ‘Tracking Entities’strategy can pick any entity whose timestamp is inside the specified time window. For example, if set to ‘30 minutes’, any entity having timestamp in recent 30 minutes will be the listing target when this processor runs. A listed entity is considered ‘new/updated’ and a FlowFile is emitted if one of following condition meets: 1. does not exist in the already-listed entities, 2. has newer timestamp than the cached entity, 3. has different size than the cached entity. If a cached entity ‘s timestamp becomes older than specified time window, that entity will be removed from the cached already-listed entities. Used by’Tracking Entities’strategy. |
팔로우 심볼릭 링크 |
true이면, 심볼릭 파일과 중첩된 심볼릭 하위 디렉터리도 가져오고, 그렇지 않으면 심볼릭 파일을 읽지 않고 심볼릭 링크 하위 디렉터리를 트래버스하지 않습니다 |
listing-strategy |
신규/업데이트된 엔터티를 확인하는 방법을 지정합니다. 자세한 내용은 각 전략 설명을 참조하십시오. |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
record-writer |
목록 작성에 사용할 Record Writer를 지정합니다. 지정하지 않으면 목록에 있는 각 엔터티에 대해 FlowFile 이 1개씩 생성됩니다. Record Writer를 지정하면 모든 엔터티는 개별 FlowFiles 에 특성을 추가하는 대신 단일 FlowFile 에 기록됩니다. |
target-system-timestamp-precision |
대상 시스템에서 타임스탬프 전체 자릿수를 지정합니다. 이 프로세서는 엔터티의 타임스탬프를 사용하여 목록에 추가할 엔터티를 결정하므로 타임스탬프의 올바른 전체 자릿수를 사용하는 것이 중요합니다. |
상태 관리¶
범위 |
설명 |
|---|---|
CLUSTER |
파일 목록 성능을 수행한 후 최신 파일의 타임스탬프가 저장됩니다. 이렇게 하면 프로세서가 다음에 프로세서를 실행할 때 이 날짜 이후에 추가되거나 수정된 파일만 목록에 표시할 수 있습니다. 상태는 클러스터 전체에 저장되어 이 프로세서가 기본 노드에서만 실행될 수 있으며 새 기본 노드가 선택되면 새 노드는 이전 기본 노드가 나열한 데이터를 복제하지 않습니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
수신된 모든 FlowFiles 은 성공으로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
sftp.remote.host |
SFTP 서버의 호스트 이름 |
sftp.remote.port |
SFTP 서버에서 연결된 포트 |
sftp.listing.user |
SFTP 목록을 수행한 사용자의 사용자 이름 |
file.owner |
소스 파일의 숫자 소유자 ID입니다 |
file.group |
소스 파일의 숫자 그룹 ID입니다 |
file.permissions |
소스 파일의 읽기/쓰기/실행 권한 |
file.size |
소스 파일의 바이트 수입니다 |
file.lastModifiedTime |
파일 시스템의 파일이 마지막으로 수정된 시점의 타임스탬프는 ‘yyyy-MM-dd’T’HH:mm:ssZ’ 형식으로 표시됩니다. |
파일 이름 |
SFTP 서버에 있는 파일의 이름 |
경로 |
파일을 가져온 SFTP 서버에 있는 디렉터리의 정규화된 이름입니다 |
mime.type |
구성된 Record Writer에서 제공하는 MIME 유형입니다 |