From 46fbff61442dee746958a2288c2e8ca8082d3af2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Volkan=20=C5=9Eahin?= Date: Fri, 6 May 2016 16:36:50 +0300 Subject: [PATCH] file transfer via ssh --- opt/ahenk/base/messaging/ssh_file_transfer.py | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/opt/ahenk/base/messaging/ssh_file_transfer.py b/opt/ahenk/base/messaging/ssh_file_transfer.py index 8b928e9..41ab570 100644 --- a/opt/ahenk/base/messaging/ssh_file_transfer.py +++ b/opt/ahenk/base/messaging/ssh_file_transfer.py @@ -2,9 +2,8 @@ # -*- coding: utf-8 -*- # Author: Volkan Şahin -import paramiko - from base.Scope import Scope +import paramiko class FileTransfer(object): @@ -29,9 +28,9 @@ class FileTransfer(object): try: sftp = paramiko.SFTPClient.from_transport(self.connection) sftp.put(local_path, remote_path) - self.logger.debug('[FileTransfer] File was sent to %s from %s'.format(local_path,remote_path)) + self.logger.debug('[FileTransfer] File was sent to {} from {}'.format(local_path, remote_path)) except Exception as e: - self.logger.error('[FileTransfer] A problem occurred while sending file. Exception message: %s'.format(str(e))) + self.logger.error('[FileTransfer] A problem occurred while sending file. Exception message: {}'.format(str(e))) finally: self.connection.close() self.logger.debug('[FileTransfer] Connection is closed successfully') @@ -41,20 +40,19 @@ class FileTransfer(object): try: sftp = paramiko.SFTPClient.from_transport(self.connection) sftp.get(remote_path, local_path) - self.logger.debug('[FileTransfer] File was downloaded to %s from %s'.format(local_path,remote_path)) + self.logger.debug('[FileTransfer] File was downloaded to {} from {}'.format(local_path, remote_path)) except Exception as e: - self.logger.error('[FileTransfer] A problem occurred while downloading file. Exception message: %s'.format(str(e))) + self.logger.error('[FileTransfer] A problem occurred while downloading file. Exception message: {}'.format(str(e))) finally: self.connection.close() self.logger.debug('[FileTransfer] Connection is closed successfully') def connect(self): - self.logger.debug('[FileTransfer] Connecting to %s via %d'.format(self.target_hostname,self.port)) + self.logger.debug('[FileTransfer] Connecting to {} via {}'.format(self.target_hostname, self.port)) try: - connection = paramiko.Transport((self.target_hostname, self.port)) + connection = paramiko.Transport((self.target_hostname, int(self.port))) connection.connect(username=self.target_username, password=self.target_password, pkey=self.p_key) self.connection = connection self.logger.debug('[FileTransfer] Connected.') except Exception as e: - self.logger.error('[FileTransfer] A problem occurred while connecting to %s . Exception message: %s'.format(self.target_hostname, str(e))) - + self.logger.error('[FileTransfer] A problem occurred while connecting to {} . Exception message: {}'.format(self.target_hostname, str(e)))