php python ftp操作类

php python ftp操作类

1. class Ftp {
3. //FTP 连接资源
4. private $link;
6. //FTP连接时间
7. public $link_time;
9. //错误代码
10. private $err_code = 0;
12. //传送模式{文本模式:FTP_ASCII, 二进制模式:FTP_BINARY}
13. public $mode = FTP_BINARY;
15. /**
16. 初始化类
18. **/
19. public function start($data)
20. {
21. if(empty($data['port'])) $data['port'] ='21';
22. if(empty($data['pasv'])) $data['pasv'] =false;
23. if(empty($data['ssl'])) $data['ssl'] = false;
24. if(empty($data['timeout'])) $data['timeout'] = 30;
25. return $this->connect($data['server'],$data['username'],$data['password'],$data['port'],$data['pasv'],$data['ssl'],$data['timeout']);
26. }
28. /**
29. * 连接FTP服务器
30. * @param string $host 　　 服务器地址
31. * @param string $username　　　用户名
32. * @param string $password　　　密码
33. * @param integer $port　　　　 服务器端口，默认值为21
34. * @param boolean $pasv 是否开启被动模式
35. * @param boolean $ssl　　　　 　是否使用SSL连接
36. * @param integer $timeout 超时时间　
37. */
38. public function connect($host, $username = '', $password = '', $port = '21', $pasv = false, $ssl = false, $timeout = 30) {
39. $start = time();
40. if ($ssl) {
41. if (!$this->link = @ftp_ssl_connect($host, $port, $timeout)) {
42. $this->err_code = 1;
43. return false;
44. }
45. } else {
46. if (!$this->link = @ftp_connect($host, $port, $timeout)) {
47. $this->err_code = 1;
48. return false;
49. }
50. }
52. if (@ftp_login($this->link, $username, $password)) {
53. if ($pasv)
54. ftp_pasv($this->link, true);
55. $this->link_time = time() - $start;
56. return true;
57. } else {
58. $this->err_code = 1;
59. return false;
60. }
61. register_shutdown_function(array(&$this, 'close'));
62. }
64. /**
65. * 创建文件夹
66. * @param string $dirname 目录名，
67. */
68. public function mkdir($dirname) {
69. if (!$this->link) {
70. $this->err_code = 2;
71. return false;
72. }
73. $dirname = $this->ck_dirname($dirname);
74. $nowdir = '/';
75. foreach ($dirname as $v) {
76. if ($v && !$this->chdir($nowdir . $v)) {
77. if ($nowdir)
78. $this->chdir($nowdir);
79. @ftp_mkdir($this->link, $v);
80. }
81. if ($v)
82. $nowdir .= $v . '/';
83. }
84. return true;
85. }
87. /**
88. * 上传文件
89. * @param string $remote 远程存放地址
90. * @param string $local 本地存放地址
91. */
92. public function put($remote, $local) {
93. if (!$this->link) {
94. $this->err_code = 2;
95. return false;
96. }
97. $dirname = pathinfo($remote, PATHINFO_DIRNAME);
98. if (!$this->chdir($dirname)) {
99. $this->mkdir($dirname);
100. }
101. if (@ftp_put($this->link, $remote, $local, $this->mode)) {
102. return true;
103. } else {
104. $this->err_code = 7;
105. return false;
106. }
107. }
109. /**
110. * 删除文件夹
111. * @param string $dirname 目录地址
112. * @param boolean $enforce 强制删除
113. */
114. public function rmdir($dirname, $enforce = false) {
115. if (!$this->link) {
116. $this->err_code = 2;
117. return false;
118. }
119. $list = $this->nlist($dirname);
120. if ($list && $enforce) {
121. $this->chdir($dirname);
122. foreach ($list as $v) {
123. $this->f_delete($v);
124. }
125. } elseif ($list && !$enforce) {
126. $this->err_code = 3;
127. return false;
128. }
129. @ftp_rmdir($this->link, $dirname);
130. return true;
131. }
133. /**
134. * 删除指定文件
135. * @param string $filename 文件名
136. */
137. public function delete($filename) {
138. if (!$this->link) {
139. $this->err_code = 2;
140. return false;
141. }
142. if (@ftp_delete($this->link, $filename)) {
143. return true;
144. } else {
145. $this->err_code = 4;
146. return false;
147. }
148. }
150. /**
151. * 返回给定目录的文件列表
152. * @param string $dirname 目录地址
153. * @return array 文件列表数据
154. */
155. public function nlist($dirname) {
156. if (!$this->link) {
157. $this->err_code = 2;
158. return false;
159. }
160. if ($list = @ftp_nlist($this->link, $dirname)) {
161. return $list;
162. } else {
163. $this->err_code = 5;
164. return false;
165. }
166. }
168. /**
169. * 在 FTP 服务器上改变当前目录
170. * @param string $dirname 修改服务器上当前目录
171. */
172. public function chdir($dirname) {
173. if (!$this->link) {
174. $this->err_code = 2;
175. return false;
176. }
177. if (@ftp_chdir($this->link, $dirname)) {
178. return true;
179. } else {
180. $this->err_code = 6;
181. return false;
182. }
183. }
185. /**
186. * 获取错误信息
187. */
188. public function get_error() {
189. if (!$this->err_code)
190. return false;
191. $err_msg = array(
192. '1' => 'Server can not connect',
193. '2' => 'Not connect to server',
194. '3' => 'Can not delete non-empty folder',
195. '4' => 'Can not delete file',
196. '5' => 'Can not get file list',
197. '6' => 'Can not change the current directory on the server',
198. '7' => 'Can not upload files'
199. );
200. return $err_msg[$this->err_code];
201. }
203. /**
204. * 检测目录名
205. * @param string $url 目录
206. * @return 由 / 分开的返回数组
207. */
208. private function ck_dirname($url) {
209. $url = str_replace('', '/', $url);
210. $urls = explode('/', $url);
211. return $urls;
212. }
214. /**
215. * 关闭FTP连接
216. */
218. public function close() {
219. return @ftp_close($this->link);
220. }
222. }

