Skip to content
Snippets Groups Projects
Commit 9249d7fb authored by sveseli's avatar sveseli
Browse files

attempt fix for occasional 'no such file' errors

parent 5473afba
No related branches found
No related tags found
No related merge requests found
...@@ -6,6 +6,7 @@ import stat ...@@ -6,6 +6,7 @@ import stat
import pysftp import pysftp
from dm.common.utility.timeUtility import TimeUtility from dm.common.utility.timeUtility import TimeUtility
from dm.common.utility.loggingManager import LoggingManager from dm.common.utility.loggingManager import LoggingManager
from dm.common.exceptions.commandFailed import CommandFailed
import urlparse import urlparse
class SftpUtility: class SftpUtility:
...@@ -90,8 +91,15 @@ class SftpUtility: ...@@ -90,8 +91,15 @@ class SftpUtility:
if not self.sftpClient: if not self.sftpClient:
self.sftpClient = self.getSftpClient(self.host, self.port, self.username, self.password, self.privateKey) self.sftpClient = self.getSftpClient(self.host, self.port, self.username, self.password, self.privateKey)
try: try:
md5Sum = self.sftpClient.execute('md5sum "%s"' % filePath)[0].split()[0] #md5Sum = self.sftpClient.execute('md5sum "%s"' % filePath)[0].split()[0]
output = self.sftpClient.execute('md5sum "%s"' % filePath)[0]
if output.startswith("md5sum"):
raise CommandFailed(output)
md5Sum = output.split()[0]
fileInfo['md5Sum'] = md5Sum fileInfo['md5Sum'] = md5Sum
except CommandFailed, ex:
self.getLogger().error('Could not get md5sum for file %s: %s' % (filePath,ex))
raise
except Exception, ex: except Exception, ex:
self.getLogger().error('Could not get md5sum for file %s: %s' % (filePath,ex)) self.getLogger().error('Could not get md5sum for file %s: %s' % (filePath,ex))
self.closeConnection() self.closeConnection()
...@@ -137,9 +145,9 @@ class SftpUtility: ...@@ -137,9 +145,9 @@ class SftpUtility:
if __name__ == '__main__': if __name__ == '__main__':
#sftpUtility = SftpUtility('s1dserv', username='dmadmin', password='theKey12') #sftpUtility = SftpUtility('s1dserv', username='dmadmin', password='theKey12')
sftpUtility = SftpUtility('s1dserv',privateKey='/home/beams/DMADMIN/.ssh/id_dsa') sftpUtility = SftpUtility('s1dserv',privateKey='/home/beams/DMADMIN/.ssh/id_dsa')
files = sftpUtility.getFiles('/export/dm/test') #files = sftpUtility.getFiles('/export/dm/test')
print files #print files
print sftpUtility.getMd5Sum('/export/dm/test/testfile01') print sftpUtility.getMd5Sum('/export/dm/test/testfile01')
print 'Closing connection' #print 'Closing connection'
sftpUtility.closeConnection() #sftpUtility.closeConnection()
print sftpUtility.statFile('/export/dm/test/testfile01') #print sftpUtility.statFile('/export/dm/test/testfile01')
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment