PHP Python FTP ?? ???
- class Ftp {
-
- //FTP ?? ???
- private $link;
-
- //FTP ?? ??
- public $link_time;
-
- //?? ??
- private $err_code = 0;
-
- //?? ?? {??? ??: FTP_ASCII, ???? ??: FTP_BINARY}
- ?? $mode = FTP_BINARY;
-
- /**
- ??? ???
-
- **/
- ?? ?? start($data)
- {
- if(empty($data['port']) ) $data['port'] ='21';
- if(empty($data['pasv'])) $data['pasv'] =false;
- if(empty($data[' ssl'])) $data['ssl'] = false;
- if(empty($data['timeout'])) $data['timeout'] = 30;
- return $this-> connect($data['??'],$data['??? ??'],$data['????'],$data['??'],$data['pasv'],$data['ssl'], $data['timeout']);
- }
-
- /**
- * FTP ??? ??
- * @param string $host ?? ??
- * @param string $username ??? ??
- * @param string $password ????
- * @param ?? $port ?? ?? , ???? 21
- * @param boolean $pasv Passive ?? ??? ??
- * @param boolean $ssl SSL ?? ?? ??
- * @param ?? $timeout ?? ?? ??
- */
- ?? ?? connect($host, $username = '', $password = '', $ port = '21', $pasv = false, $ssl = false, $timeout = 30) {
- $start = time();
- if ($ssl) {
- if (!$this- >link = @ftp_ssl_connect($host, $port, $timeout)) {
- $this->err_code = 1;
- return false;
- }
- } else {
- if (!$this->link = @ftp_connect($host, $port, $timeout)) {
- $this->err_code = 1;
- return false;
- }
- }
-
- if (@ftp_login($this->link, $username, $password)) {
- if ($pasv)
- ftp_pasv($this->link, true);
- $this->link_time = time() - $start;
- return true;
- } else {
- $this->err_code = 1;
- return false;
- }
- register_shutdown_function(array(&$this, 'close'));
- }
-
- /**
- * ?? ??
- * @param string $dirname ???? ??,
- */
- ?? ?? mkdir($dirname) {
- if ( !$this->link) {
- $this->err_code = 2;
- return false;
- }
- $dirname = $this->ck_dirname($dirname);
- $nowdir = '/';
- foreach ($dirname as $v) {
- if ($v && !$this->chdir($nowdir . $v)) {
- if ($ nowdir)
- $this->chdir($nowdir);
- @ftp_mkdir($this->link, $v);
- }
- if ($v)
- $nowdir .= $v . '/';
- }
- return true;
- }
-
- /**
- * ?? ???
- * @param string $remote ?? ??? ??
- * @param string $local ?? ??? ??
- */
- ?? ?? put($remote, $local) {
- if (!$this->link) {
- $this->err_code = 2;
- return false;
- }
- $dirname = pathinfo($remote, PATHINFO_DIRNAME) ;
- if (!$this->chdir($dirname)) {
- $this->mkdir($dirname);
- }
- if (@ftp_put($this-> link, $remote, $local, $this->mode)) {
- return true;
- } else {
- $this->err_code = 7;
- return false;
- }
- }
-
- /**
- * ?? ??
- * @param string $dirname ???? ??
- * @param boolean $enforce ?? ??
- */
- ?? ?? rmdir($dirname, $enforce = false) {
- if (!$this->link) {
- $this->err_code = 2;
- return false;
- }
- $list = $this->nlist($dirname);
- if ($list && $enforce) {
- $this->chdir($dirname);
- foreach ($list as $v) {
- $this->f_delete($v);
- }
- } elseif ( $list && !$enforce) {
- $this->err_code = 3;
- return false;
- }
- @ftp_rmdir($this->link, $dirname);
- true? ?????.
- }
-
- /**
- * 刪除指定檔案
- * @param string $filename 檔案名稱
- */
- public function delete($filename) {
- if (!$this->link) {
- $this->err_code = 2 ;
- return false;
- }
- if (@ftp_delete($this->link, $filename)) {
- return true;
- } else {
- $this-> ;err_code = 4;
- return false;
- }
- }
-
- /**
- * 傳回給定目錄的檔案清單
- * @param string $dirname 目錄位址
- * @return array 檔案清單資料
- */
- public function nlist($dirname) {
- if (! $ $this-this >link) {
- $this->err_code = 2;
- return false;
- }
- if ($list = @ftp_nlist($this->link, $dirname )) {
- return $list;
- } else {
- $this->err_code = 5;
- return false;
- }
- }
-
- /* *
- * 在 FTP 伺服器上改變目前目錄
- * @param string $dirname 修改伺服器上目前目錄
- */
- public function chdir($dirname) {
- if (!$this->link) {
- $this->err_code = 2;
- return false;
- }
- if (if (@ ftp_chdir($this->link, $dirname)) {
- return true;
- } else {
- $this->err_code = 6;
- return false;
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
- }
-
- /**
- * 取得錯誤訊息
- */
- public function get_error() {
- if (!$this->err_code)
- 回傳false;
- $err_msg = array(
- '1' =>; '伺服器無法連線',
- '2' =>; '未連線到伺服器',
'3' =>; '無法刪除非空資料夾', '4' =>; '無法刪除檔案', '5' =>; '無法取得檔案清單', '6' =>; '無法變更伺服器上的目前目錄', '7' =>; ' 無法上傳檔案' ); return $err_msg[$this->err_code]; } /** * 偵測目錄名稱 * @param string $url 目錄 * @return 由 / 分開的回傳陣列*/ 介面函數(shù) ck_dirname ($ url) { $url = str_replace('', '/', $url); $urls =explode('/', $url); return $urls; } /** * 關閉FTP連線*/ public function close() { return @ftp_close($this->link); } 複製程式碼
- #!/usr/bin/python
- #coding=gbk
- '''
- ftp ?? ????, ?? ??? ????, ??? ???? ?? ??
- '''
-
- from ftplib import FTP
- import os,sys,string,datetime,time
- import ??
-
- class MYFTP:
- def __init__(self,hostaddr , ??? ??, ????, ?? ????, ??=21):
- self.hostaddr = ??? ??
- self.username = ??? ??
- self.password = ????
- self.remotedir = ?? ????
- self.port = port
- self.ftp = FTP()
- self.file_list = []
- # self.ftp.set_debuglevel(2)
- def __del__(self):
- self.ftp.close ()
- # self.ftp.set_debuglevel(0)
- def login(self):
- ftp = self.ftp
- try:
- timeout = 60
- ??.setdefaulttimeout(timeout )
- ftp.set_pasv(True)
- print '%s? ?? ??' %(self.hostaddr)
- ftp.connect(self.hostaddr, self.port)
- print '%s? ????? ???????. %s' %(self.hostaddr)
- print '%s? ???? ?????' %(self.hostaddr)
- ftp.login(self.username, self.password)
- print '????? ????????. % s' %(self.hostaddr)
- debug_print(ftp.getwelcome())
- ?? ??:
- deal_error("?? ?? ??? ??")
- ??:
- ftp.cwd (self .remotedir)
- ??(??):
- deal_error('???? ?? ??')
-
- def is_same_size(self, localfile, remotefile):
- try:
- remotefile_size = self.ftp.size(remotefile)
- ??:
- Remotefile_size = -1
- ??:
- localfile_size = os.path.getsize(localfile)
- ??:
- localfile_size = - 1
- debug_print('lo:%d re:%d' %(localfile_size, remotefile_size),)
- if remotefile_size == localfile_size:
- return 1
- else:
- return 0
- def download_file (self, localfile, remotefile):
- if self.is_same_size(localfile, remotefile):
- debug_print('%s ??? ??? ????? ????? ??? ????.' %localfile)
- return
- else:
- debug_print('>>>>>>>>>>>>%s ?? ???? ... ...' %localfile)
- #return
- file_handler = open(localfile, 'wb')
- self.ftp.retrbinary('RETR %s'%(remotefile), file_handler.write)
- file_handler.close()
-
- def download_files( self, localdir='./', remotedir='./'):
- ??:
- self.ftp.cwd(remotedir)
- ??:
- debug_print( '???? %s?(?) ???? ????. ?????...' %remotedir)
- return
- ??? ?? ?? os.path.isdir(localdir):
- os.makedirs(localdir)
- debug_print('Switch %s' %self.ftp.pwd())
- self.file_list = []
- self.ftp.dir(self.get_file_list)
- remotenames = self.file_list
- #print( ?? ??)
- #return
- ?? ??? ??:
- filetype = item[0]
- filename = item[1]
- local = os.path.join(localdir, filename)
- if filetype == 'd' :
- self.download_files(local, ?? ??)
- elif filetype == '-':
- self.download_file(local, ?? ??)
- self.ftp.cwd ('..')
- debug_print('?? ???? %s? ?????' %self.ftp.pwd())
- def upload_file(self, localfile, remotefile):
- os.path? ?? ?? .isfile(localfile):
- return
- if self.is_same_size(localfile, remotefile):
- debug_print('Skip [equal]: %s' %localfile)
- return
- file_handler = open (localfile, 'rb')
- self.ftp.storbinary('STOR %s' %remotefile, file_handler)
- file_handler.close()
- debug_print('???: %s' %localfile)
- def upload_files(self, localdir= './', remotedir = './'):
- ??? ?? ?? os.path.isdir(localdir):
- return
- localnames = os.listdir(localdir)
- self.ftp.cwd (remotedir)
- for item in localnames:
- src = os.path.join(localdir, item)
- if os.path.isdir(src):
- ??:
- self.ftp .mkd(item)
- ??:
- debug_print('????? ?? %s' %item)
- self.upload_files(src, item)
- else:
- self.upload_file(src, item)
- self.ftp.cwd('..')
-
- def get_file_list(self, line):
- ret_arr = []
- file_arr = self.get_filename(line)
- if file_arr[1]? ['.', '..']? ??:
- self.file_list.append(file_arr)
-
- def get_filename(self, line ):
- pos = line .rfind(':')
- while(line[pos] != ' '):
- pos = 1
- while(line[pos] == ' ') :
- pos = 1
- file_arr = [line[0], line[pos:]]
- return file_arr
- def debug_print(s):
- print(s)
- def deal_error (e):
- timenow = time.localtime()
- datenow = time.strftime('%Y-%m-%d', timenow)
- logstr = '%s ??? ??????: %s ' %(datenow, e)
- debug_print(logstr)
- file.write(logstr)
- sys.exit()
-
- if __name__ == '__main__':
- file = open("log.txt", " a")
- timenow = time.localtime()
- datenow = time.strftime('%Y-%m-%d', timenow)
- logstr = datenow
- # ?? ??? ?????
- hostaddr = 'localhost' # ftp ??
- username = 'test' # Username
- password = 'test' # ????
- port = 21 # ?? ??
- rootdir_local = '.' os.sep 'bak/' # ?? ????
- rootdir_remote = './' # ?? ????
-
- f = MYFTP(hostaddr, ??? ??, ????, rootdir_remote, ??)
- f.login()
- f.download_files(rootdir_local, rootdir_remote)
-
- timenow = time.localtime()
- datenow = time.strftime('%Y-%m-%d', timenow )
- logstr = " - %s? ?? n? ????? ??????." ?tenow
- debug_print(logstr)
-
- file.write(logstr)
- file.close()
-
?? ??
|