add create_bucket example

examples/create_bucket.py

@@ -0,0 +1,25 @@
+# -*- coding: utf-8 -*-
+"""
+创建存储空间
+"""
+
+from qiniu import Auth
+from qiniu import BucketManager
+
+
+access_key = '...'
+secret_key = '...'
+
+q = Auth(access_key, secret_key)
+
+bucket = BucketManager(q)
+
+bucket_name = 'Bucket_Name'
+
+# "填写存储区域代号  z0:华东, z1:华北, z2:华南, na0:北美"
+region = 'z0'
+
+ret, info = bucket.mkbucketv2(bucket_name, region)
+print(info)
+print(ret)
+assert info.status_code == 200

qiniu/services/processing/pfop.py

@@ -29,7 +29,7 @@ def execute(self, key, fops, force=None):
 
         Args:
             key:    待处理的源文件
-            fops:   处理详细操作，规格详见 http://developer.qiniu.com/docs/v6/api/reference/fop/
+            fops:   处理详细操作，规格详见 https://developer.qiniu.com/dora/manual/1291/persistent-data-processing-pfop
             force:  强制执行持久化处理开关
 
         Returns:

qiniu/services/storage/bucket.py

@@ -283,6 +283,18 @@ def delete_after_days(self, bucket, key, days):
         resource = entry(bucket, key)
         return self.__rs_do('deleteAfterDays', resource, days)
 
+    def mkbucketv2(self, bucket_name, region):
+        """
+        创建存储空间
+        https://developer.qiniu.com/kodo/api/1382/mkbucketv2
+
+        Args:
+            bucket_name: 存储空间名
+            region: 存储区域
+        """
+        bucket_name = urlsafe_base64_encode(bucket_name)
+        return self.__rs_do('mkbucketv2', bucket_name, 'region', region)
+
     def __rs_do(self, operation, *args):
         return self.__server_do(config.get_default('default_rs_host'), operation, *args)