import logging
+import os
import uuid
+from catalog.pub.config.config import CATALOG_ROOT_PATH
+from catalog.pub.utils import fileutil
from catalog.pub.utils.values import ignore_case_get
logger = logging.getLogger(__name__)
return data
-def upload(files, nsdInfoId):
- pass
+def upload(files, nsd_info_id):
+ remote_files = files
+ for remote_file in remote_files:
+ local_file_name = remote_file.name
+ local_file_dir = os.path.join(CATALOG_ROOT_PATH, nsd_info_id)
+ local_file_name = os.path.join(local_file_dir, local_file_name)
+ if not os.path.exists(local_file_dir):
+ fileutil.make_dirs(local_file_dir)
+ with open(local_file_name, 'wb') as local_file:
+ if remote_file.multiple_chunks(chunk_size=None):
+ for chunk in remote_file.chunks():
+ local_file.write(chunk)
+ else:
+ data = remote_file.read()
+ local_file.write(data)