PHP Python FTP 작업 클래스

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' =>; '未連線到伺服器',

'7' =>; ' 無法上傳檔案' ); return $err_msg[$this->err_code]; } /** * 偵測目錄名稱 * @param string $url 目錄 * @return 由 / 分開的回傳陣列*/ 介面函數 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()