|
@@ -16,7 +16,7 @@ logger = Log('data-processing').logger
|
|
|
app = Flask('pre_data_ftp——service')
|
|
app = Flask('pre_data_ftp——service')
|
|
|
|
|
|
|
|
ftp_params = {
|
|
ftp_params = {
|
|
|
- 'local_dir' : './data_processing/cache/data',
|
|
|
|
|
|
|
+ 'local_dir' : './syjy/cache/data',
|
|
|
# 'host' : '192.168.12.20',
|
|
# 'host' : '192.168.12.20',
|
|
|
# 'port': 32121,
|
|
# 'port': 32121,
|
|
|
'host': '192.168.1.33',
|
|
'host': '192.168.1.33',
|
|
@@ -122,6 +122,7 @@ def upload_sftp(zip_path, zip_file, args):
|
|
|
sftp_upload(sftp, zip_path, 'STOR /' + ftp_params[args['user']]['modeler'] + '/'+zip_file)
|
|
sftp_upload(sftp, zip_path, 'STOR /' + ftp_params[args['user']]['modeler'] + '/'+zip_file)
|
|
|
# 关闭连接
|
|
# 关闭连接
|
|
|
sftp_close(sftp, ssh)
|
|
sftp_close(sftp, ssh)
|
|
|
|
|
+ shutil.rmtree(os.path.dirname(zip_path))
|
|
|
|
|
|
|
|
def upload_ftp(zip_path, zip_file, args):
|
|
def upload_ftp(zip_path, zip_file, args):
|
|
|
ftp_host, ftp_port, ftp_user, ftp_pass = ftp_params['host'], ftp_params['port'], args['user'], ftp_params[args['user']]['password']
|
|
ftp_host, ftp_port, ftp_user, ftp_pass = ftp_params['host'], ftp_params['port'], args['user'], ftp_params[args['user']]['password']
|
