resume upload part concurrently

.github/workflows/ci-test.yml

@@ -39,7 +39,7 @@ jobs:
         shell: bash -l {0}
         run: |
           python -m pip install --upgrade pip
-          python -m pip install --ignore-installed "coverage<7.2" flake8 pytest pytest-cov freezegun requests scrutinizer-ocular codecov
+          python -m pip install -I -e ".[dev]"
       - name: Run cases
         shell: bash -l {0}
         env:

qiniu/auth.py

@@ -144,6 +144,7 @@ def upload_token(
             key:     上传的文件名，默认为空
             expires: 上传凭证的过期时间，默认为3600s
             policy:  上传策略，默认为空
+            strict_policy:  严格模式，将校验 policy 字段，默认为 True
 
         Returns:
             上传凭证
@@ -175,6 +176,13 @@ def up_token_decode(up_token):
         dict_policy = json.loads(decode_policy)
         return ak, sign, dict_policy
 
+    @staticmethod
+    def get_bucket_name(up_token):
+        _, _, policy = Auth.up_token_decode(up_token)
+        if not policy or not policy['scope']:
+            return None
+        return policy['scope'].split(':', 1)[0]
+
     def __upload_token(self, policy):
         data = json.dumps(policy, separators=(',', ':'))
         return self.token_with_data(data)

qiniu/compat.py

@@ -4,6 +4,7 @@
 pythoncompat
 """
 
+import os
 import sys
 
 try:
@@ -51,6 +52,13 @@ def s(data):
     def u(data):
         return unicode(data, 'unicode_escape')  # noqa
 
+    def is_seekable(data):
+        try:
+            data.seek(0, os.SEEK_CUR)
+            return True
+        except (AttributeError, IOError):
+            return False
+
 elif is_py3:
     from urllib.parse import urlparse  # noqa
     import io
@@ -75,3 +83,6 @@ def s(data):
 
     def u(data):
         return data
+
+    def is_seekable(data):
+        return data.seekable()

qiniu/region.py

@@ -110,6 +110,8 @@ def get_api_host(self, ak, bucket, home_dir=None):
         return api_hosts[0]
 
     def get_up_host(self, ak, bucket, home_dir):
+        if home_dir is None:
+            home_dir = os.getcwd()
         bucket_hosts = self.get_bucket_hosts(ak, bucket, home_dir)
         if 'upHosts' not in bucket_hosts:
             bucket_hosts = self.get_bucket_hosts(ak, bucket, home_dir, force=True)