复制代码

1. #!/usr/bin/python
2. #coding=gbk
3. '''
4. ftp自动下载、自动上传脚本，可以递归目录操作
5. '''
7. from ftplib import FTP
8. import os,sys,string,datetime,time
9. import socket
11. class MYFTP:
12. def __init__(self, hostaddr, username, password, remotedir, port=21):
13. self.hostaddr = hostaddr
14. self.username = username
15. self.password = password
16. self.remotedir = remotedir
17. self.port = port
18. self.ftp = FTP()
19. self.file_list = []
20. # self.ftp.set_debuglevel(2)
21. def __del__(self):
22. self.ftp.close()
23. # self.ftp.set_debuglevel(0)
24. def login(self):
25. ftp = self.ftp
26. try:
27. timeout = 60
28. socket.setdefaulttimeout(timeout)
29. ftp.set_pasv(True)
30. print '开始连接到 %s' %(self.hostaddr)
31. ftp.connect(self.hostaddr, self.port)
32. print '成功连接到 %s' %(self.hostaddr)
33. print '开始登录到 %s' %(self.hostaddr)
34. ftp.login(self.username, self.password)
35. print '成功登录到 %s' %(self.hostaddr)
36. debug_print(ftp.getwelcome())
37. except Exception:
38. deal_error("连接或登录失败")
39. try:
40. ftp.cwd(self.remotedir)
41. except(Exception):
42. deal_error('切换目录失败')
44. def is_same_size(self, localfile, remotefile):
45. try:
46. remotefile_size = self.ftp.size(remotefile)
47. except:
48. remotefile_size = -1
49. try:
50. localfile_size = os.path.getsize(localfile)
51. except:
52. localfile_size = -1
53. debug_print('lo:%d re:%d' %(localfile_size, remotefile_size),)
54. if remotefile_size == localfile_size:
55. return 1
56. else:
57. return 0
58. def download_file(self, localfile, remotefile):
59. if self.is_same_size(localfile, remotefile):
60. debug_print('%s 文件大小相同，无需下载' %localfile)
61. return
62. else:
63. debug_print('>>>>>>>>>>>>下载文件 %s ... ...' %localfile)
64. #return
65. file_handler = open(localfile, 'wb')
66. self.ftp.retrbinary('RETR %s'%(remotefile), file_handler.write)
67. file_handler.close()
69. def download_files(self, localdir='./', remotedir='./'):
70. try:
71. self.ftp.cwd(remotedir)
72. except:
73. debug_print('目录%s不存在，继续...' %remotedir)
74. return
75. if not os.path.isdir(localdir):
76. os.makedirs(localdir)
77. debug_print('切换至目录 %s' %self.ftp.pwd())
78. self.file_list = []
79. self.ftp.dir(self.get_file_list)
80. remotenames = self.file_list
81. #print(remotenames)
82. #return
83. for item in remotenames:
84. filetype = item[0]
85. filename = item[1]
86. local = os.path.join(localdir, filename)
87. if filetype == 'd':
88. self.download_files(local, filename)
89. elif filetype == '-':
90. self.download_file(local, filename)
91. self.ftp.cwd('..')
92. debug_print('返回上层目录 %s' %self.ftp.pwd())
93. def upload_file(self, localfile, remotefile):
94. if not os.path.isfile(localfile):
95. return
96. if self.is_same_size(localfile, remotefile):
97. debug_print('跳过[相等]: %s' %localfile)
98. return
99. file_handler = open(localfile, 'rb')
100. self.ftp.storbinary('STOR %s' %remotefile, file_handler)
101. file_handler.close()
102. debug_print('已传送: %s' %localfile)
103. def upload_files(self, localdir='./', remotedir = './'):
104. if not os.path.isdir(localdir):
105. return
106. localnames = os.listdir(localdir)
107. self.ftp.cwd(remotedir)
108. for item in localnames:
109. src = os.path.join(localdir, item)
110. if os.path.isdir(src):
111. try:
112. self.ftp.mkd(item)
113. except:
114. debug_print('目录已存在 %s' %item)
115. self.upload_files(src, item)
116. else:
117. self.upload_file(src, item)
118. self.ftp.cwd('..')
120. def get_file_list(self, line):
121. ret_arr = []
122. file_arr = self.get_filename(line)
123. if file_arr[1] not in ['.', '..']:
124. self.file_list.append(file_arr)
126. def get_filename(self, line):
127. pos = line.rfind(':')
128. while(line[pos] != ' '):
129. pos += 1
130. while(line[pos] == ' '):
131. pos += 1
132. file_arr = [line[0], line[pos:]]
133. return file_arr
134. def debug_print(s):
135. print (s)
136. def deal_error(e):
137. timenow = time.localtime()
138. datenow = time.strftime('%Y-%m-%d', timenow)
139. logstr = '%s 发生错误: %s' %(datenow, e)
140. debug_print(logstr)
141. file.write(logstr)
142. sys.exit()
144. if __name__ == '__main__':
145. file = open("log.txt", "a")
146. timenow = time.localtime()
147. datenow = time.strftime('%Y-%m-%d', timenow)
148. logstr = datenow
149. # 配置如下变量
150. hostaddr = 'localhost' # ftp地址
151. username = 'test' # 用户名
152. password = 'test' # 密码
153. port = 21 # 端口号
154. rootdir_local = '.' + os.sep + 'bak/' # 本地目录
155. rootdir_remote = './' # 远程目录
157. f = MYFTP(hostaddr, username, password, rootdir_remote, port)
158. f.login()
159. f.download_files(rootdir_local, rootdir_remote)
161. timenow = time.localtime()
162. datenow = time.strftime('%Y-%m-%d', timenow)
163. logstr += " - %s 成功执行了备份\n" %datenow
164. debug_print(logstr)
166. file.write(logstr)
167. file.close()

复制代码