Помогите пожалуйсто в следующем вопросе: необходимо "модифицировать" либу следующим образом: нужно, чтобы в ф-ции "ftp_STOR" данные, которые пришли по FTP в виде файла и должны "упасть" в файловую систему не "падали" туда; поток с этими данными должен отпарсиваться нужным образом.... Собственно, вопрос: __ где "место", где он пишет на диск ново пришедший файл? __ как "добраться" до потока с данными ("буфера"), в который пишется ново пришедший файл?
Заранее спасибо! =)
http://code.google.com/p/pyftpdlib/ -- сайт проджекта http://pyftpdlib.googlecode.com/files/pyftpdlib-0.5.1.tar.gz -- либа собственной персоны
Ф-ция, где происходит прием нового файла и по логики должна быть запись на диск или в буфер:
def ftp_STOR(self, file, mode='w'): """Store a file (transfer from the client to the server).""" # A resume could occur in case of APPE or REST commands. # In that case we have to open file object in different ways: # STOR: mode = 'w' # APPE: mode = 'a' # REST: mode = 'r+' (to permit seeking on file object) if 'a' in mode: cmd = 'APPE' else: cmd = 'STOR' line = self.fs.fs2ftp(file) rest_pos = self.restart_position self.restart_position = 0 if rest_pos: mode = 'r+' try: fd = self.run_as_current_user(self.fs.open, file, mode + 'b') except IOError, err: why = _strerror(err) self.log('FAIL %s "%s". %s.' %(cmd, line, why)) self.respond('550 %s.' %why) return
if rest_pos: # Make sure that the requested offset is valid (within the # size of the file being resumed). # According to RFC-1123 a 554 reply may result in case # that the existing file cannot be repositioned as # specified in the REST. ok = 0 try: assert not rest_pos > self.fs.getsize(file) fd.seek(rest_pos) ok = 1 except AssertionError: why = "Invalid REST parameter" except IOError, err: why = _strerror(err) if not ok: self.respond('554 %s' %why) self.log('FAIL %s "%s". %s.' %(cmd, line, why)) return
self.log('OK %s "%s". Upload starting.' %(cmd, line)) if self.data_channel is not None: self.respond("125 Data connection already open. Transfer starting.") self.data_channel.file_obj = fd self.data_channel.enable_receiving(self.current_type) else: self.respond("150 File status okay. About to open data connection.") self._in_dtp_queue = fd
