Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #! /usr/bin/python
- import MySQLdb
- import os
- import paramiko
- import datetime
- db = MySQLdb.connect(host="localhost",user='root',passwd="1111",db="Backup2",charset='utf8')#connection
- cursor=db.cursor()#cursor
- sql='''select FromDirectory,WhereDirectory from DirectoryForBackup where IdOfServer=1'''#query
- cursor.execute(sql)
- host = '192.168.56.2'
- user = 'root'
- secret = 'fgh123Q'
- port = 22
- client = paramiko.SSHClient()
- client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
- client.connect(hostname=host, username=user, password=secret, port=port)
- transport = paramiko.Transport((host, port))
- transport.connect(username=user,password=secret)
- sftp = paramiko.SFTPClient.from_transport(transport)
- for directory in cursor:
- stdin, stdout, stderr = client.exec_command('ls '+directory[0])
- data = stdout.read() + stderr.read()
- files=data.split('\n')
- for file in files:
- if file is not '':
- sftp.get(directory[0]+'/'+file,directory[1]+'/'+file)
- sftp.remove(directory[0]+'/'+file)
- cursor.execute('''insert into TableOfBackups(IdOfServer,date,file) values(%s,%s,%s)''', (1,datetime.datetime.now().strftime("%Y-%m-%d %H:%M"),file))
- db.commit()
- client.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement