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)