データベース認証付きFTPサーバー

サーバーに展開するための既製のFTPサーバーが多数あります。 しかし、FTPがサーバー上ですでに実行されているため、代替ポートでFTPサーバーを上げる必要がありました。 また、ユーザーがファイルのあるフォルダにのみアクセスできるようにします。 Pythonツールを使用して何ができるかを尋ねることにしました。 検索はすぐにpyFTPdライブラリを返しました。





このライブラリの既製の例は、FTPサーバーを数分で上げる方法を示しています。 ユーザーとユーザーがアクセスできるファイルへのパスは、データベースに保存されます。 したがって、このライブラリーを基礎としてデータベースにリンクすることが決定されました。 そして、あなた自身のグッズを備えたFTPサーバーを入手してください:)

データベース

データベース内のテーブルは、複雑なものを超えるものを表しません。

SQL：

CREATE TABLE ` users ` (

` id ` int ( 11 ) NOT NULL auto_increment,

` username ` varchar ( 255 ) NOT NULL ,

` password ` varchar ( 32 ) NOT NULL ,

` path ` varchar ( 255 ) NOT NULL ,

` perm ` varchar ( 8 ) default NULL ,

PRIMARY KEY ( ` id ` ),

KEY ` username ` ( ` username ` )

)



使用される主なパラメーターは、ログイン、パスワード、アクセス権、ユーザーがアクセスできるフォルダーへのパスです。

実装

すぐに行われた最初のことは、データベースを操作するための小さなクラスラッパーでした。 したがって、ニーズに合わせて書き直して、MySQLを任意のデータベースに置き換えることができます。

class DB :



init = None

db = None

def __init__ ( self ,init_db):

""" Constructor """

self . init = init_db

self . db = self . init()



def doSql ( self ,sql):

""" Handle SQL """

try :

self . db . execute(sql)

except :

try :

self . db = self . init()

self . db . execute(sql)

except :

print "error:" + sql



def getDB ( self ):

""" """

return self . db



def getLastId ( self ):

"""Get last insert ID"""

sql = "select LAST_INSERT_ID() as `id`"

self . doSql(sql)

data = self . db . fetchone()

if 'id' in data:

return data[ 'id' ]

else :

return None



ウィキペディアとサーバー自体のソースコードを検討した結果、承認とファイルの場所の選択を担当するメソッドが特定されました。 その後、これらの方法を再定義する必要があり、問題は解決しました。

サーバーの起動方法は次のとおりです。

. . .

def starterver ( self ):

"""Run server"""

authorizer = self . ftpserver . DummyAuthorizer()



authorizer . validate_authentication = self . my_validate_authentication

authorizer . get_home_dir = self . my_get_home_dir

authorizer . get_perms = self . my_get_perms

authorizer . get_msg_login = self . my_get_msg_login

authorizer . get_msg_quit = self . my_get_msg_quit



authorizer . has_perm = self . my_has_perms

authorizer . has_user = self . my_has_user



# Instantiate FTP handler class

ftp_handler = ftpserver . FTPHandler

ftp_handler . authorizer = authorizer

ftp_handler . passive_ports = range ( 63000 , 63500 )

# Define a customized banner (string returned when client connects)

ftp_handler . banner = "pyftpdlib %s based ftpd ready." % ftpserver . __ver__



address = ( '127.0.0.1' , 23 )

ftpd = ftpserver . FTPServer(address, ftp_handler)



# set a limit for connections

ftpd . max_cons = 256

ftpd . max_cons_per_ip = 5



# start ftp server

ftpd . serve_forever()

. . .



オーバーライドされた主なメソッド

validate_authentication-ユーザー認証を担当します。

get_home_dir-ユーザーがアクセスできるホームディレクトリを取得します。

get_perms-データアクセス許可を取得します。

has_perm-ディレクトリへのユーザーアクセス権の確認

has_user-ユーザーの存在を確認します



ユーザーと連携するために、別のクラスが実装されました。

from db import DB

from config import init_db

class User :



def __init__ ( self ):

"""Init"""



def auth ( self ,username,password):

"""Make auth"""

sql = "select * from `users` where `username`=' %s ' and `password`=' %s '" % (username,password)

db = DB(init_db)

db . doSql(sql)

res = db . getDB() . fetchone()

if res:

return 1

else :

return None



def getPath ( self ,username):

"""Return path by username"""

sql = "select `path` from `users` where `username`=' %s '" % username

db = DB(init_db)

db . doSql(sql)

uparam = db . getDB() . fetchone()

if uparam:

return uparam[ 'path' ]

else :

return None



def getPerm ( self ,username):

"""Return permission by username"""

sql = "select `perm` from `users` where `username`=' %s '" % username

db = DB(init_db)

db . doSql(sql)

uparam = db . getDB() . fetchone()

if uparam:

return uparam[ 'perm' ]

else :

return ''



def hasUser ( self ,username):

"""Checj user into DB"""

sql = "select `id` from `users` where `username`=' %s '" % (username)

db = DB(init_db)

db . doSql(sql)

uparam = db . getDB() . fetchone()

if uparam:

return 1

else :

return 0



必要なメソッドをラップします。

def my_validate_authentication ( self ,username,password):

return User() . auth(username, password)



def my_get_home_dir ( self ,username):

return User() . getPath(username)



def my_get_perms ( self ,username):

return User() . getPerm(username)



def my_get_msg_login ( self ,username):

return 'hello msg login'



def my_get_msg_quit ( self ,username):

return 'byu msg quit'



def my_has_user ( self ,username):

return User() . hasUser(username)



def my_has_perms ( self ,username, perm, path = None ):

return 1



結果

ユーザーはデータベースを介してログインし、自分のディレクトリにアクセスします。

改善できるもの

キャッシュを使用して、データベース呼び出しをオフロードできます。 たとえば、memcache。 ここには非常に多くのオプションがあります：

• ユーザーがログインするときに、ユーザーに関するすべての情報をキャッシュに書き込み、そこから読み取ります
• ユーザーデータベースをキャッシュに保存し、定期的に更新する

ソースコード

ソースコードはこちらからダウンロードできます 。

ソース

http://en.wikipedia.org/wiki/File_Transfer_Protocol

http://code.google.com/p/pyftpdlib/