Net :: SFTP 오류

Question

Net :: SFTP를 사용하여 파일을 다운로드하려고 시도했지만 오류가 계속 발생합니다.

파일이 부분적으로 다운로드되며 단지 2.1MB이므로 엄청난 파일이 아닙니다. 나는 파일을 통해 루프를 제거하고 심지어는 단지 하나 개의 파일을 다운로드 시도와 같은 오류가있어 : 어떤 도움을 주시면 감사하겠습니다

yml = YAML.load_file Rails.root.join('config', 'ftp.yml') 
Net::SFTP.start(yml["url"], yml["username"], password: yml["password"]) do |sftp| 
    sftp.dir.glob(File.join('users', 'import'), '*.csv').each do |f| 
    sftp.download!(File.join('users', 'import', f.name), Rails.root.join('processing_files', 'download_files', f.name), read_size: 1024) 
    end 
end 

NoMethodError: undefined method close' for #<Pathname:0x007fc8fdb50ea0> from /[my_working_ap_dir]/gems/net-sftp-2.1.2/lib/net/sftp/operations/download.rb:331:in on_read'

합니다. 나는 할 수있는 모두를 google에기도했고, 그것으로 어디에도 가지 않고있다.

Answer 1

Rails.root는 Pathname 객체를 반환하지만 SFTP를 코드는 그것이 경로 이름 또는 파일 핸들을 가지고 있는지 여부를 확인하지 않는 것 같습니다 , 그냥 실행됩니다. entry.sink.close으로 실행되면 Pathnames가 닫기를 구현하지 않으므로 충돌합니다.

경로 이름은 파일과 디렉토리 경로를 조작하는 데 적합하지만 파일 핸들 대신 사용할 수 있습니다. 문자열을 반환하는 to_s을 붙일 수 있습니다. 여기

이 문서에서 download 전화의 요약입니다이 예상되는 매개 변수는 문자열이어야한다 힌트 :

내가 코드에 파고 경우가 있는지 여부를 확인합니다 의심

 
To download a single file from the remote server, simply specify both the 
remote and local paths: 

    downloader = sftp.download("/path/to/remote.txt", "/path/to/local.txt") 

매개 변수는 문자열이며, 그렇지 않은 경우 IO 핸들이라고 가정합니다.

자세한 내용은 ri Net::SFTP::Operations::Download을 참조하십시오.

---

다음은 현재 download! 코드에서 발췌 한 것입니다, 당신은 문제가 발생하는 방법을 볼 수 있습니다

def download!(remote, local=nil, options={}, &block) 
    require 'stringio' unless defined?(StringIO) 
    destination = local || StringIO.new 
    result = download(remote, destination, options, &block).wait 
    local ? result : destination.string 
end 

local는 경로 이름으로 전달했다. 코드는 전달 된 내용이 있는지 확인하지만 그 내용이 아닌지 확인합니다. 아무 것도 전달되지 않으면 IO와 비슷한 기능을 가진 것으로 가정합니다. 이는 StringIO가 메모리 내 캐싱에 제공하는 것입니다.

Answer 2

분명히 문제의 원인이었던 Rails.root.join을 사용할 수 없습니다. 파일의 일부를 다운로드하기 때문에 정말 어리 석다.

sftp.download!(File.join('users', 'import', f.name), Rails.root.join('processing_files', 'download_files', f.name)) 

에 :

가 변경

sftp.download!(File.join('users', 'import', f.name), File.join('processing_files', 'download_files', f.name))