27 lines
644 B
Python
27 lines
644 B
Python
|
from async import async
|
||
|
|
#~ from logger import logGeneric
|
||
|
|
import socket
|
||
|
|
from ftplib import FTP
|
||
|
|
from io import BytesIO
|
||
|
|
from functools import partial
|
||
|
|
|
||
|
|
def buildUploader(host, port, user, passwd):
|
||
|
|
|
||
|
|
@async(daemon=False)
|
||
|
|
def uploader(filepath, filename, buf):
|
||
|
|
retries = 3
|
||
|
|
ftp = FTP()
|
||
|
|
while retries > 0:
|
||
|
|
try:
|
||
|
|
ftp.connect(host=host, port=port)
|
||
|
|
ftp.login(user=user, passwd=passwd)
|
||
|
|
ftp.cwd(filepath)
|
||
|
|
ftp.storbinary('STOR ' + filename, BytesIO(buf))
|
||
|
|
break
|
||
|
|
except IOError:
|
||
|
|
retries =- 1
|
||
|
|
#~ logGeneric('remoteServer: Failed to upload file. ' + str(retries) + ' retries left...', 0)
|
||
|
|
ftp.quit()
|
||
|
|
|
||
|
|
return uploader
|