Pastable version of sendfile.SftpSClient

<div style="overflow:auto;border:solid 1px #ccc;background:#000;color:#F8F8F8">
 <div class="section">
 
 <pre style="float:left;margin:0 10px;border-right:0;color:#666;">1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111</pre>
 <pre class="sunburst">#!/usr/bin/env python
# #########################
# # $Id: sendfile.py,v 1.4 2008/03/19 11:59:52 dhylton Exp $
# # $Log: $
# #########################

import time
import os
import sys
#import paramiko
#import ftplib
#import pycurl

class SftpSClient (object):
 def __init__(self, protocol, hostname, hostport, username, password, source_path, dest_path):

self.protocol = protocol
 self.hostname = hostname
 self.hostport = hostport
 self.username = username
 self.password = password
 self.source_path = source_path
 self.dest_path = dest_path

def xfer(self, source_file, dest_file=None):
 if not dest_file: dest_file = source_file
 source = os.path.join(self.source_path, source_file)
 dest = os.path.join(self.dest_path, dest_file)

if self.protocol == &quot;sftp&quot;:
 if not self.hostport: self.hostport = 22
 self.client.connect(self.hostname, self.hostport, self.username, self.password)
 sftp_client = self.client.open_sftp()
 sftp_client.put(source, dest)
 sftp_client.close()
 elif self.protocol == &quot;ftps&quot;:
 if not self.hostport: self.hostport = 990
 userpwd = '%s:%s' % (self.username, self.password)
 infile = open(source, 'rb')
 self.client.setopt(pycurl.URL, 'ftp://%s:%d/%s' % (self.hostname, self.hostport, dest))
 self.client.setopt(pycurl.FTP_SSL, 1)
 self.client.setopt(pycurl.FTPSSLAUTH, 1)
 self.client.setopt(pycurl.SSL_VERIFYHOST, 1)
 self.client.setopt(pycurl.SSL_VERIFYPEER, 1)
 self.client.setopt(pycurl.USERPWD, userpwd)
 self.client.setopt(pycurl.READDATA, infile)
 self.client.setopt(pycurl.UPLOAD, 1)
 self.client.perform()
 infile.close()
 else: #self.protocol == &quot;ftp&quot;:
 if not self.hostport: self.hostport = 21
 self.client.connect(self.hostname, self.hostport)
 self.client.login(user=self.username, passwd=self.password)
 self.client.set_pasv(False)
 infile = open(source, 'rb')
 self.client.storbinary('STOR ' + dest, infile)
 infile.close()

def main():

hostname = 'localhost'
 username = 'snark'
 password = 'Bgt54rfv'
 source_path = 'lo cal'
 source_file = &quot;test file'132&quot;
 dest_file = &quot;remote test file'133&quot;

print 'testing ftp'
 protocol = 'ftp'
 hostport = None
 start = time.time()
 dest_path = '%s/re mote' % (protocol)
 p = SftpSClient(protocol, hostname, hostport, username, password, source_path, dest_path)
 p.xfer(source_file, dest_file)
 elapsedtime = time.time() - start
 print 'elapsed time:', elapsedtime

print 'testing ftps'
 protocol = 'ftps'
 hostport = 990
 start = time.time()
 dest_path = '%s/re mote' % (protocol)
 p = SftpSClient(protocol, hostname, hostport, username, password, source_path, dest_path)
 p.xfer(source_file, dest_file)
 elapsedtime = time.time() - start
 print 'elapsed time:', elapsedtime

print 'testing sftp'
 protocol = 'sftp'
 hostport = 22
 start = time.time()
 dest_path = '%s/re mote' % (protocol)
 p = SftpSClient(protocol, hostname, hostport, username, password, source_path, dest_path)
 p.xfer(source_file, dest_file)
 elapsedtime = time.time() - start
 print 'elapsed time:', elapsedtime

if __name__ == '__main__': main()
</pre>
 </div>
 </div>

Refactor :my => 'code'

Recent

Popular

Pastable version of sendfile.SftpSClient