| | |
| | | |
| | | def connect(self, Timeout=5): |
| | | if(not self.connected): |
| | | try: |
| | | print("Trying to connect to: "+self.username+"@"+self.hostname+":"+str(self.port)+".") |
| | | self.ssh.connect(self.hostname, username=self.username, password=self.password, port=self.port, timeout=Timeout) |
| | | self.connected=True |
| | | except: |
| | | print("Error establishing connection with "+self.username+"@"+self.hostname+":"+str(self.port)+".") |
| | | exit(1) |
| | | # try: |
| | | print("Trying to connect to: "+self.username+"@"+self.hostname+":"+str(self.port)+".") |
| | | self.ssh.connect(self.hostname, username=self.username, password=self.password, port=self.port, timeout=Timeout) |
| | | self.connected=True |
| | | # except: |
| | | # print("Error establishing connection with "+self.username+"@"+self.hostname+":"+str(self.port)+".") |
| | | # self.connected=False |
| | | # exit(1) |
| | | else: |
| | | print("Already connected!") |
| | | return |
| | | |
| | | def disconnect(self): |
| | | if(self.connected): |
| | | try: |
| | | self.ssh.close() |
| | | except: |
| | | print("Cannot disconect. Unknown error.") |
| | | self.ssh.close() |
| | | else: |
| | | print("Cannot disconect. Already disconnected.") |
| | | self.connected=False |
| | |
| | | print("Cannot execute remote commands. Connect first.") |
| | | |
| | | def send_file(self, local, remote): |
| | | sftp=self.ssh.open_sftp() |
| | | sftp.put(local,remote) |
| | | sftp.close() |
| | | pass |
| | | # sftp=self.ssh.open_sftp() |
| | | # sftp.put(local,remote) |
| | | # sftp.close() |
| | | |
| | | def receive_file(self,remote,local): |
| | | sftp=self.ssh.open_sftp() |
| | | sftp.get(remote,local) |
| | | sftp.close() |
| | | pass |
| | | # sftp=self.ssh.open_sftp() |
| | | # sftp.get(remote,local) |
| | | # sftp.close() |
| | | |
| | | def mkdir_remote(self,directory): |
| | | sftp=self.ssh.open_sftp() |
| | |
| | | return True |
| | | |
| | | def send_multiple_files_in_directory(self,local_files,directory): |
| | | sftp=self.ssh.open_sftp() |
| | | # try: |
| | | # sftp.chdir(directory) # Test if remote_path exists |
| | | # except (IOError,FileNotFoundError): |
| | | # sftp.mkdir(directory) # Create remote_path |
| | | # sftp.chdir(directory) |
| | | self.mkdir_p(sftp, directory) |
| | | for f in set(local_files): |
| | | sftp.put(f, f) |
| | | sftp.close() |
| | | pass |