Загрузка файла в корзину S3 с использованием библиотеки SFTP Jsch

Question

Я получаю исключение при загрузке документа по каналу SFTP с использованием библиотеки jsch в корзину S3. Я знаю, что он работает через тот же ключ и детали в Filezilla / cyberduck, но не java. Может кто-то указать, что я пропускаю?

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;

public class TestSSHUpdloadFile {
    public static void main(String[] args) throws Exception {

        JSch jsch = new JSch();
        String privateKey = "/Users/Documents/SFTP/sftprivate_key";
              Session session = null;
              try {
                  jsch.addIdentity(privateKey, "Passphrase");
                  session = jsch.getSession("User", "sftp.aws.com", 22);
                  session.setConfig("StrictHostKeyChecking", "no");
                  //session.setPassword("Passphrase");
                  session.connect();

                  Channel channel = session.openChannel("sftp");
                  channel.connect();
                  ChannelSftp sftpChannel = (ChannelSftp) channel;
                  sftpChannel.put("/Users/Documents/Temp1.csv", "/mys3bucket/Temp1.csv");  
                  sftpChannel.exit();
                  session.disconnect();
              } catch (JSchException e) {
                  e.printStackTrace();  
              } catch (SftpException e) {
                  e.printStackTrace();
              }

       }
}

Ниже приведено исключение

com.jcraft.jsch.JSchException: USERAUTH fail
    at com.jcraft.jsch.UserAuthPublicKey.start(UserAuthPublicKey.java:119)
    at com.jcraft.jsch.Session.connect(Session.java:470)
    at com.jcraft.jsch.Session.connect(Session.java:183)
    at TestS3.TestSSHUpdloadFile.main(TestSSHUpdloadFile.java:21)

Answer 1

вам нужно использовать inputStream, чтобы получить файл с сервера и поместить его снова, в моем случае я использовал текущий код, я не использовал номер порта для аутентификации:

private ChannelSftp setupJsch(String host, String username, String password) {

        JSch jsch = new JSch();
        //jsch.setKnownHosts(knownHosts);

        Session jschSession;
        try {
            jschSession = jsch.getSession(username, host);
            jschSession.setPassword(password);

            //extra config code
            java.util.Properties config = new java.util.Properties(); 
            config.put("StrictHostKeyChecking", "no");
            jschSession.setConfig(config);


            jschSession.connect();
            return (ChannelSftp) jschSession.openChannel("sftp");
        } catch (JSchException e) {
        }
    return null;
    }   
private InputStream getInputStream(String host,
            String username, String password,String pdfFromIN) {
        InputStream in = null;
        ChannelSftp channelSftp;
        try {
            channelSftp = setupJsch(host, username, password);
            channelSftp.connect();
            in=channelSftp.get(pdfFromIN);
        } catch (JSchException |SftpException e) {

        }
        //channelSftp.exit();
        return in;
    }


    private void putFile(String host,
            String username, String password,InputStream in,String desFileRepo){

        ChannelSftp channelSftp;
        try {
            channelSftp = setupJsch(host, username, password);
            channelSftp.connect();
            channelSftp.put(in, desFileRepo);
            channelSftp.exit();
        } catch (JSchException |SftpException e) {
;

        }
    }