* Added sftp_client.put() method.

* Added sftp_status_callback class.
master
Wirawan Purwanto 13 years ago
parent 6433e5da3c
commit dcb7fa304c
  1. 59
      net/sftp.py

@ -15,6 +15,9 @@ only works for Linux OS since it uses /proc/$PID approach.
import getpass
import os
import stat
import sys
import time
try:
import paramiko
@ -43,7 +46,7 @@ if has_paramiko:
#print "here1"
conn.load_host_keys(os.path.expanduser("~/.ssh/known_hosts"))
#print "here1"
conn.set_missing_host_key_policy(paramiko.RejectPolicy) # default=paranoid
conn.set_missing_host_key_policy(paramiko.RejectPolicy()) # default=paranoid
#print "here1"
conn.connect(hostname=hostname, username=username, password=password,
port=port,
@ -60,11 +63,21 @@ if has_paramiko:
def get(self, remotepath, localpath, callback=None):
# TODO: progress bar
self.sftp.get(remotepath, localpath, callback)
# Save the attributes as much as I can do it
# Preserve the attributes as much as I can do it
stats = self.sftp.stat(remotepath)
os.utime(localpath, (stats.st_atime, stats.st_mtime))
os.chmod(localpath, stats.st_mode)
def put(self, localpath, remotepath, callback=None):
# TODO: progress bar
self.sftp.put(localpath, remotepath, callback)
# Preserve the attributes as much as I can do it
stats = os.stat(localpath)
self.sftp.utime(remotepath, (stats.st_atime, stats.st_mtime))
self.sftp.chmod(remotepath, stats.st_mode)
def close(self):
self.sftp.close()
# TODO: recode the sftp driver from
@ -74,3 +87,45 @@ class sftp_driver(object):
def __init__(self, hostname, username=None, port=22, password=None):
raise NotImplementedError
# TODO
class sftp_status_callback(object):
"""SFTP progress bar for sftp_client object above.
Example usage:
statproc = sftp_status_callback(fname=remote_root + "/myfile.txt")
sftp.get(remote_root + "/myfile.txt", "mylocalfile.txt", statproc)
statproc.done()
"""
def __init__(self, fname, out=sys.stderr):
self.first = True
self.fname = fname
self.out = out
self.marks = [ 0, 10, 20, 30, 40, 50, 60, 70, 80, 90 ]
self.nbars = 25
self.lastbar = 0
self.begin_time = time.time()
def printbar(self, bar):
if bar > self.lastbar:
dbar = bar - self.lastbar
self.out.write("*" * dbar)
self.out.flush()
self.lastbar = bar
def __call__(self, nbytes, filesize):
if self.first:
self.first = False
self.filesize = filesize
self.last = 0
self.out.write("%-40s : %12d " % (self.fname[-40:], self.filesize))
self.out.flush()
self.cursize = nbytes
curbar = int(float(nbytes) / self.filesize * self.nbars)
self.printbar(curbar)
def done(self):
self.end_time = time.time()
dtime = self.end_time - self.begin_time
self.out.write(" %.2f kibps\n" % (self.filesize / 1024.0 / dtime))
self.out.flush()

Loading…
Cancel
Save