出典: link タグ:phppythonftp 操作クラス

出典: link タグ:phppythonftp 操作クラス

class Ftp {

 //FTP 接続リソース
 private $link;

 //FTP 接続時間
 public $link_time;

 //エラー コード
 private $err_code = 0;

 //転送モード {テキストモード: FTP_ASCII、バイナリモード: FTP_BINARY}
 public $mode = FTP_BINARY;

 /**
初期化クラス

 **/
 public function 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 ['タイムアウト']);
 }

 /**
 * FTP サーバーに接続します
 * @param string $host サーバーアドレス
 * @param string $username ユーザー名
 * @param string $password パスワード
 * @param integer $port サーバーポート、デフォルト値は 21 です
 * @param boolean $pasv パッシブモードを有効にするかどうか
 * @param boolean $ssl SSL接続を使用するかどうか
 * @param integer $timeout タイムアウト時間
*/
 public function 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 ディレクトリ名,
*/
 public function 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 ローカル ストレージ アドレス
*/
 public function 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 強制削除
*/
 public function 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);
 return 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 配列ファイルリストデータ
* /
 public function nlist($dirname) {
 if (!$this->link) {
 $this->gt;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 (@ftp_chdir($this->link, $dirname)) {
 return true;
 } else {
 $this->err_code = 6;
 return false;
 }
 }

 /**
 * エラーメッセージを取得します
*/
 public function get_error() {
 if (!$this ->err_code)
 return false;
 $err_msg = array(
 '1' => 'サーバーに接続できません',
 '2' => 'サーバーに接続していません',
 '3' => '空ではないフォルダーは削除できません',
 '4' => 'ファイルを削除できません',
 '5' => 'ファイルリストを取得できません',
 '6' => 'サーバー上の現在のディレクトリを変更できません',
 '7' => 'ファイルをアップロードできません'
 );
 return $err_msg[$this->err_code];
 }

 /**
 * ディレクトリ名を検出します
 * @param string $url ディレクトリ
 * @return / で区切られた配列を返します
*/
 private function 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,文字列, 日付時刻, 時刻
インポートソケット

クラス MYFTP:
 def __init__(self, hostaddr, ユーザー名, パスワード, リモートディレクトリ, port=21):
 self.hostaddr = hostaddr
 self.username = ユーザー名
 self.password = パスワード
 self.remotedir = 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 に正常に接続しました' %(self.hostaddr)
 print '%s へのログインを開始します' % ( self.hostaddr)
 ftp.login(self.username, self.password)
 print '%s に正常にログインしました' %(self.hostaddr)
 debug_print(ftp.getwelcome())
 例外:
 deal_error( "接続またはログインに失敗しました")
 try:
 ftp.cwd(self.remotedir)
Exception(Exception):
 deal_error('ディレクトリの切り替えに失敗しました')

 def is_same_size(self, localfile, Remotefile):
 try:
remotefile_size = self.ftp.size(remotefile)
例外:
remotefile_size = -1
try:
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='./'):
 try:
 self.ftp.cwd(remotedir)
例外:
 debug_print('Directory %s は存在しません。続行します。 ..' %remotedir)
 return
 if os.path.isdir(localdir):
 os.makedirs(localdir)
 debug_print('ディレクトリ %s' %self.ftp に切り替えます。 pwd())
 self.file_list = []
 self.ftp.dir(self.get_file_list)
 Remotenames = self.file_list
 #print(remotenames)
 #return
 for item inremotename:
 filetype = item[0]
 filename = item[1]
 local = os.path.join(localdir, filename)
 if filetype == 'd':
 self.download_files(local, filename)
 elif filetype == '-':
 self. download_file(local, filename)
 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('Transmitted: %s' %localfile)
 def Upload_files(self, localdir='./', Remotedir = './') :
 os.path.isdir(localdir) でない場合:
 return
 localnames = os.listdir(localdir)
 self.ftp.cwd(remotedir)
 localnames の項目の場合:
 src = os .path.join(localdir, item)
 if os.path.isdir(src):
 try:
 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] not in ['.', '..']:
 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' # ユーザー名
 パスワード = 'test' # パスワード
 port = 21 # ポート番号
rootdir_local = '.' + os.sep + 'bak/' # ローカルディレクトリ
 rootdir_remote = './' # リモートディレクトリ

 f = MYFTP(hostaddr, ユーザー名, パスワード, rootdir_remote, port)
 f.login()
 f.download_files(rootdir_local, rootdir_remote)

 timenow = time.localtime()
 datenow = time.strftime('%Y-%m-%d', timenow)
 logstr += " - %s はバックアップ n を正常に実行しました " %datenow
 debug_print(logstr)

 file.write(logstr)
 file.close()