我用ftp上传功能把文件上传到我自己的ftp服务器上,它通过以下方式保存除了
2015-12-10 11:35:22,985 - FtpUpload - Failed to setup connection
Exception in thread Thread-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/threading.py", line 810, in __bootstrap_inner
self.run()
File "/usr/lib/python2.7/threading.py", line 763, in run
self.__target(*self.__args, **self.__kwargs)
File "ftp_upload.py", line 122, in upload_queue
queue.put(upload(ifn))
File "ftp_upload.py", line 95, in upload
upload_to_ftp(trans_dst,s3_dst)
File "ftp_upload.py", line 53, in upload_to_ftp
_ftp.connect(server_ip, port)
File "/usr/lib/python2.7/ftplib.py", line 135, in connect
self.sock = socket.create_connection((self.host, self.port), self.timeout)
File "/usr/lib/python2.7/socket.py", line 553, in create_connection
for res in getaddrinfo(host, port, 0, SOCK_STREAM):
gaierror: [Errno -2] Name or service not known
我用其他伪代码测试了我的ftp服务器,它工作正常,这里是我的函数。。在
^{pr2}$上传功能在这里:
def upload(ifn):
""" Upload Function."""
create_time = datetime.now().strftime("%Y/%m/%d")
ifn_norm = resub('[ !@#$%\t"#$%&\()*\-/<=>?@^_`{|},.:]', '-', ifn).lower() + os.path.splitext(ifn)[1]
src = "%s/%s" % (src_loc,ifn)
dst = "%s/%s" % (dst_loc, ifn_norm)
s3_dst = "%s/%s" % (create_time,ifn_norm)
trans_dst = "%s/%s" % (proc_loc,ifn_norm)
start_time = time.time()
try:
transcode(src,trans_dst)
except:
return
trans_time = time.time() - start_time
try:
upload_to_ftp(trans_dst,s3_dst)
# post request will be performed if no exception will raise in upload_to_ftp method
# parameters for this call should be set in config file, because i don't know the url
perform_post_req(trans_dst,s3_dst)
except NameError as s3error:
logger.error("Upload failed for %s , with exception %s" % (trans_dst, s3error))
oflist.remove(ifn)
hsize.pop(ifn)
return
upload_time = (time.time() - start_time) - trans_time
logger.info("Uploading completed for %s, stats - transcode time : %.3f seconds, upload time : %.3f seconds" %(ifn,trans_time,upload_time))
logger.info("Moving \"%s\" to \"%s\"" % (trans_dst, dst))
rc = os.system("mv \"%s\" \"%s\"" %(trans_dst, dst))
if rc != 0:
logger.error("Can't move file %s - Exiting" %(trans_dst))
else:
logger.info("Moved file %s" %(trans_dst))
oflist.remove(ifn)
hsize.pop(ifn)
return
ftp服务器工作正常,经过测试
你能给我个建议吗
根据函数
upload_to_ftp
定义,它期望服务器ip作为第二个参数。在但在调用部分,文件(或目录)路径被传递。在
用服务器ip更改
s3_dst
。在相关问题 更多 >
编程相关推荐