डेटाबेस प्राधिकरण के साथ एफ़टीपी सर्वर

आपके सर्वर पर तैनाती के लिए कई तैयार-निर्मित एफ़टीपी सर्वर हैं। लेकिन ऐसा हुआ कि एफ़टीपी पहले से ही सर्वर पर चल रहा है और आपको एफ़टीपी सर्वर को एक वैकल्पिक पोर्ट पर उठाने की आवश्यकता है। और उपयोगकर्ताओं को केवल फ़ाइलों के साथ अपने फ़ोल्डर्स तक पहुंच प्रदान करते हैं। मैंने यह पूछने का फैसला किया कि पायथन टूल्स का उपयोग करके क्या किया जा सकता है। खोज ने जल्द ही pyFTPd लाइब्रेरी लौटा दी।





इस लाइब्रेरी के तैयार उदाहरणों से पता चलता है कि एक दो मिनट में अपने एफ़टीपी सर्वर को कैसे बढ़ाया जाए। उपयोगकर्ता और उन फ़ाइलों का पथ जिनके लिए उन्हें एक्सेस करने में सक्षम होना चाहिए, डेटाबेस में संग्रहीत हैं। इस प्रकार, इस पुस्तकालय को आधार के रूप में लेने और इसे डेटाबेस से जोड़ने का निर्णय लिया गया। और अपने खुद के उपहार के साथ एक एफ़टीपी सर्वर प्राप्त करें :)

डेटाबेस

एक डेटाबेस में एक तालिका जटिल से परे किसी भी चीज़ का प्रतिनिधित्व नहीं करती है।

एसक्यूएल:

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/