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 由 / 分開的回傳陣列*/ 介面函數 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()
-
코드 복사
|