Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/python
- # --------------------------------------------------------------------
- #import libraries
- # --------------------------------------------------------------------
- import paramiko as PM
- import os
- import datetime
- # --------------------------------------------------------------------
- # Global Variables
- # --------------------------------------------------------------------
- host = 'host IP address'
- port = 22
- username = 'Username'
- password = '*********'
- # Variable Paths
- localPath = '/shares/MILKLINK/fromML'
- remotePath = '/'
- logPath = '/shares/MILKLINK/logs/PPcfg02.log'
- SRCfiles = '/shares/MILKLINK/Milklink.cpy'
- # --------------------------------------------------------------------
- # Create LOG FILE
- # --------------------------------------------------------------------
- log = open(logPath, 'a')
- log.write(datetime.datetime.now().isoformat()+'n')
- # Creating lockfile
- if(os.path.isfile('LockSFTP')):
- log.write("LOCK FILE STILL EXISTS!")
- quit()
- else:
- os.system(">LockSFTP")
- # --------------------------------------------------------------------
- # Remove all files from /formML/
- # --------------------------------------------------------------------
- fileList = os.listdir(localPath)
- for fileName in fileList:
- try:
- os.remove(localPath+"/"+fileName)
- except OSError:
- log.write("%s could not be deletedn" % fileName)
- # --------------------------------------------------------------------
- # Create SFTP CONNECTION
- # --------------------------------------------------------------------
- log.write("Starting Connection...n")
- # SSH connection
- ssh_Connection = PM.Transport((host, port))
- ssh_Connection.connect(username = username, password = password)
- # Creaat SFTP CLIENT SERVICES
- sftp = PM.SFTPClient.from_transport(ssh_Connection)
- log.write("Connection Established...n")
- remoteList = sftp.listdir(remotePath)
- fileList = os.listdir(SRCfiles)
- try:
- sftp.chdir(remotePath+'/tmp')
- except IOError:
- sftp.mkdir(remotePath+'/tmp')
- sftp.chdir(remotePath+'/tmp')
- for fileName in fileList:
- if 'comphaulier.asc' not in remoteList:
- if 'Last' in fileName:
- continue
- else:
- sftp.put(SRCfiles+'/'+fileName, remotePath+'/tmp/'+fileName)
- log.write(fileName+" Transferredn")
- else:
- log.write("Files Still Existn")
- log.close()
- quit()
- checkList = sftp.listdir(remotePath)
- if len(checkList) == 7:
- sftp.put(SRCfiles+'/LastFile.lst', remotePath+'/LastFile.lst')
- log.write("LastFile.lst Transferredn")
- else:
- log.write("Not all files transferred!!!n")
- quit()
- sftp.close()
- ssh_Connection.close()
- os.system("rm LockSFTP")
- sftp.rename(remotePath+'/tmp/'+fileName, remotePath+fileName)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement