diff options
author | maopeng zhang <zhang.maopeng1@zte.com.cn> | 2019-09-05 00:56:32 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2019-09-05 00:56:32 +0000 |
commit | 5fd2ae6a4517980ce0f89247bb354220748ae67b (patch) | |
tree | 0569d08b8eddf72c6c402cd3e8b681ed9e56621a /catalog/packages/biz/common.py | |
parent | 842a4fd77b1c9f93a4b97bd7f138c9b35a855d13 (diff) | |
parent | a32c2b20207885d895bd96204cc166fca14db97b (diff) |
Merge "update for change to etsicatalog"
Diffstat (limited to 'catalog/packages/biz/common.py')
-rw-r--r-- | catalog/packages/biz/common.py | 51 |
1 files changed, 51 insertions, 0 deletions
diff --git a/catalog/packages/biz/common.py b/catalog/packages/biz/common.py new file mode 100644 index 0000000..ce77a41 --- /dev/null +++ b/catalog/packages/biz/common.py @@ -0,0 +1,51 @@ +# Copyright 2018 ZTE Corporation. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +import os + +from catalog.pub.config.config import CATALOG_ROOT_PATH +from catalog.pub.utils import fileutil + +CHUNK_SIZE = 1024 * 8 + + +def save(remote_file, vnf_pkg_id): + local_file_name = remote_file.name + local_file_dir = os.path.join(CATALOG_ROOT_PATH, vnf_pkg_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: + for chunk in remote_file.chunks(chunk_size=CHUNK_SIZE): + local_file.write(chunk) + return local_file_name + + +def read(file_path, start, end): + fp = open(file_path, 'rb') + fp.seek(start) + pos = start + while pos + CHUNK_SIZE < end: + yield fp.read(CHUNK_SIZE) + pos = fp.tell() + yield fp.read(end - pos) + + +def parse_file_range(file_path, file_range): + start, end = 0, os.path.getsize(file_path) + if file_range: + [start, range_end] = file_range.split('-') + range_end = range_end.strip() if range_end.strip() else end + start, end = int(start.strip()), int(range_end) + return start, end |